▽

Package kaikosdk

Constants

const (
    StreamAggregatedPriceServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamAggregatedPriceServiceV1/Subscribe"
)

const (
    StreamAggregatedQuoteServiceV2_Subscribe_FullMethodName = "/kaikosdk.StreamAggregatedQuoteServiceV2/Subscribe"
)

const (
    StreamAggregatedStatePriceServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamAggregatedStatePriceServiceV1/Subscribe"
)

const (
    StreamAggregatesOHLCVServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamAggregatesOHLCVServiceV1/Subscribe"
)

const (
    StreamAggregatesSpotDirectExchangeRateV2ServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamAggregatesSpotDirectExchangeRateV2ServiceV1/Subscribe"
)

const (
    StreamAggregatesSpotExchangeRateV2ServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamAggregatesSpotExchangeRateV2ServiceV1/Subscribe"
)

const (
    StreamAggregatesVWAPServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamAggregatesVWAPServiceV1/Subscribe"
)

const (
    StreamDerivativesInstrumentMetricsServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamDerivativesInstrumentMetricsServiceV1/Subscribe"
)

const (
    StreamExoticIndicesServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamExoticIndicesServiceV1/Subscribe"
)

const (
    StreamIndexForexRateServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamIndexForexRateServiceV1/Subscribe"
)

const (
    StreamIndexMultiAssetsServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamIndexMultiAssetsServiceV1/Subscribe"
)

const (
    StreamIndexServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamIndexServiceV1/Subscribe"
)

const (
    StreamIvSviParametersServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamIvSviParametersServiceV1/Subscribe"
)

const (
    StreamMarketUpdateServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamMarketUpdateServiceV1/Subscribe"
)

const (
    StreamOrderbookL2ReplayServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamOrderbookL2ReplayServiceV1/Subscribe"
)

const (
    StreamOrderbookL2ServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamOrderbookL2ServiceV1/Subscribe"
)

const (
    StreamTradesServiceV1_Subscribe_FullMethodName = "/kaikosdk.StreamTradesServiceV1/Subscribe"
)

Variables

var File_sdk_sdk_proto FileDescriptor

StreamAggregatedPriceServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamAggregatedPriceServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamAggregatedPriceServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamAggregatedPriceServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamAggregatedPriceServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamAggregatedQuoteServiceV2_ServiceDesc is the grpc.ServiceDesc for StreamAggregatedQuoteServiceV2 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamAggregatedQuoteServiceV2_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamAggregatedQuoteServiceV2",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamAggregatedQuoteServiceV2_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamAggregatedStatePriceServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamAggregatedStatePriceServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamAggregatedStatePriceServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamAggregatedStatePriceServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamAggregatedStatePriceServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamAggregatesOHLCVServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamAggregatesOHLCVServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamAggregatesOHLCVServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamAggregatesOHLCVServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamAggregatesOHLCVServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamAggregatesSpotDirectExchangeRateV2ServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamAggregatesSpotDirectExchangeRateV2ServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamAggregatesSpotDirectExchangeRateV2ServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamAggregatesSpotDirectExchangeRateV2ServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamAggregatesSpotDirectExchangeRateV2ServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamAggregatesSpotExchangeRateV2ServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamAggregatesSpotExchangeRateV2ServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamAggregatesSpotExchangeRateV2ServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamAggregatesSpotExchangeRateV2ServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamAggregatesSpotExchangeRateV2ServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamAggregatesVWAPServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamAggregatesVWAPServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamAggregatesVWAPServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamAggregatesVWAPServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamAggregatesVWAPServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamDerivativesInstrumentMetricsServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamDerivativesInstrumentMetricsServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamDerivativesInstrumentMetricsServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamDerivativesInstrumentMetricsServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamDerivativesInstrumentMetricsServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamExoticIndicesServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamExoticIndicesServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamExoticIndicesServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamExoticIndicesServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamExoticIndicesServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamIndexForexRateServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamIndexForexRateServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamIndexForexRateServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamIndexForexRateServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamIndexForexRateServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamIndexMultiAssetsServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamIndexMultiAssetsServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamIndexMultiAssetsServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamIndexMultiAssetsServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamIndexMultiAssetsServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamIndexServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamIndexServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamIndexServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamIndexServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamIndexServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamIvSviParametersServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamIvSviParametersServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamIvSviParametersServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamIvSviParametersServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamIvSviParametersServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamMarketUpdateServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamMarketUpdateServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamMarketUpdateServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamMarketUpdateServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamMarketUpdateServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamOrderbookL2ReplayServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamOrderbookL2ReplayServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamOrderbookL2ReplayServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamOrderbookL2ReplayServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamOrderbookL2ReplayServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamOrderbookL2ServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamOrderbookL2ServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamOrderbookL2ServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamOrderbookL2ServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamOrderbookL2ServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

StreamTradesServiceV1_ServiceDesc is the grpc.ServiceDesc for StreamTradesServiceV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var StreamTradesServiceV1_ServiceDesc = ServiceDesc{
    ServiceName: "kaikosdk.StreamTradesServiceV1",
    nil),
    MethodDesc{},
    StreamDesc{
        {
            StreamName:    "Subscribe",
            Handler:       _StreamTradesServiceV1_Subscribe_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "sdk/sdk.proto",
}

func RegisterStreamAggregatedPriceServiceV1Server ¶

func RegisterStreamAggregatedPriceServiceV1Server(s StreamAggregatedPriceServiceV1Server)

func RegisterStreamAggregatedQuoteServiceV2Server ¶

func RegisterStreamAggregatedQuoteServiceV2Server(s StreamAggregatedQuoteServiceV2Server)

func RegisterStreamAggregatedStatePriceServiceV1Server ¶

func RegisterStreamAggregatedStatePriceServiceV1Server(s StreamAggregatedStatePriceServiceV1Server)

func RegisterStreamAggregatesOHLCVServiceV1Server ¶

func RegisterStreamAggregatesOHLCVServiceV1Server(s StreamAggregatesOHLCVServiceV1Server)

func RegisterStreamAggregatesSpotDirectExchangeRateV2ServiceV1Server ¶

func RegisterStreamAggregatesSpotDirectExchangeRateV2ServiceV1Server(s StreamAggregatesSpotDirectExchangeRateV2ServiceV1Server)

func RegisterStreamAggregatesSpotExchangeRateV2ServiceV1Server ¶

func RegisterStreamAggregatesSpotExchangeRateV2ServiceV1Server(s StreamAggregatesSpotExchangeRateV2ServiceV1Server)

func RegisterStreamAggregatesVWAPServiceV1Server ¶

func RegisterStreamAggregatesVWAPServiceV1Server(s StreamAggregatesVWAPServiceV1Server)

func RegisterStreamDerivativesInstrumentMetricsServiceV1Server ¶

func RegisterStreamDerivativesInstrumentMetricsServiceV1Server(s StreamDerivativesInstrumentMetricsServiceV1Server)

func RegisterStreamExoticIndicesServiceV1Server ¶

func RegisterStreamExoticIndicesServiceV1Server(s StreamExoticIndicesServiceV1Server)

func RegisterStreamIndexForexRateServiceV1Server ¶

func RegisterStreamIndexForexRateServiceV1Server(s StreamIndexForexRateServiceV1Server)

func RegisterStreamIndexMultiAssetsServiceV1Server ¶

func RegisterStreamIndexMultiAssetsServiceV1Server(s StreamIndexMultiAssetsServiceV1Server)

func RegisterStreamIndexServiceV1Server ¶

func RegisterStreamIndexServiceV1Server(s StreamIndexServiceV1Server)

func RegisterStreamIvSviParametersServiceV1Server ¶

func RegisterStreamIvSviParametersServiceV1Server(s StreamIvSviParametersServiceV1Server)

func RegisterStreamMarketUpdateServiceV1Server ¶

func RegisterStreamMarketUpdateServiceV1Server(s StreamMarketUpdateServiceV1Server)

func RegisterStreamOrderbookL2ReplayServiceV1Server ¶

func RegisterStreamOrderbookL2ReplayServiceV1Server(s StreamOrderbookL2ReplayServiceV1Server)

func RegisterStreamOrderbookL2ServiceV1Server ¶

func RegisterStreamOrderbookL2ServiceV1Server(s StreamOrderbookL2ServiceV1Server)

func RegisterStreamTradesServiceV1Server ¶

func RegisterStreamTradesServiceV1Server(s StreamTradesServiceV1Server)

type StreamAggregatedPriceServiceV1Client ¶

StreamAggregatedPriceServiceV1Client is the client API for StreamAggregatedPriceServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamAggregatedPriceServiceV1Client interface {
    // Deprecated: Do not use.
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamAggregatedPriceServiceV1Client ¶

func NewStreamAggregatedPriceServiceV1Client(cc StreamAggregatedPriceServiceV1Client

type StreamAggregatedPriceServiceV1Server ¶

StreamAggregatedPriceServiceV1Server is the server API for StreamAggregatedPriceServiceV1 service. All implementations must embed UnimplementedStreamAggregatedPriceServiceV1Server for forward compatibility

type StreamAggregatedPriceServiceV1Server interface {
    // Deprecated: Do not use.
    // Subscribe
    Subscribe(*aggregated_price_v1.StreamAggregatedPriceRequestV1, StreamAggregatedPriceServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamAggregatedPriceServiceV1_SubscribeClient ¶

type StreamAggregatedPriceServiceV1_SubscribeClient interface {
    Recv() (*aggregated_price_v1.StreamAggregatedPriceResponseV1, error)
    ClientStream
}

type StreamAggregatedPriceServiceV1_SubscribeServer ¶

type StreamAggregatedPriceServiceV1_SubscribeServer interface {
    Send(*aggregated_price_v1.StreamAggregatedPriceResponseV1) error
    ServerStream
}

type StreamAggregatedQuoteServiceV2Client ¶

StreamAggregatedQuoteServiceV2Client is the client API for StreamAggregatedQuoteServiceV2 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamAggregatedQuoteServiceV2Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamAggregatedQuoteServiceV2Client ¶

func NewStreamAggregatedQuoteServiceV2Client(cc StreamAggregatedQuoteServiceV2Client

type StreamAggregatedQuoteServiceV2Server ¶

StreamAggregatedQuoteServiceV2Server is the server API for StreamAggregatedQuoteServiceV2 service. All implementations must embed UnimplementedStreamAggregatedQuoteServiceV2Server for forward compatibility

type StreamAggregatedQuoteServiceV2Server interface {
    // Subscribe
    Subscribe(*aggregated_quote_v2.StreamAggregatedQuoteRequestV2, StreamAggregatedQuoteServiceV2_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamAggregatedQuoteServiceV2_SubscribeClient ¶

type StreamAggregatedQuoteServiceV2_SubscribeClient interface {
    Recv() (*aggregated_quote_v2.StreamAggregatedQuoteResponseV2, error)
    ClientStream
}

type StreamAggregatedQuoteServiceV2_SubscribeServer ¶

type StreamAggregatedQuoteServiceV2_SubscribeServer interface {
    Send(*aggregated_quote_v2.StreamAggregatedQuoteResponseV2) error
    ServerStream
}

type StreamAggregatedStatePriceServiceV1Client ¶

StreamAggregatedStatePriceServiceV1Client is the client API for StreamAggregatedStatePriceServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamAggregatedStatePriceServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamAggregatedStatePriceServiceV1Client ¶

func NewStreamAggregatedStatePriceServiceV1Client(cc StreamAggregatedStatePriceServiceV1Client

type StreamAggregatedStatePriceServiceV1Server ¶

StreamAggregatedStatePriceServiceV1Server is the server API for StreamAggregatedStatePriceServiceV1 service. All implementations must embed UnimplementedStreamAggregatedStatePriceServiceV1Server for forward compatibility

type StreamAggregatedStatePriceServiceV1Server interface {
    // Subscribe
    Subscribe(*aggregated_state_price_v1.StreamAggregatedStatePriceRequestV1, StreamAggregatedStatePriceServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamAggregatedStatePriceServiceV1_SubscribeClient ¶

type StreamAggregatedStatePriceServiceV1_SubscribeClient interface {
    Recv() (*aggregated_state_price_v1.StreamAggregatedStatePriceResponseV1, error)
    ClientStream
}

type StreamAggregatedStatePriceServiceV1_SubscribeServer ¶

type StreamAggregatedStatePriceServiceV1_SubscribeServer interface {
    Send(*aggregated_state_price_v1.StreamAggregatedStatePriceResponseV1) error
    ServerStream
}

type StreamAggregatesOHLCVServiceV1Client ¶

StreamAggregatesOHLCVServiceV1Client is the client API for StreamAggregatesOHLCVServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamAggregatesOHLCVServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamAggregatesOHLCVServiceV1Client ¶

func NewStreamAggregatesOHLCVServiceV1Client(cc StreamAggregatesOHLCVServiceV1Client

type StreamAggregatesOHLCVServiceV1Server ¶

StreamAggregatesOHLCVServiceV1Server is the server API for StreamAggregatesOHLCVServiceV1 service. All implementations must embed UnimplementedStreamAggregatesOHLCVServiceV1Server for forward compatibility

type StreamAggregatesOHLCVServiceV1Server interface {
    // Subscribe
    Subscribe(*aggregates_ohlcv_v1.StreamAggregatesOHLCVRequestV1, StreamAggregatesOHLCVServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamAggregatesOHLCVServiceV1_SubscribeClient ¶

type StreamAggregatesOHLCVServiceV1_SubscribeClient interface {
    Recv() (*aggregates_ohlcv_v1.StreamAggregatesOHLCVResponseV1, error)
    ClientStream
}

type StreamAggregatesOHLCVServiceV1_SubscribeServer ¶

type StreamAggregatesOHLCVServiceV1_SubscribeServer interface {
    Send(*aggregates_ohlcv_v1.StreamAggregatesOHLCVResponseV1) error
    ServerStream
}

type StreamAggregatesSpotDirectExchangeRateV2ServiceV1Client ¶

StreamAggregatesSpotDirectExchangeRateV2ServiceV1Client is the client API for StreamAggregatesSpotDirectExchangeRateV2ServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamAggregatesSpotDirectExchangeRateV2ServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamAggregatesSpotDirectExchangeRateV2ServiceV1Client ¶

func NewStreamAggregatesSpotDirectExchangeRateV2ServiceV1Client(cc StreamAggregatesSpotDirectExchangeRateV2ServiceV1Client

type StreamAggregatesSpotDirectExchangeRateV2ServiceV1Server ¶

StreamAggregatesSpotDirectExchangeRateV2ServiceV1Server is the server API for StreamAggregatesSpotDirectExchangeRateV2ServiceV1 service. All implementations must embed UnimplementedStreamAggregatesSpotDirectExchangeRateV2ServiceV1Server for forward compatibility

type StreamAggregatesSpotDirectExchangeRateV2ServiceV1Server interface {
    // Subscribe
    Subscribe(*aggregates_direct_exchange_rate_v2.StreamAggregatesDirectExchangeRateV2RequestV1, StreamAggregatesSpotDirectExchangeRateV2ServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamAggregatesSpotDirectExchangeRateV2ServiceV1_SubscribeClient ¶

type StreamAggregatesSpotDirectExchangeRateV2ServiceV1_SubscribeClient interface {
    Recv() (*aggregates_direct_exchange_rate_v2.StreamAggregatesDirectExchangeRateV2ResponseV1, error)
    ClientStream
}

type StreamAggregatesSpotDirectExchangeRateV2ServiceV1_SubscribeServer ¶

type StreamAggregatesSpotDirectExchangeRateV2ServiceV1_SubscribeServer interface {
    Send(*aggregates_direct_exchange_rate_v2.StreamAggregatesDirectExchangeRateV2ResponseV1) error
    ServerStream
}

type StreamAggregatesSpotExchangeRateV2ServiceV1Client ¶

StreamAggregatesSpotExchangeRateV2ServiceV1Client is the client API for StreamAggregatesSpotExchangeRateV2ServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamAggregatesSpotExchangeRateV2ServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamAggregatesSpotExchangeRateV2ServiceV1Client ¶

func NewStreamAggregatesSpotExchangeRateV2ServiceV1Client(cc StreamAggregatesSpotExchangeRateV2ServiceV1Client

type StreamAggregatesSpotExchangeRateV2ServiceV1Server ¶

StreamAggregatesSpotExchangeRateV2ServiceV1Server is the server API for StreamAggregatesSpotExchangeRateV2ServiceV1 service. All implementations must embed UnimplementedStreamAggregatesSpotExchangeRateV2ServiceV1Server for forward compatibility

type StreamAggregatesSpotExchangeRateV2ServiceV1Server interface {
    // Subscribe
    Subscribe(*aggregates_spot_exchange_rate_v2.StreamAggregatesSpotExchangeRateV2RequestV1, StreamAggregatesSpotExchangeRateV2ServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamAggregatesSpotExchangeRateV2ServiceV1_SubscribeClient ¶

type StreamAggregatesSpotExchangeRateV2ServiceV1_SubscribeClient interface {
    Recv() (*aggregates_spot_exchange_rate_v2.StreamAggregatesSpotExchangeRateV2ResponseV1, error)
    ClientStream
}

type StreamAggregatesSpotExchangeRateV2ServiceV1_SubscribeServer ¶

type StreamAggregatesSpotExchangeRateV2ServiceV1_SubscribeServer interface {
    Send(*aggregates_spot_exchange_rate_v2.StreamAggregatesSpotExchangeRateV2ResponseV1) error
    ServerStream
}

type StreamAggregatesVWAPServiceV1Client ¶

StreamAggregatesVWAPServiceV1Client is the client API for StreamAggregatesVWAPServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamAggregatesVWAPServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamAggregatesVWAPServiceV1Client ¶

func NewStreamAggregatesVWAPServiceV1Client(cc StreamAggregatesVWAPServiceV1Client

type StreamAggregatesVWAPServiceV1Server ¶

StreamAggregatesVWAPServiceV1Server is the server API for StreamAggregatesVWAPServiceV1 service. All implementations must embed UnimplementedStreamAggregatesVWAPServiceV1Server for forward compatibility

type StreamAggregatesVWAPServiceV1Server interface {
    // Subscribe
    Subscribe(*aggregates_vwap_v1.StreamAggregatesVWAPRequestV1, StreamAggregatesVWAPServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamAggregatesVWAPServiceV1_SubscribeClient ¶

type StreamAggregatesVWAPServiceV1_SubscribeClient interface {
    Recv() (*aggregates_vwap_v1.StreamAggregatesVWAPResponseV1, error)
    ClientStream
}

type StreamAggregatesVWAPServiceV1_SubscribeServer ¶

type StreamAggregatesVWAPServiceV1_SubscribeServer interface {
    Send(*aggregates_vwap_v1.StreamAggregatesVWAPResponseV1) error
    ServerStream
}

type StreamDerivativesInstrumentMetricsServiceV1Client ¶

StreamDerivativesInstrumentMetricsServiceV1Client is the client API for StreamDerivativesInstrumentMetricsServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamDerivativesInstrumentMetricsServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamDerivativesInstrumentMetricsServiceV1Client ¶

func NewStreamDerivativesInstrumentMetricsServiceV1Client(cc StreamDerivativesInstrumentMetricsServiceV1Client

type StreamDerivativesInstrumentMetricsServiceV1Server ¶

StreamDerivativesInstrumentMetricsServiceV1Server is the server API for StreamDerivativesInstrumentMetricsServiceV1 service. All implementations must embed UnimplementedStreamDerivativesInstrumentMetricsServiceV1Server for forward compatibility

type StreamDerivativesInstrumentMetricsServiceV1Server interface {
    // Subscribe
    Subscribe(*derivatives_instrument_metrics_v1.StreamDerivativesInstrumentMetricsRequestV1, StreamDerivativesInstrumentMetricsServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamDerivativesInstrumentMetricsServiceV1_SubscribeClient ¶

type StreamDerivativesInstrumentMetricsServiceV1_SubscribeClient interface {
    Recv() (*derivatives_instrument_metrics_v1.StreamDerivativesInstrumentMetricsResponseV1, error)
    ClientStream
}

type StreamDerivativesInstrumentMetricsServiceV1_SubscribeServer ¶

type StreamDerivativesInstrumentMetricsServiceV1_SubscribeServer interface {
    Send(*derivatives_instrument_metrics_v1.StreamDerivativesInstrumentMetricsResponseV1) error
    ServerStream
}

type StreamExoticIndicesServiceV1Client ¶

StreamExoticIndicesServiceV1Client is the client API for StreamExoticIndicesServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamExoticIndicesServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamExoticIndicesServiceV1Client ¶

func NewStreamExoticIndicesServiceV1Client(cc StreamExoticIndicesServiceV1Client

type StreamExoticIndicesServiceV1Server ¶

StreamExoticIndicesServiceV1Server is the server API for StreamExoticIndicesServiceV1 service. All implementations must embed UnimplementedStreamExoticIndicesServiceV1Server for forward compatibility

type StreamExoticIndicesServiceV1Server interface {
    // Subscribe
    Subscribe(*exotic_indices_v1.StreamExoticIndicesServiceRequestV1, StreamExoticIndicesServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamExoticIndicesServiceV1_SubscribeClient ¶

type StreamExoticIndicesServiceV1_SubscribeClient interface {
    Recv() (*exotic_indices_v1.StreamExoticIndicesServiceResponseV1, error)
    ClientStream
}

type StreamExoticIndicesServiceV1_SubscribeServer ¶

type StreamExoticIndicesServiceV1_SubscribeServer interface {
    Send(*exotic_indices_v1.StreamExoticIndicesServiceResponseV1) error
    ServerStream
}

type StreamIndexForexRateServiceV1Client ¶

StreamIndexForexRateServiceV1Client is the client API for StreamIndexForexRateServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamIndexForexRateServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamIndexForexRateServiceV1Client ¶

func NewStreamIndexForexRateServiceV1Client(cc StreamIndexForexRateServiceV1Client

type StreamIndexForexRateServiceV1Server ¶

StreamIndexForexRateServiceV1Server is the server API for StreamIndexForexRateServiceV1 service. All implementations must embed UnimplementedStreamIndexForexRateServiceV1Server for forward compatibility

type StreamIndexForexRateServiceV1Server interface {
    // Subscribe
    Subscribe(*index_forex_rate_v1.StreamIndexForexRateServiceRequestV1, StreamIndexForexRateServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamIndexForexRateServiceV1_SubscribeClient ¶

type StreamIndexForexRateServiceV1_SubscribeClient interface {
    Recv() (*index_forex_rate_v1.StreamIndexForexRateServiceResponseV1, error)
    ClientStream
}

type StreamIndexForexRateServiceV1_SubscribeServer ¶

type StreamIndexForexRateServiceV1_SubscribeServer interface {
    Send(*index_forex_rate_v1.StreamIndexForexRateServiceResponseV1) error
    ServerStream
}

type StreamIndexMultiAssetsServiceV1Client ¶

StreamIndexMultiAssetsServiceV1Client is the client API for StreamIndexMultiAssetsServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamIndexMultiAssetsServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamIndexMultiAssetsServiceV1Client ¶

func NewStreamIndexMultiAssetsServiceV1Client(cc StreamIndexMultiAssetsServiceV1Client

type StreamIndexMultiAssetsServiceV1Server ¶

StreamIndexMultiAssetsServiceV1Server is the server API for StreamIndexMultiAssetsServiceV1 service. All implementations must embed UnimplementedStreamIndexMultiAssetsServiceV1Server for forward compatibility

type StreamIndexMultiAssetsServiceV1Server interface {
    // Subscribe
    Subscribe(*index_multi_assets_v1.StreamIndexMultiAssetsServiceRequestV1, StreamIndexMultiAssetsServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamIndexMultiAssetsServiceV1_SubscribeClient ¶

type StreamIndexMultiAssetsServiceV1_SubscribeClient interface {
    Recv() (*index_multi_assets_v1.StreamIndexMultiAssetsServiceResponseV1, error)
    ClientStream
}

type StreamIndexMultiAssetsServiceV1_SubscribeServer ¶

type StreamIndexMultiAssetsServiceV1_SubscribeServer interface {
    Send(*index_multi_assets_v1.StreamIndexMultiAssetsServiceResponseV1) error
    ServerStream
}

type StreamIndexServiceV1Client ¶

StreamIndexServiceV1Client is the client API for StreamIndexServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamIndexServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamIndexServiceV1Client ¶

func NewStreamIndexServiceV1Client(cc StreamIndexServiceV1Client

type StreamIndexServiceV1Server ¶

StreamIndexServiceV1Server is the server API for StreamIndexServiceV1 service. All implementations must embed UnimplementedStreamIndexServiceV1Server for forward compatibility

type StreamIndexServiceV1Server interface {
    // Subscribe
    Subscribe(*index_v1.StreamIndexServiceRequestV1, StreamIndexServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamIndexServiceV1_SubscribeClient ¶

type StreamIndexServiceV1_SubscribeClient interface {
    Recv() (*index_v1.StreamIndexServiceResponseV1, error)
    ClientStream
}

type StreamIndexServiceV1_SubscribeServer ¶

type StreamIndexServiceV1_SubscribeServer interface {
    Send(*index_v1.StreamIndexServiceResponseV1) error
    ServerStream
}

type StreamIvSviParametersServiceV1Client ¶

StreamIvSviParametersServiceV1Client is the client API for StreamIvSviParametersServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamIvSviParametersServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamIvSviParametersServiceV1Client ¶

func NewStreamIvSviParametersServiceV1Client(cc StreamIvSviParametersServiceV1Client

type StreamIvSviParametersServiceV1Server ¶

StreamIvSviParametersServiceV1Server is the server API for StreamIvSviParametersServiceV1 service. All implementations must embed UnimplementedStreamIvSviParametersServiceV1Server for forward compatibility

type StreamIvSviParametersServiceV1Server interface {
    // Subscribe
    Subscribe(*iv_svi_parameters_v1.StreamIvSviParametersRequestV1, StreamIvSviParametersServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamIvSviParametersServiceV1_SubscribeClient ¶

type StreamIvSviParametersServiceV1_SubscribeClient interface {
    Recv() (*iv_svi_parameters_v1.StreamIvSviParametersResponseV1, error)
    ClientStream
}

type StreamIvSviParametersServiceV1_SubscribeServer ¶

type StreamIvSviParametersServiceV1_SubscribeServer interface {
    Send(*iv_svi_parameters_v1.StreamIvSviParametersResponseV1) error
    ServerStream
}

type StreamMarketUpdateServiceV1Client ¶

StreamMarketUpdateServiceV1Client is the client API for StreamMarketUpdateServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamMarketUpdateServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamMarketUpdateServiceV1Client ¶

func NewStreamMarketUpdateServiceV1Client(cc StreamMarketUpdateServiceV1Client

type StreamMarketUpdateServiceV1Server ¶

StreamMarketUpdateServiceV1Server is the server API for StreamMarketUpdateServiceV1 service. All implementations must embed UnimplementedStreamMarketUpdateServiceV1Server for forward compatibility

type StreamMarketUpdateServiceV1Server interface {
    // Subscribe
    Subscribe(*market_update_v1.StreamMarketUpdateRequestV1, StreamMarketUpdateServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamMarketUpdateServiceV1_SubscribeClient ¶

type StreamMarketUpdateServiceV1_SubscribeClient interface {
    Recv() (*market_update_v1.StreamMarketUpdateResponseV1, error)
    ClientStream
}

type StreamMarketUpdateServiceV1_SubscribeServer ¶

type StreamMarketUpdateServiceV1_SubscribeServer interface {
    Send(*market_update_v1.StreamMarketUpdateResponseV1) error
    ServerStream
}

type StreamOrderbookL2ReplayServiceV1Client ¶

StreamOrderbookL2ReplayServiceV1Client is the client API for StreamOrderbookL2ReplayServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamOrderbookL2ReplayServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamOrderbookL2ReplayServiceV1Client ¶

func NewStreamOrderbookL2ReplayServiceV1Client(cc StreamOrderbookL2ReplayServiceV1Client

type StreamOrderbookL2ReplayServiceV1Server ¶

StreamOrderbookL2ReplayServiceV1Server is the server API for StreamOrderbookL2ReplayServiceV1 service. All implementations must embed UnimplementedStreamOrderbookL2ReplayServiceV1Server for forward compatibility

type StreamOrderbookL2ReplayServiceV1Server interface {
    // Subscribe
    Subscribe(*orderbookl2_v1.StreamOrderBookL2ReplayRequestV1, StreamOrderbookL2ReplayServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamOrderbookL2ReplayServiceV1_SubscribeClient ¶

type StreamOrderbookL2ReplayServiceV1_SubscribeClient interface {
    Recv() (*orderbookl2_v1.StreamOrderBookL2ResponseV1, error)
    ClientStream
}

type StreamOrderbookL2ReplayServiceV1_SubscribeServer ¶

type StreamOrderbookL2ReplayServiceV1_SubscribeServer interface {
    Send(*orderbookl2_v1.StreamOrderBookL2ResponseV1) error
    ServerStream
}

type StreamOrderbookL2ServiceV1Client ¶

StreamOrderbookL2ServiceV1Client is the client API for StreamOrderbookL2ServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamOrderbookL2ServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamOrderbookL2ServiceV1Client ¶

func NewStreamOrderbookL2ServiceV1Client(cc StreamOrderbookL2ServiceV1Client

type StreamOrderbookL2ServiceV1Server ¶

StreamOrderbookL2ServiceV1Server is the server API for StreamOrderbookL2ServiceV1 service. All implementations must embed UnimplementedStreamOrderbookL2ServiceV1Server for forward compatibility

type StreamOrderbookL2ServiceV1Server interface {
    // Subscribe
    Subscribe(*orderbookl2_v1.StreamOrderBookL2RequestV1, StreamOrderbookL2ServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamOrderbookL2ServiceV1_SubscribeClient ¶

type StreamOrderbookL2ServiceV1_SubscribeClient interface {
    Recv() (*orderbookl2_v1.StreamOrderBookL2ResponseV1, error)
    ClientStream
}

type StreamOrderbookL2ServiceV1_SubscribeServer ¶

type StreamOrderbookL2ServiceV1_SubscribeServer interface {
    Send(*orderbookl2_v1.StreamOrderBookL2ResponseV1) error
    ServerStream
}

type StreamTradesServiceV1Client ¶

StreamTradesServiceV1Client is the client API for StreamTradesServiceV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamTradesServiceV1Client interface {
    // Subscribe
    Subscribe(ctx error)
}

func NewStreamTradesServiceV1Client ¶

func NewStreamTradesServiceV1Client(cc StreamTradesServiceV1Client

type StreamTradesServiceV1Server ¶

StreamTradesServiceV1Server is the server API for StreamTradesServiceV1 service. All implementations must embed UnimplementedStreamTradesServiceV1Server for forward compatibility

type StreamTradesServiceV1Server interface {
    // Subscribe
    Subscribe(*trades_v1.StreamTradesRequestV1, StreamTradesServiceV1_SubscribeServer) error
    // contains filtered or unexported methods
}

type StreamTradesServiceV1_SubscribeClient ¶

type StreamTradesServiceV1_SubscribeClient interface {
    Recv() (*trades_v1.StreamTradesResponseV1, error)
    ClientStream
}

type StreamTradesServiceV1_SubscribeServer ¶

type StreamTradesServiceV1_SubscribeServer interface {
    Send(*trades_v1.StreamTradesResponseV1) error
    ServerStream
}

type UnimplementedStreamAggregatedPriceServiceV1Server ¶

UnimplementedStreamAggregatedPriceServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamAggregatedPriceServiceV1Server struct {
}

func (UnimplementedStreamAggregatedPriceServiceV1Server) Subscribe ¶

func (UnimplementedStreamAggregatedPriceServiceV1Server) Subscribe(*aggregated_price_v1.StreamAggregatedPriceRequestV1, StreamAggregatedPriceServiceV1_SubscribeServer) error

type UnimplementedStreamAggregatedQuoteServiceV2Server ¶

UnimplementedStreamAggregatedQuoteServiceV2Server must be embedded to have forward compatible implementations.

type UnimplementedStreamAggregatedQuoteServiceV2Server struct {
}

func (UnimplementedStreamAggregatedQuoteServiceV2Server) Subscribe ¶

func (UnimplementedStreamAggregatedQuoteServiceV2Server) Subscribe(*aggregated_quote_v2.StreamAggregatedQuoteRequestV2, StreamAggregatedQuoteServiceV2_SubscribeServer) error

type UnimplementedStreamAggregatedStatePriceServiceV1Server ¶

UnimplementedStreamAggregatedStatePriceServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamAggregatedStatePriceServiceV1Server struct {
}

func (UnimplementedStreamAggregatedStatePriceServiceV1Server) Subscribe ¶

func (UnimplementedStreamAggregatedStatePriceServiceV1Server) Subscribe(*aggregated_state_price_v1.StreamAggregatedStatePriceRequestV1, StreamAggregatedStatePriceServiceV1_SubscribeServer) error

type UnimplementedStreamAggregatesOHLCVServiceV1Server ¶

UnimplementedStreamAggregatesOHLCVServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamAggregatesOHLCVServiceV1Server struct {
}

func (UnimplementedStreamAggregatesOHLCVServiceV1Server) Subscribe ¶

func (UnimplementedStreamAggregatesOHLCVServiceV1Server) Subscribe(*aggregates_ohlcv_v1.StreamAggregatesOHLCVRequestV1, StreamAggregatesOHLCVServiceV1_SubscribeServer) error

type UnimplementedStreamAggregatesSpotDirectExchangeRateV2ServiceV1Server ¶

UnimplementedStreamAggregatesSpotDirectExchangeRateV2ServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamAggregatesSpotDirectExchangeRateV2ServiceV1Server struct {
}

func (UnimplementedStreamAggregatesSpotDirectExchangeRateV2ServiceV1Server) Subscribe ¶

func (UnimplementedStreamAggregatesSpotDirectExchangeRateV2ServiceV1Server) Subscribe(*aggregates_direct_exchange_rate_v2.StreamAggregatesDirectExchangeRateV2RequestV1, StreamAggregatesSpotDirectExchangeRateV2ServiceV1_SubscribeServer) error

type UnimplementedStreamAggregatesSpotExchangeRateV2ServiceV1Server ¶

UnimplementedStreamAggregatesSpotExchangeRateV2ServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamAggregatesSpotExchangeRateV2ServiceV1Server struct {
}

func (UnimplementedStreamAggregatesSpotExchangeRateV2ServiceV1Server) Subscribe ¶

func (UnimplementedStreamAggregatesSpotExchangeRateV2ServiceV1Server) Subscribe(*aggregates_spot_exchange_rate_v2.StreamAggregatesSpotExchangeRateV2RequestV1, StreamAggregatesSpotExchangeRateV2ServiceV1_SubscribeServer) error

type UnimplementedStreamAggregatesVWAPServiceV1Server ¶

UnimplementedStreamAggregatesVWAPServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamAggregatesVWAPServiceV1Server struct {
}

func (UnimplementedStreamAggregatesVWAPServiceV1Server) Subscribe ¶

func (UnimplementedStreamAggregatesVWAPServiceV1Server) Subscribe(*aggregates_vwap_v1.StreamAggregatesVWAPRequestV1, StreamAggregatesVWAPServiceV1_SubscribeServer) error

type UnimplementedStreamDerivativesInstrumentMetricsServiceV1Server ¶

UnimplementedStreamDerivativesInstrumentMetricsServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamDerivativesInstrumentMetricsServiceV1Server struct {
}

func (UnimplementedStreamDerivativesInstrumentMetricsServiceV1Server) Subscribe ¶

func (UnimplementedStreamDerivativesInstrumentMetricsServiceV1Server) Subscribe(*derivatives_instrument_metrics_v1.StreamDerivativesInstrumentMetricsRequestV1, StreamDerivativesInstrumentMetricsServiceV1_SubscribeServer) error

type UnimplementedStreamExoticIndicesServiceV1Server ¶

UnimplementedStreamExoticIndicesServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamExoticIndicesServiceV1Server struct {
}

func (UnimplementedStreamExoticIndicesServiceV1Server) Subscribe ¶

func (UnimplementedStreamExoticIndicesServiceV1Server) Subscribe(*exotic_indices_v1.StreamExoticIndicesServiceRequestV1, StreamExoticIndicesServiceV1_SubscribeServer) error

type UnimplementedStreamIndexForexRateServiceV1Server ¶

UnimplementedStreamIndexForexRateServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamIndexForexRateServiceV1Server struct {
}

func (UnimplementedStreamIndexForexRateServiceV1Server) Subscribe ¶

func (UnimplementedStreamIndexForexRateServiceV1Server) Subscribe(*index_forex_rate_v1.StreamIndexForexRateServiceRequestV1, StreamIndexForexRateServiceV1_SubscribeServer) error

type UnimplementedStreamIndexMultiAssetsServiceV1Server ¶

UnimplementedStreamIndexMultiAssetsServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamIndexMultiAssetsServiceV1Server struct {
}

func (UnimplementedStreamIndexMultiAssetsServiceV1Server) Subscribe ¶

func (UnimplementedStreamIndexMultiAssetsServiceV1Server) Subscribe(*index_multi_assets_v1.StreamIndexMultiAssetsServiceRequestV1, StreamIndexMultiAssetsServiceV1_SubscribeServer) error

type UnimplementedStreamIndexServiceV1Server ¶

UnimplementedStreamIndexServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamIndexServiceV1Server struct {
}

func (UnimplementedStreamIndexServiceV1Server) Subscribe ¶

func (UnimplementedStreamIndexServiceV1Server) Subscribe(*index_v1.StreamIndexServiceRequestV1, StreamIndexServiceV1_SubscribeServer) error

type UnimplementedStreamIvSviParametersServiceV1Server ¶

UnimplementedStreamIvSviParametersServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamIvSviParametersServiceV1Server struct {
}

func (UnimplementedStreamIvSviParametersServiceV1Server) Subscribe ¶

func (UnimplementedStreamIvSviParametersServiceV1Server) Subscribe(*iv_svi_parameters_v1.StreamIvSviParametersRequestV1, StreamIvSviParametersServiceV1_SubscribeServer) error

type UnimplementedStreamMarketUpdateServiceV1Server ¶

UnimplementedStreamMarketUpdateServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamMarketUpdateServiceV1Server struct {
}

func (UnimplementedStreamMarketUpdateServiceV1Server) Subscribe ¶

func (UnimplementedStreamMarketUpdateServiceV1Server) Subscribe(*market_update_v1.StreamMarketUpdateRequestV1, StreamMarketUpdateServiceV1_SubscribeServer) error

type UnimplementedStreamOrderbookL2ReplayServiceV1Server ¶

UnimplementedStreamOrderbookL2ReplayServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamOrderbookL2ReplayServiceV1Server struct {
}

func (UnimplementedStreamOrderbookL2ReplayServiceV1Server) Subscribe ¶

func (UnimplementedStreamOrderbookL2ReplayServiceV1Server) Subscribe(*orderbookl2_v1.StreamOrderBookL2ReplayRequestV1, StreamOrderbookL2ReplayServiceV1_SubscribeServer) error

type UnimplementedStreamOrderbookL2ServiceV1Server ¶

UnimplementedStreamOrderbookL2ServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamOrderbookL2ServiceV1Server struct {
}

func (UnimplementedStreamOrderbookL2ServiceV1Server) Subscribe ¶

func (UnimplementedStreamOrderbookL2ServiceV1Server) Subscribe(*orderbookl2_v1.StreamOrderBookL2RequestV1, StreamOrderbookL2ServiceV1_SubscribeServer) error

type UnimplementedStreamTradesServiceV1Server ¶

UnimplementedStreamTradesServiceV1Server must be embedded to have forward compatible implementations.

type UnimplementedStreamTradesServiceV1Server struct {
}

func (UnimplementedStreamTradesServiceV1Server) Subscribe ¶

func (UnimplementedStreamTradesServiceV1Server) Subscribe(*trades_v1.StreamTradesRequestV1, StreamTradesServiceV1_SubscribeServer) error

type UnsafeStreamAggregatedPriceServiceV1Server ¶

UnsafeStreamAggregatedPriceServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamAggregatedPriceServiceV1Server will result in compilation errors.

type UnsafeStreamAggregatedPriceServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamAggregatedQuoteServiceV2Server ¶

UnsafeStreamAggregatedQuoteServiceV2Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamAggregatedQuoteServiceV2Server will result in compilation errors.

type UnsafeStreamAggregatedQuoteServiceV2Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamAggregatedStatePriceServiceV1Server ¶

UnsafeStreamAggregatedStatePriceServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamAggregatedStatePriceServiceV1Server will result in compilation errors.

type UnsafeStreamAggregatedStatePriceServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamAggregatesOHLCVServiceV1Server ¶

UnsafeStreamAggregatesOHLCVServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamAggregatesOHLCVServiceV1Server will result in compilation errors.

type UnsafeStreamAggregatesOHLCVServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamAggregatesSpotDirectExchangeRateV2ServiceV1Server ¶

UnsafeStreamAggregatesSpotDirectExchangeRateV2ServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamAggregatesSpotDirectExchangeRateV2ServiceV1Server will result in compilation errors.

type UnsafeStreamAggregatesSpotDirectExchangeRateV2ServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamAggregatesSpotExchangeRateV2ServiceV1Server ¶

UnsafeStreamAggregatesSpotExchangeRateV2ServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamAggregatesSpotExchangeRateV2ServiceV1Server will result in compilation errors.

type UnsafeStreamAggregatesSpotExchangeRateV2ServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamAggregatesVWAPServiceV1Server ¶

UnsafeStreamAggregatesVWAPServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamAggregatesVWAPServiceV1Server will result in compilation errors.

type UnsafeStreamAggregatesVWAPServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamDerivativesInstrumentMetricsServiceV1Server ¶

UnsafeStreamDerivativesInstrumentMetricsServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamDerivativesInstrumentMetricsServiceV1Server will result in compilation errors.

type UnsafeStreamDerivativesInstrumentMetricsServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamExoticIndicesServiceV1Server ¶

UnsafeStreamExoticIndicesServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamExoticIndicesServiceV1Server will result in compilation errors.

type UnsafeStreamExoticIndicesServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamIndexForexRateServiceV1Server ¶

UnsafeStreamIndexForexRateServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamIndexForexRateServiceV1Server will result in compilation errors.

type UnsafeStreamIndexForexRateServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamIndexMultiAssetsServiceV1Server ¶

UnsafeStreamIndexMultiAssetsServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamIndexMultiAssetsServiceV1Server will result in compilation errors.

type UnsafeStreamIndexMultiAssetsServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamIndexServiceV1Server ¶

UnsafeStreamIndexServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamIndexServiceV1Server will result in compilation errors.

type UnsafeStreamIndexServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamIvSviParametersServiceV1Server ¶

UnsafeStreamIvSviParametersServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamIvSviParametersServiceV1Server will result in compilation errors.

type UnsafeStreamIvSviParametersServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamMarketUpdateServiceV1Server ¶

UnsafeStreamMarketUpdateServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamMarketUpdateServiceV1Server will result in compilation errors.

type UnsafeStreamMarketUpdateServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamOrderbookL2ReplayServiceV1Server ¶

UnsafeStreamOrderbookL2ReplayServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamOrderbookL2ReplayServiceV1Server will result in compilation errors.

type UnsafeStreamOrderbookL2ReplayServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamOrderbookL2ServiceV1Server ¶

UnsafeStreamOrderbookL2ServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamOrderbookL2ServiceV1Server will result in compilation errors.

type UnsafeStreamOrderbookL2ServiceV1Server interface {
    // contains filtered or unexported methods
}

type UnsafeStreamTradesServiceV1Server ¶

UnsafeStreamTradesServiceV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamTradesServiceV1Server will result in compilation errors.

type UnsafeStreamTradesServiceV1Server interface {
    // contains filtered or unexported methods
}

Subdirectories