Upstox .NET SDK for API v2

Introduction

The official .NET client for communicating with the Upstox API.

Upstox API is a set of rest APIs that provide data required to build a complete investment and trading platform. Execute orders in real time, manage user portfolio, stream live market data (using Websocket), and more, with the easy to understand API collection.

API version: v2
Package version: 2.2.0
Build package: org.openapitools.codegen.languages.CSharpClientCodegen

This .NET package is automatically generated by the OpenAPI Generator project.

Documentation

Upstox API Documentation

Requirements

.NET 8.0+

Installation & Usage

NuGet Package Manager

Install-Package upstox-dotnet-sdk

.NET CLI

dotnet add package upstox-dotnet-sdk

Sandbox Mode

We recommend using the sandbox environment for testing purposes. To enable sandbox mode, set the Sandbox flag to true in the configuration object.

public class Program
    {
        public static async Task Main(string[] args)
        {
            var host = Host.CreateDefaultBuilder(args)
                .ConfigureApi((context, services, options) =>
                {
                    var token = new OAuthToken("{your_access_token}");
                    options.AddTokens(token);
                    options.Sandbox = true; // Enable sandbox mode
                }).Build();
            await host.StartAsync();

            try
            {

                var orderApi = host.Services.GetRequiredService<IOrderV3Api>();

                // Create order request
                var orderRequest = new PlaceOrderV3Request(
                    quantity: 1,
                    product: PlaceOrderV3Request.ProductEnum.D,
                    validity: PlaceOrderV3Request.ValidityEnum.DAY,
                    price: 10,
                    instrumentToken: "NSE_EQ|INE669E01016",
                    orderType: PlaceOrderV3Request.OrderTypeEnum.LIMIT,
                    transactionType: PlaceOrderV3Request.TransactionTypeEnum.BUY,
                    disclosedQuantity: 0,
                    triggerPrice: 0,
                    isAmo: false
                );
                var response = await orderApi.PlaceOrderAsync(orderRequest);
                Console.WriteLine(response.RawContent);
            }
            catch (Exception ex)
            {
                Console.WriteLine($"Error: {ex.Message}");
            }
            await host.StopAsync();
        }
    }
}

To learn more about the sandbox environment and the available sandbox APIs, please visit the Upstox API documentation - Sandbox.

Algo Name Support

The SDK supports passing an algorithm name for order tracking and management. When provided, the SDK will pass the algo name as X-Algo-Name header.

public class Program
    {
        public static async Task Main(string[] args)
        {
            var host = Host.CreateDefaultBuilder(args)
                .ConfigureApi((context, services, options) =>
                {
                    var token = new OAuthToken("{your_access_token}");
                    options.AddTokens(token);
                }).Build();
            await host.StartAsync();

            try
            {

                var orderApi = host.Services.GetRequiredService<IOrderV3Api>();

                // Create order request
                var orderRequest = new PlaceOrderV3Request(
                    quantity: 1,
                    product: PlaceOrderV3Request.ProductEnum.D,
                    validity: PlaceOrderV3Request.ValidityEnum.DAY,
                    price: 10,
                    instrumentToken: "NSE_EQ|INE669E01016",
                    orderType: PlaceOrderV3Request.OrderTypeEnum.LIMIT,
                    transactionType: PlaceOrderV3Request.TransactionTypeEnum.BUY,
                    disclosedQuantity: 0,
                    triggerPrice: 0,
                    isAmo: false
                );
                var response = await orderApi.PlaceOrderAsync(orderRequest, algoName: "name");
                Console.WriteLine(response.RawContent);
            }
            catch (Exception ex)
            {
                Console.WriteLine($"Error: {ex.Message}");
            }
            await host.StopAsync();
        }
    }
}

Other order methods (modify, cancel, etc.) follow the same pattern by accepting an optional algoName as a keyword parameter.

Documentation for Feeder Functions

Connecting to the WebSocket for market and portfolio updates is streamlined through two primary Feeder functions:

MarketDataStreamerV3: Offers real-time market updates, providing a seamless way to receive instantaneous information on various market instruments.
PortfolioDataStreamer: Delivers updates related to the user's orders, enhancing the ability to track order status and portfolio changes effectively.

Both functions are designed to simplify the process of subscribing to essential data streams, ensuring users have quick and easy access to the information they need.

Detailed Explanation of Feeder Interface

MarketDataStreamerV3

The MarketDataStreamerV3 interface is designed for effortless connection to the market WebSocket, enabling users to receive instantaneous updates on various instruments. The following example demonstrates how to quickly set up and start receiving market updates for selected instrument keys:

using System;
using System.Collections.Generic;
using Microsoft.Extensions.DependencyInjection;
using UpstoxClient.Api;
using UpstoxClient.Feeder;
using UpstoxClient.Feeder.Listener;
using UpstoxClient.Feeder.Model;

public class Program
    {
        public class OnMarketUpdateListenerImpl : IOnMarketUpdateV3Listener
        {
            public Task OnUpdateAsync(MarketUpdateV3 marketUpdate)
            {
                Console.WriteLine(marketUpdate);
                return Task.CompletedTask;
            }
        }
        public static async Task Main(string[] args)
        {
            var host = Host.CreateDefaultBuilder(args)
                .ConfigureApi((context, services, options) =>
                {
                    var token = new OAuthToken("{your_access_token}");
                    options.AddTokens(token);
                }).Build();
            await host.StartAsync();

            try
            {

                IWebsocketApi websocketApi = host.Services.GetRequiredService<IWebsocketApi>();

                var instrumentKeys = new HashSet<string> { "NSE_INDEX|Nifty 50", "NSE_INDEX|Nifty Bank" };
                var streamer = new MarketDataStreamerV3(websocketApi, instrumentKeys, Feeder.Constants.Mode.FULL);

                streamer.SetOnMarketUpdateListener(new OnMarketUpdateListenerImpl());

                await streamer.ConnectAsync();


                Console.WriteLine("Press any key to stop and disconnect...");

                // Wait for user input to keep the connection alive
                await Task.Run(() => Console.ReadKey(true));

                Console.WriteLine("\nDisconnecting...");
                await streamer.DisconnectAsync();

            }
            catch (Exception ex)
            {
                Console.WriteLine($"Error: {ex.Message}");
            }
            await host.StopAsync();
        }
    }

In this example, you first obtain the WebSocket API service from dependency injection, then instantiate MarketDataStreamerV3 with specific instrument keys and a subscription mode. Upon connecting, the streamer listens for market updates, which are logged to the console as they arrive.

Modes

LTPC: Provides information solely about the most recent trade, encompassing details such as the last trade price, time of the last trade, quantity traded, and the closing price from the previous day.
FULL: The full option offers comprehensive information, including the latest trade prices, D5 depth, 1-minute, 30-minute, and daily candlestick data, along with some additional details.
OPTION_GREEKS: Contains only option greeks.
FULL_D30: Includes Full mode data plus 30 market level quotes.

Functions

constructor MarketDataStreamerV3(IWebsocketApi websocketApi): Initializes the streamer without initial subscriptions.
constructor MarketDataStreamerV3(IWebsocketApi websocketApi, ISet<string> instrumentKeys, Mode mode): Initializes the streamer with optional instrument keys and mode (FULL, LTPC, OPTION_GREEKS or FULL_D30).
ConnectAsync(): Establishes the WebSocket connection.
SubscribeAsync(ISet<string> instrumentKeys, Mode mode): Subscribes to updates for given instrument keys in the specified mode. Both parameters are mandatory.
UnsubscribeAsync(ISet<string> instrumentKeys): Stops updates for the specified instrument keys.
ChangeModeAsync(ISet<string> instrumentKeys, Mode newMode): Switches the mode for already subscribed instrument keys.
DisconnectAsync(): Ends the active WebSocket connection.
AutoReconnect(bool enable): Enables or disables auto-reconnect functionality with default parameters.
AutoReconnect(bool enable, int intervalSeconds, int retryCount): Customizes auto-reconnect functionality. Parameters include a flag to enable/disable it, the interval (in seconds) between attempts, and the maximum number of retries.

Events/Listeners

SetOnOpenListener(IOnOpenListener listener): Emitted upon successful connection establishment.
SetOnCloseListener(IOnCloseListener listener): Indicates the WebSocket connection has been closed.
SetOnMarketUpdateListener(IOnMarketUpdateV3Listener listener): Delivers market updates.
SetOnErrorListener(IOnErrorListener listener): Signals an error has occurred.
SetOnReconnectingListener(IOnReconnectingListener listener): Announced when a reconnect attempt is initiated.
SetOnAutoReconnectStoppedListener(IOnAutoReconnectStoppedListener listener): Informs when auto-reconnect efforts have ceased after exhausting the retry count.

The following documentation includes examples to illustrate the usage of these functions and listeners, providing a practical understanding of how to interact with the MarketDataStreamerV3 effectively.

Subscribing to Instruments with Delays

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Microsoft.Extensions.DependencyInjection;
using UpstoxClient.Api;
using UpstoxClient.Feeder;
using UpstoxClient.Feeder.Listener;
using UpstoxClient.Feeder.Model;

public class Program
    {
        public class OnMarketUpdateListenerImpl : IOnMarketUpdateV3Listener
        {
            public Task OnUpdateAsync(MarketUpdateV3 marketUpdate)
            {
                Console.WriteLine(marketUpdate);
                return Task.CompletedTask;
            }
        }
        public class OnOpenListenerImpl : IOnOpenListener
        {
            public Task OnOpenAsync()
            {
                Console.WriteLine("Connected.");
                return Task.CompletedTask;
            }
        }
        public static async Task Main(string[] args)
        {
            var host = Host.CreateDefaultBuilder(args)
                .ConfigureApi((context, services, options) =>
                {
                    var token = new OAuthToken("{your_access_token}");
                    options.AddTokens(token);
                }).Build();
            await host.StartAsync();

            try
            {

                IWebsocketApi websocketApi = host.Services.GetRequiredService<IWebsocketApi>();

                var streamer = new MarketDataStreamerV3(websocketApi);

                var onOpenListener = new OnOpenListenerImpl();
                var onMessageListener = new OnMarketUpdateListenerImpl();

                streamer.SetOnOpenListener(onOpenListener);
                streamer.SetOnMarketUpdateListener(onMessageListener);

                await streamer.ConnectAsync();

                await Task.Delay(5000);
                var instrumentKeys = new HashSet<string> { "NSE_EQ|INE020B01018" };
                await streamer.SubscribeAsync(instrumentKeys, Feeder.Constants.Mode.FULL);

                Console.WriteLine("Press any key to stop and disconnect...");

                await Task.Run(() => Console.ReadKey(true));

                Console.WriteLine("\nDisconnecting...");
                await streamer.DisconnectAsync();

            }
            catch (Exception ex)
            {
                Console.WriteLine($"Error: {ex.Message}");
            }
            await host.StopAsync();
        }
    }

Subscribing and Unsubscribing to Instruments

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Microsoft.Extensions.DependencyInjection;
using UpstoxClient.Api;
using UpstoxClient.Feeder;
using UpstoxClient.Feeder.Listener;
using UpstoxClient.Feeder.Model;

public class Program
    {
        public class OnMarketUpdateListenerImpl : IOnMarketUpdateV3Listener
        {
            public Task OnUpdateAsync(MarketUpdateV3 marketUpdate)
            {
                Console.WriteLine(marketUpdate);
                return Task.CompletedTask;
            }
        }
        public class OnOpenListenerImpl : IOnOpenListener
        {
            public Task OnOpenAsync()
            {
                Console.WriteLine("Connected.");
                return Task.CompletedTask;
            }
        }
        public static async Task Main(string[] args)
        {
            var host = Host.CreateDefaultBuilder(args)
                .ConfigureApi((context, services, options) =>
                {
                    var token = new OAuthToken("{your_access_token}");
                    options.AddTokens(token);
                }).Build();
            await host.StartAsync();

            try
            {
                IWebsocketApi websocketApi = host.Services.GetRequiredService<IWebsocketApi>();

                var streamer = new MarketDataStreamerV3(websocketApi);

                var onOpenListener = new OnOpenListenerImpl();
                var onMessageListener = new OnMarketUpdateListenerImpl();

                streamer.SetOnOpenListener(onOpenListener);
                streamer.SetOnMarketUpdateListener(onMessageListener);

                await streamer.ConnectAsync();

                await streamer.SubscribeAsync(new HashSet<string> { "NSE_INDEX|Nifty 50" , "NSE_EQ|INE020B01018"}, Feeder.Constants.Mode.FULL);
                await Task.Delay(5000);
                Console.WriteLine("Unsubscribing from instrument keys.");
                var instrumentKeys = new HashSet<string> { "NSE_EQ|INE020B01018" };
                await streamer.UnsubscribeAsync(instrumentKeys);

                Console.WriteLine("Press any key to stop and disconnect...");

                // Wait for user input to keep the connection alive
                await Task.Run(() => Console.ReadKey(true));

                Console.WriteLine("\nDisconnecting...");
                await streamer.DisconnectAsync();

            }
            catch (Exception ex)
            {
                Console.WriteLine($"Error: {ex.Message}");
            }
            await host.StopAsync();
        }
    }

Subscribe, Change Mode and Unsubscribe

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Microsoft.Extensions.DependencyInjection;
using UpstoxClient.Api;
using UpstoxClient.Feeder;
using UpstoxClient.Feeder.Listener;
using UpstoxClient.Feeder.Model;

public class Program
    {
        public class OnMarketUpdateListenerImpl : IOnMarketUpdateV3Listener
        {
            public Task OnUpdateAsync(MarketUpdateV3 marketUpdate)
            {
                Console.WriteLine(marketUpdate);
                return Task.CompletedTask;
            }
        }
        public class OnOpenListenerImpl : IOnOpenListener
        {
            public Task OnOpenAsync()
            {
                Console.WriteLine("Connected.");
                return Task.CompletedTask;
            }
        }
        public static async Task Main(string[] args)
        {
            var host = Host.CreateDefaultBuilder(args)
                .ConfigureApi((context, services, options) =>
                {
                    var token = new OAuthToken("{your_access_token}");
                    options.AddTokens(token);
                }).Build();
            await host.StartAsync();

            try
            {
                IWebsocketApi websocketApi = host.Services.GetRequiredService<IWebsocketApi>();

                var streamer = new MarketDataStreamerV3(websocketApi);

                var onOpenListener = new OnOpenListenerImpl();
                var onMessageListener = new OnMarketUpdateListenerImpl();

                streamer.SetOnOpenListener(onOpenListener);
                streamer.SetOnMarketUpdateListener(onMessageListener);

                await streamer.ConnectAsync();

                await Task.Delay(5000);
                Console.WriteLine("Changing subscription mode to LTPC...");
                var instrumentKeys = new HashSet<string> { "NSE_EQ|INE020B01018", "NSE_EQ|INE467B01029" };
                await streamer.ChangeModeAsync(instrumentKeys, Feeder.Constants.Mode.LTPC);

                await Task.Delay(5000);
                Console.WriteLine("Unsubscribing from instrument keys.");
                await streamer.UnsubscribeAsync(instrumentKeys);


                Console.WriteLine("Press any key to stop and disconnect...");

                // Wait for user input to keep the connection alive
                await Task.Run(() => Console.ReadKey(true));

                Console.WriteLine("\nDisconnecting...");
                await streamer.DisconnectAsync();

            }
            catch (Exception ex)
            {
                Console.WriteLine($"Error: {ex.Message}");
            }
            await host.StopAsync();
        }
    }

Disable Auto-Reconnect

using System;
using System.Threading.Tasks;
using Microsoft.Extensions.DependencyInjection;
using UpstoxClient.Api;
using UpstoxClient.Feeder;
using UpstoxClient.Feeder.Listener;

public class Program
    {
        public class OnMarketUpdateListenerImpl : IOnMarketUpdateV3Listener
        {
            public Task OnUpdateAsync(MarketUpdateV3 marketUpdate)
            {
                Console.WriteLine(marketUpdate);
                return Task.CompletedTask;
            }
        }
        public class OnOpenListenerImpl : IOnOpenListener
        {
            public Task OnOpenAsync()
            {
                Console.WriteLine("Connected.");
                return Task.CompletedTask;
            }
        }
        public class OnAutoReconnectStoppedListenerImpl : IOnAutoReconnectStoppedListener
        {
            public Task OnHaultAsync(string message)
            {
                Console.WriteLine(message);
                return Task.CompletedTask;
            }
        }
        public static async Task Main(string[] args)
        {
            var host = Host.CreateDefaultBuilder(args)
                .ConfigureApi((context, services, options) =>
                {
                    var token = new OAuthToken("{your_access_token}");
                    options.AddTokens(token);
                }).Build();
            await host.StartAsync();

            try
            {
                IWebsocketApi websocketApi = host.Services.GetRequiredService<IWebsocketApi>();

                var streamer = new MarketDataStreamerV3(websocketApi);

                var onReconnectStoppedListener = new OnAutoReconnectStoppedListenerImpl();
                streamer.SetOnAutoReconnectStoppedListener(onReconnectStoppedListener);

                // Disable auto-reconnect feature
                streamer.AutoReconnect(false);

                await streamer.ConnectAsync();

                Console.WriteLine("Press any key to stop and disconnect...");

                // Wait for user input to keep the connection alive
                await Task.Run(() => Console.ReadKey(true));

                Console.WriteLine("\nDisconnecting...");
                await streamer.DisconnectAsync();

            }
            catch (Exception ex)
            {
                Console.WriteLine($"Error: {ex.Message}");
            }
            await host.StopAsync();
        }
    }

Modify Auto-Reconnect parameters

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Microsoft.Extensions.DependencyInjection;
using UpstoxClient.Api;
using UpstoxClient.Feeder;
using UpstoxClient.Feeder.Listener;
using UpstoxClient.Feeder.Model;

public class Program
    {
        public class OnMarketUpdateListenerImpl : IOnMarketUpdateV3Listener
        {
            public Task OnUpdateAsync(MarketUpdateV3 marketUpdate)
            {
                Console.WriteLine(marketUpdate);
                return Task.CompletedTask;
            }
        }
        public class OnOpenListenerImpl : IOnOpenListener
        {
            public Task OnOpenAsync()
            {
                Console.WriteLine("Connected.");
                return Task.CompletedTask;
            }
        }
        public static async Task Main(string[] args)
        {
            var host = Host.CreateDefaultBuilder(args)
                .ConfigureApi((context, services, options) =>
                {
                    var token = new OAuthToken("{your_access_token}");
                    options.AddTokens(token);
                }).Build();
            await host.StartAsync();

            try
            {

                IWebsocketApi websocketApi = host.Services.GetRequiredService<IWebsocketApi>();

                var streamer = new MarketDataStreamerV3(websocketApi);

                var onOpenListener = new OnOpenListenerImpl();
                var onMessageListener = new OnMarketUpdateListenerImpl();

                streamer.SetOnOpenListener(onOpenListener);
                streamer.SetOnMarketUpdateListener(onMessageListener);

                await streamer.ConnectAsync();

                // Modify auto-reconnect parameters: enable it, set interval to 10 seconds, and retry count to 3
                streamer.AutoReconnect(true, 10, 3);

                await Task.Delay(5000);
                var instrumentKeys = new HashSet<string> { "NSE_EQ|INE020B01018" };
                await streamer.SubscribeAsync(instrumentKeys, Feeder.Constants.Mode.FULL);

                Console.WriteLine("Press any key to stop and disconnect...");

                await Task.Run(() => Console.ReadKey(true));

                Console.WriteLine("\nDisconnecting...");
                await streamer.DisconnectAsync();

            }
            catch (Exception ex)
            {
                Console.WriteLine($"Error: {ex.Message}");
            }
            await host.StopAsync();
        }
    }

PortfolioDataStreamer

Connecting to the Portfolio WebSocket for real-time order updates is straightforward with the PortfolioDataStreamer function. Below is a concise guide to get you started on receiving updates:

using System;
using System.Threading.Tasks;
using Microsoft.Extensions.DependencyInjection;
using UpstoxClient.Api;
using UpstoxClient.Feeder;
using UpstoxClient.Feeder.Listener;
using UpstoxClient.Feeder.Model;

public class Program
    {
        public class OnOrderUpdateListenerImpl : IOnOrderUpdateListener
        {
            public Task OnUpdateAsync(OrderUpdate orderUpdate)
            {
                Console.WriteLine(orderUpdate);
                return Task.CompletedTask;
            }
        }

        public static async Task Main(string[] args)
        {
            var host = Host.CreateDefaultBuilder(args)
                .ConfigureApi((context, services, options) =>
                {
                    var token = new OAuthToken("{your_access_token}");
                    options.AddTokens(token);
                }).Build();
            await host.StartAsync();

            try
            {
                IWebsocketApi websocketApi = host.Services.GetRequiredService<IWebsocketApi>();

                var streamer = new PortfolioDataStreamer(websocketApi);

                streamer.SetOnOrderUpdateListener(new OnOrderUpdateListenerImpl());

                await streamer.ConnectAsync();

                Console.WriteLine("Press any key to stop and disconnect...");

                await Task.Run(() => Console.ReadKey(true));

                Console.WriteLine("\nDisconnecting...");
                await streamer.DisconnectAsync();

            }
            catch (Exception ex)
            {
                Console.WriteLine($"Error: {ex.Message}");
            }
            await host.StopAsync();
        }
    }

Position, holding, and GTT order updates can be enabled by setting the corresponding flag to true in the constructor of the PortfolioDataStreamer class.

using System;
using System.Threading.Tasks;
using Microsoft.Extensions.DependencyInjection;
using UpstoxClient.Api;
using UpstoxClient.Feeder;
using UpstoxClient.Feeder.Listener;
using UpstoxClient.Feeder.Model;

public class Program
    {
        public class OnOpenListenerImpl : IOnOpenListener
        {
            public Task OnOpenAsync()
            {
                Console.WriteLine("Connection opened");
                return Task.CompletedTask;
            }
        }
        public class OnOrderUpdateListenerImpl : IOnOrderUpdateListener
        {
            public Task OnUpdateAsync(OrderUpdate orderUpdate)
            {
                Console.WriteLine(orderUpdate);
                return Task.CompletedTask;
            }
        }

        public class OnPositionUpdateListenerImpl : IOnPositionUpdateListener
        {
            public Task OnUpdateAsync(PositionUpdate positionUpdate)
            {
                Console.WriteLine(positionUpdate);
                return Task.CompletedTask;
            }
        }

        public class OnHoldingUpdateListenerImpl : IOnHoldingUpdateListener
        {
            public Task OnUpdateAsync(HoldingUpdate holdingUpdate)
            {
                Console.WriteLine(holdingUpdate);
                return Task.CompletedTask;
            }
        }

        public class OnGttUpdateListenerImpl : IOnGttUpdateListener
        {
            public Task OnUpdateAsync(GttUpdate gttUpdate)
            {
                Console.WriteLine(gttUpdate);
                return Task.CompletedTask;
            }
        }

        public static async Task Main(string[] args)
        {
            var host = Host.CreateDefaultBuilder(args)
                .ConfigureApi((context, services, options) =>
                {
                    var token = new OAuthToken("{your_access_token}");
                    options.AddTokens(token);
                }).Build();
            await host.StartAsync();

            try
            {
                IWebsocketApi websocketApi = host.Services.GetRequiredService<IWebsocketApi>();

                var streamer = new PortfolioDataStreamer(
                    websocketApi,
                    orderUpdate: true,
                    positionUpdate: true,
                    holdingUpdate: true,
                    gttUpdate: true);

                streamer.SetOnOrderUpdateListener(new OnOrderUpdateListenerImpl());
                streamer.SetOnPositionUpdateListener(new OnPositionUpdateListenerImpl());
                streamer.SetOnHoldingUpdateListener(new OnHoldingUpdateListenerImpl());
                streamer.SetOnGttUpdateListener(new OnGttUpdateListenerImpl());
                streamer.SetOnOpenListener(new OnOpenListenerImpl());

                await streamer.ConnectAsync();

                Console.WriteLine("Press any key to stop and disconnect...");

                await Task.Run(() => Console.ReadKey(true));

                Console.WriteLine("\nDisconnecting...");
                await streamer.DisconnectAsync();

            }
            catch (Exception ex)
            {
                Console.WriteLine($"Error: {ex.Message}");
            }
            await host.StopAsync();
        }
    }

Exploring the PortfolioDataStreamer Functionality

Constructor Parameters

websocketApi: Your API client instance (required)
orderUpdate: Set to true to receive real-time order updates (default: true)
positionUpdate: Set to true to receive position updates (default: false)
holdingUpdate: Set to true to receive holding updates (default: false)
gttUpdate: Set to true to receive GTT order updates (default: false)

Functions

constructor PortfolioDataStreamer(IWebsocketApi websocketApi): Initializes the streamer with only order updates enabled.
constructor PortfolioDataStreamer(IWebsocketApi websocketApi, bool orderUpdate, bool positionUpdate, bool holdingUpdate): Initializes the streamer with specified update types (gttUpdate defaults to false).
constructor PortfolioDataStreamer(IWebsocketApi websocketApi, bool orderUpdate, bool positionUpdate, bool holdingUpdate, bool gttUpdate): Initializes the streamer with all update types configurable.
ConnectAsync(): Establishes the WebSocket connection.
DisconnectAsync(): Ends the active WebSocket connection.
AutoReconnect(bool enable): Enables or disables auto-reconnect functionality with default parameters.
AutoReconnect(bool enable, int intervalSeconds, int retryCount): Customizes auto-reconnect functionality. Parameters include a flag to enable/disable it, the interval (in seconds) between attempts, and the maximum number of retries.

Events/Listeners

SetOnOpenListener(IOnOpenListener listener): Emitted upon successful connection establishment.
SetOnCloseListener(IOnCloseListener listener): Indicates the WebSocket connection has been closed.
SetOnOrderUpdateListener(IOnOrderUpdateListener listener): Delivers order updates (when enabled).
SetOnPositionUpdateListener(IOnPositionUpdateListener listener): Delivers position updates (when enabled).
SetOnHoldingUpdateListener(IOnHoldingUpdateListener listener): Delivers holding updates (when enabled).
SetOnGttUpdateListener(IOnGttUpdateListener listener): Delivers GTT order updates (when enabled).
SetOnErrorListener(IOnErrorListener listener): Signals an error has occurred.
SetOnReconnectingListener(IOnReconnectingListener listener): Announced when a reconnect attempt is initiated.
SetOnAutoReconnectStoppedListener(IOnAutoReconnectStoppedListener listener): Informs when auto-reconnect efforts have ceased after exhausting the retry count.

Name		Name	Last commit message	Last commit date
Latest commit History 26 Commits
.github/workflows		.github/workflows
docs		docs
src		src
.gitignore		.gitignore
README.md		README.md
UpstoxClient.sln		UpstoxClient.sln
appveyor.yml		appveyor.yml

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Repository files navigation

Upstox .NET SDK for API v2

Introduction

Documentation

Requirements

Installation & Usage

NuGet Package Manager

.NET CLI

Sandbox Mode

Algo Name Support

Documentation for Feeder Functions

Detailed Explanation of Feeder Interface

MarketDataStreamerV3

Modes

Functions

Events/Listeners

PortfolioDataStreamer

Exploring the PortfolioDataStreamer Functionality

Constructor Parameters

Functions

Events/Listeners

About

Uh oh!

Releases 6

Packages

Uh oh!

Contributors 4

Uh oh!

Languages

upstox/upstox-dotnet

Folders and files

Latest commit

History

Repository files navigation

Upstox .NET SDK for API v2

Introduction

Documentation

Requirements

Installation & Usage

NuGet Package Manager

.NET CLI

Sandbox Mode

Algo Name Support

Documentation for Feeder Functions

Detailed Explanation of Feeder Interface

MarketDataStreamerV3

Modes

Functions

Events/Listeners

PortfolioDataStreamer

Exploring the PortfolioDataStreamer Functionality

Constructor Parameters

Functions

Events/Listeners

About

Resources

Uh oh!

Stars

Watchers

Forks

Releases 6

Packages 0

Uh oh!

Contributors 4

Uh oh!

Languages

Packages