Documentation ¶
Index ¶
- Variables
- func KeyFromSub(sub *ClientSubscription) string
- func KeysFromSubs(subs []*ClientSubscription) []string
- type APIAuthenticationMessage
- func (*APIAuthenticationMessage) Descriptor() ([]byte, []int)
- func (m *APIAuthenticationMessage) GetApiKey() string
- func (m *APIAuthenticationMessage) GetClientSubscriptions() []*ClientSubscription
- func (m *APIAuthenticationMessage) GetNonce() string
- func (m *APIAuthenticationMessage) GetSource() APIAuthenticationMessage_Source
- func (m *APIAuthenticationMessage) GetSubscriptions() []stringdeprecated
- func (m *APIAuthenticationMessage) GetToken() string
- func (m *APIAuthenticationMessage) GetVersion() string
- func (m *APIAuthenticationMessage) Marshal() (dAtA []byte, err error)
- func (m *APIAuthenticationMessage) MarshalTo(dAtA []byte) (int, error)
- func (*APIAuthenticationMessage) ProtoMessage()
- func (m *APIAuthenticationMessage) Reset()
- func (m *APIAuthenticationMessage) Size() (n int)
- func (m *APIAuthenticationMessage) String() string
- func (m *APIAuthenticationMessage) Unmarshal(dAtA []byte) error
- func (m *APIAuthenticationMessage) XXX_DiscardUnknown()
- func (m *APIAuthenticationMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *APIAuthenticationMessage) XXX_Merge(src proto.Message)
- func (m *APIAuthenticationMessage) XXX_Size() int
- func (m *APIAuthenticationMessage) XXX_Unmarshal(b []byte) error
- type APIAuthenticationMessage_Source
- type ClientIdentificationMessage
- func (*ClientIdentificationMessage) Descriptor() ([]byte, []int)
- func (m *ClientIdentificationMessage) GetClientSubscriptions() []*ClientSubscription
- func (m *ClientIdentificationMessage) GetIntegration() string
- func (m *ClientIdentificationMessage) GetLocale() string
- func (m *ClientIdentificationMessage) GetRevision() string
- func (m *ClientIdentificationMessage) GetSubscriptions() []stringdeprecated
- func (m *ClientIdentificationMessage) GetUseragent() string
- func (m *ClientIdentificationMessage) Marshal() (dAtA []byte, err error)
- func (m *ClientIdentificationMessage) MarshalTo(dAtA []byte) (int, error)
- func (*ClientIdentificationMessage) ProtoMessage()
- func (m *ClientIdentificationMessage) Reset()
- func (m *ClientIdentificationMessage) Size() (n int)
- func (m *ClientIdentificationMessage) String() string
- func (m *ClientIdentificationMessage) Unmarshal(dAtA []byte) error
- func (m *ClientIdentificationMessage) XXX_DiscardUnknown()
- func (m *ClientIdentificationMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClientIdentificationMessage) XXX_Merge(src proto.Message)
- func (m *ClientIdentificationMessage) XXX_Size() int
- func (m *ClientIdentificationMessage) XXX_Unmarshal(b []byte) error
- type ClientMessage
- func (*ClientMessage) Descriptor() ([]byte, []int)
- func (m *ClientMessage) GetApiAuthentication() *APIAuthenticationMessage
- func (m *ClientMessage) GetBody() isClientMessage_Body
- func (m *ClientMessage) GetClientSession() *ClientSessionMessage
- func (m *ClientMessage) GetIdentification() *ClientIdentificationMessage
- func (m *ClientMessage) GetSubscribe() *ClientSubscribeMessage
- func (m *ClientMessage) GetUnsubscribe() *ClientUnsubscribeMessage
- func (m *ClientMessage) GetWebAuthentication() *WebAuthenticationMessage
- func (m *ClientMessage) Marshal() (dAtA []byte, err error)
- func (m *ClientMessage) MarshalTo(dAtA []byte) (int, error)
- func (*ClientMessage) ProtoMessage()
- func (m *ClientMessage) Reset()
- func (m *ClientMessage) Size() (n int)
- func (m *ClientMessage) String() string
- func (m *ClientMessage) Unmarshal(dAtA []byte) error
- func (m *ClientMessage) XXX_DiscardUnknown()
- func (m *ClientMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClientMessage) XXX_Merge(src proto.Message)
- func (*ClientMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *ClientMessage) XXX_Size() int
- func (m *ClientMessage) XXX_Unmarshal(b []byte) error
- type ClientMessage_ApiAuthentication
- type ClientMessage_ClientSession
- type ClientMessage_Identification
- type ClientMessage_Subscribe
- type ClientMessage_Unsubscribe
- type ClientMessage_WebAuthentication
- type ClientSessionMessage
- func (*ClientSessionMessage) Descriptor() ([]byte, []int)
- func (m *ClientSessionMessage) GetAnonymousTradingSession() *ClientSessionMessage_AnonymousTradingSession
- func (m *ClientSessionMessage) GetIdentification() *ClientIdentificationMessage
- func (m *ClientSessionMessage) GetSession() *ClientSessionMessage_Session
- func (m *ClientSessionMessage) GetSessionConfig() isClientSessionMessage_SessionConfig
- func (m *ClientSessionMessage) Marshal() (dAtA []byte, err error)
- func (m *ClientSessionMessage) MarshalTo(dAtA []byte) (int, error)
- func (*ClientSessionMessage) ProtoMessage()
- func (m *ClientSessionMessage) Reset()
- func (m *ClientSessionMessage) Size() (n int)
- func (m *ClientSessionMessage) String() string
- func (m *ClientSessionMessage) Unmarshal(dAtA []byte) error
- func (m *ClientSessionMessage) XXX_DiscardUnknown()
- func (m *ClientSessionMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClientSessionMessage) XXX_Merge(src proto.Message)
- func (*ClientSessionMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *ClientSessionMessage) XXX_Size() int
- func (m *ClientSessionMessage) XXX_Unmarshal(b []byte) error
- type ClientSessionMessage_AnonymousTradingSession
- func (*ClientSessionMessage_AnonymousTradingSession) Descriptor() ([]byte, []int)
- func (m *ClientSessionMessage_AnonymousTradingSession) GetExchange() string
- func (m *ClientSessionMessage_AnonymousTradingSession) GetExpiration() int64
- func (m *ClientSessionMessage_AnonymousTradingSession) GetToken() string
- func (m *ClientSessionMessage_AnonymousTradingSession) Marshal() (dAtA []byte, err error)
- func (m *ClientSessionMessage_AnonymousTradingSession) MarshalTo(dAtA []byte) (int, error)
- func (*ClientSessionMessage_AnonymousTradingSession) ProtoMessage()
- func (m *ClientSessionMessage_AnonymousTradingSession) Reset()
- func (m *ClientSessionMessage_AnonymousTradingSession) Size() (n int)
- func (m *ClientSessionMessage_AnonymousTradingSession) String() string
- func (m *ClientSessionMessage_AnonymousTradingSession) Unmarshal(dAtA []byte) error
- func (m *ClientSessionMessage_AnonymousTradingSession) XXX_DiscardUnknown()
- func (m *ClientSessionMessage_AnonymousTradingSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClientSessionMessage_AnonymousTradingSession) XXX_Merge(src proto.Message)
- func (m *ClientSessionMessage_AnonymousTradingSession) XXX_Size() int
- func (m *ClientSessionMessage_AnonymousTradingSession) XXX_Unmarshal(b []byte) error
- type ClientSessionMessage_AnonymousTradingSession_
- type ClientSessionMessage_Session
- func (*ClientSessionMessage_Session) Descriptor() ([]byte, []int)
- func (m *ClientSessionMessage_Session) GetExpires() int64
- func (m *ClientSessionMessage_Session) GetMfaToken() string
- func (m *ClientSessionMessage_Session) GetToken() string
- func (m *ClientSessionMessage_Session) GetUserId() string
- func (m *ClientSessionMessage_Session) Marshal() (dAtA []byte, err error)
- func (m *ClientSessionMessage_Session) MarshalTo(dAtA []byte) (int, error)
- func (*ClientSessionMessage_Session) ProtoMessage()
- func (m *ClientSessionMessage_Session) Reset()
- func (m *ClientSessionMessage_Session) Size() (n int)
- func (m *ClientSessionMessage_Session) String() string
- func (m *ClientSessionMessage_Session) Unmarshal(dAtA []byte) error
- func (m *ClientSessionMessage_Session) XXX_DiscardUnknown()
- func (m *ClientSessionMessage_Session) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClientSessionMessage_Session) XXX_Merge(src proto.Message)
- func (m *ClientSessionMessage_Session) XXX_Size() int
- func (m *ClientSessionMessage_Session) XXX_Unmarshal(b []byte) error
- type ClientSessionMessage_Session_
- type ClientSubscribeMessage
- func (*ClientSubscribeMessage) Descriptor() ([]byte, []int)
- func (m *ClientSubscribeMessage) GetSubscriptionKeys() []stringdeprecated
- func (m *ClientSubscribeMessage) GetSubscriptions() []*ClientSubscription
- func (m *ClientSubscribeMessage) Marshal() (dAtA []byte, err error)
- func (m *ClientSubscribeMessage) MarshalTo(dAtA []byte) (int, error)
- func (*ClientSubscribeMessage) ProtoMessage()
- func (m *ClientSubscribeMessage) Reset()
- func (m *ClientSubscribeMessage) Size() (n int)
- func (m *ClientSubscribeMessage) String() string
- func (m *ClientSubscribeMessage) Unmarshal(dAtA []byte) error
- func (m *ClientSubscribeMessage) XXX_DiscardUnknown()
- func (m *ClientSubscribeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClientSubscribeMessage) XXX_Merge(src proto.Message)
- func (m *ClientSubscribeMessage) XXX_Size() int
- func (m *ClientSubscribeMessage) XXX_Unmarshal(b []byte) error
- type ClientSubscription
- func (*ClientSubscription) Descriptor() ([]byte, []int)
- func (m *ClientSubscription) GetBody() isClientSubscription_Body
- func (m *ClientSubscription) GetStreamSubscription() *StreamSubscription
- func (m *ClientSubscription) GetTradeSubscription() *TradeSubscription
- func (m *ClientSubscription) GetTriggerSubscription() *TriggerSubscription
- func (m *ClientSubscription) Marshal() (dAtA []byte, err error)
- func (m *ClientSubscription) MarshalTo(dAtA []byte) (int, error)
- func (*ClientSubscription) ProtoMessage()
- func (m *ClientSubscription) Reset()
- func (m *ClientSubscription) Size() (n int)
- func (m *ClientSubscription) String() string
- func (m *ClientSubscription) Unmarshal(dAtA []byte) error
- func (m *ClientSubscription) XXX_DiscardUnknown()
- func (m *ClientSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClientSubscription) XXX_Merge(src proto.Message)
- func (*ClientSubscription) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *ClientSubscription) XXX_Size() int
- func (m *ClientSubscription) XXX_Unmarshal(b []byte) error
- type ClientSubscription_StreamSubscription
- type ClientSubscription_TradeSubscription
- type ClientSubscription_TriggerSubscription
- type ClientUnsubscribeMessage
- func (*ClientUnsubscribeMessage) Descriptor() ([]byte, []int)
- func (m *ClientUnsubscribeMessage) GetSubscriptionKeys() []stringdeprecated
- func (m *ClientUnsubscribeMessage) GetSubscriptions() []*ClientSubscription
- func (m *ClientUnsubscribeMessage) Marshal() (dAtA []byte, err error)
- func (m *ClientUnsubscribeMessage) MarshalTo(dAtA []byte) (int, error)
- func (*ClientUnsubscribeMessage) ProtoMessage()
- func (m *ClientUnsubscribeMessage) Reset()
- func (m *ClientUnsubscribeMessage) Size() (n int)
- func (m *ClientUnsubscribeMessage) String() string
- func (m *ClientUnsubscribeMessage) Unmarshal(dAtA []byte) error
- func (m *ClientUnsubscribeMessage) XXX_DiscardUnknown()
- func (m *ClientUnsubscribeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClientUnsubscribeMessage) XXX_Merge(src proto.Message)
- func (m *ClientUnsubscribeMessage) XXX_Size() int
- func (m *ClientUnsubscribeMessage) XXX_Unmarshal(b []byte) error
- type StreamSubscription
- func (*StreamSubscription) Descriptor() ([]byte, []int)
- func (m *StreamSubscription) GetResource() string
- func (m *StreamSubscription) Marshal() (dAtA []byte, err error)
- func (m *StreamSubscription) MarshalTo(dAtA []byte) (int, error)
- func (*StreamSubscription) ProtoMessage()
- func (m *StreamSubscription) Reset()
- func (m *StreamSubscription) Size() (n int)
- func (m *StreamSubscription) String() string
- func (m *StreamSubscription) Unmarshal(dAtA []byte) error
- func (m *StreamSubscription) XXX_DiscardUnknown()
- func (m *StreamSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StreamSubscription) XXX_Merge(src proto.Message)
- func (m *StreamSubscription) XXX_Size() int
- func (m *StreamSubscription) XXX_Unmarshal(b []byte) error
- type SubscriptionType
- type TradeSessionAuth
- func (*TradeSessionAuth) Descriptor() ([]byte, []int)
- func (m *TradeSessionAuth) GetApiKey() string
- func (m *TradeSessionAuth) GetApiSecret() string
- func (m *TradeSessionAuth) GetCustomerId() string
- func (m *TradeSessionAuth) GetKeyPassphrase() string
- func (m *TradeSessionAuth) Marshal() (dAtA []byte, err error)
- func (m *TradeSessionAuth) MarshalTo(dAtA []byte) (int, error)
- func (*TradeSessionAuth) ProtoMessage()
- func (m *TradeSessionAuth) Reset()
- func (m *TradeSessionAuth) Size() (n int)
- func (m *TradeSessionAuth) String() string
- func (m *TradeSessionAuth) Unmarshal(dAtA []byte) error
- func (m *TradeSessionAuth) XXX_DiscardUnknown()
- func (m *TradeSessionAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TradeSessionAuth) XXX_Merge(src proto.Message)
- func (m *TradeSessionAuth) XXX_Size() int
- func (m *TradeSessionAuth) XXX_Unmarshal(b []byte) error
- type TradeSubscription
- func (*TradeSubscription) Descriptor() ([]byte, []int)
- func (m *TradeSubscription) GetAuth() *TradeSessionAuth
- func (m *TradeSubscription) GetMarketId() string
- func (m *TradeSubscription) Marshal() (dAtA []byte, err error)
- func (m *TradeSubscription) MarshalTo(dAtA []byte) (int, error)
- func (*TradeSubscription) ProtoMessage()
- func (m *TradeSubscription) Reset()
- func (m *TradeSubscription) Size() (n int)
- func (m *TradeSubscription) String() string
- func (m *TradeSubscription) Unmarshal(dAtA []byte) error
- func (m *TradeSubscription) XXX_DiscardUnknown()
- func (m *TradeSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TradeSubscription) XXX_Merge(src proto.Message)
- func (m *TradeSubscription) XXX_Size() int
- func (m *TradeSubscription) XXX_Unmarshal(b []byte) error
- type TriggerSubscription
- func (*TriggerSubscription) Descriptor() ([]byte, []int)
- func (m *TriggerSubscription) Marshal() (dAtA []byte, err error)
- func (m *TriggerSubscription) MarshalTo(dAtA []byte) (int, error)
- func (*TriggerSubscription) ProtoMessage()
- func (m *TriggerSubscription) Reset()
- func (m *TriggerSubscription) Size() (n int)
- func (m *TriggerSubscription) String() string
- func (m *TriggerSubscription) Unmarshal(dAtA []byte) error
- func (m *TriggerSubscription) XXX_DiscardUnknown()
- func (m *TriggerSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TriggerSubscription) XXX_Merge(src proto.Message)
- func (m *TriggerSubscription) XXX_Size() int
- func (m *TriggerSubscription) XXX_Unmarshal(b []byte) error
- type WebAuthenticationMessage
- func (*WebAuthenticationMessage) Descriptor() ([]byte, []int)
- func (m *WebAuthenticationMessage) GetAccessList() []string
- func (m *WebAuthenticationMessage) GetIdentification() *ClientIdentificationMessage
- func (m *WebAuthenticationMessage) GetNonce() string
- func (m *WebAuthenticationMessage) GetToken() string
- func (m *WebAuthenticationMessage) Marshal() (dAtA []byte, err error)
- func (m *WebAuthenticationMessage) MarshalTo(dAtA []byte) (int, error)
- func (*WebAuthenticationMessage) ProtoMessage()
- func (m *WebAuthenticationMessage) Reset()
- func (m *WebAuthenticationMessage) Size() (n int)
- func (m *WebAuthenticationMessage) String() string
- func (m *WebAuthenticationMessage) Unmarshal(dAtA []byte) error
- func (m *WebAuthenticationMessage) XXX_DiscardUnknown()
- func (m *WebAuthenticationMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *WebAuthenticationMessage) XXX_Merge(src proto.Message)
- func (m *WebAuthenticationMessage) XXX_Size() int
- func (m *WebAuthenticationMessage) XXX_Unmarshal(b []byte) error
- type WebAuthenticationResult
- func (*WebAuthenticationResult) Descriptor() ([]byte, []int)
- func (m *WebAuthenticationResult) GetStatus() WebAuthenticationResult_Status
- func (m *WebAuthenticationResult) Marshal() (dAtA []byte, err error)
- func (m *WebAuthenticationResult) MarshalTo(dAtA []byte) (int, error)
- func (*WebAuthenticationResult) ProtoMessage()
- func (m *WebAuthenticationResult) Reset()
- func (m *WebAuthenticationResult) Size() (n int)
- func (m *WebAuthenticationResult) String() string
- func (m *WebAuthenticationResult) Unmarshal(dAtA []byte) error
- func (m *WebAuthenticationResult) XXX_DiscardUnknown()
- func (m *WebAuthenticationResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *WebAuthenticationResult) XXX_Merge(src proto.Message)
- func (m *WebAuthenticationResult) XXX_Size() int
- func (m *WebAuthenticationResult) XXX_Unmarshal(b []byte) error
- type WebAuthenticationResult_Status
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthClient = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowClient = fmt.Errorf("proto: integer overflow") )
var APIAuthenticationMessage_Source_name = map[int32]string{
0: "UNKNOWN",
1: "GOLANG_SDK",
2: "JAVASCRIPT_SDK",
3: "NODE_SDK",
5: "RUST_SDK",
4: "CW_WEB",
}
var APIAuthenticationMessage_Source_value = map[string]int32{
"UNKNOWN": 0,
"GOLANG_SDK": 1,
"JAVASCRIPT_SDK": 2,
"NODE_SDK": 3,
"RUST_SDK": 5,
"CW_WEB": 4,
}
var WebAuthenticationResult_Status_name = map[int32]string{
0: "UNKNOWN",
1: "AUTHENTICATED",
2: "INVALID_SESSION",
3: "MFA_REQUIRED",
}
var WebAuthenticationResult_Status_value = map[string]int32{
"UNKNOWN": 0,
"AUTHENTICATED": 1,
"INVALID_SESSION": 2,
"MFA_REQUIRED": 3,
}
Functions ¶
func KeyFromSub ¶
func KeyFromSub(sub *ClientSubscription) string
KeyFromString converts a given ClientSubscription to legacy string-based key.
func KeysFromSubs ¶
func KeysFromSubs(subs []*ClientSubscription) []string
KeysFromSubs converts a given list of ClientSubscription to list of legacy string-based keys.
Types ¶
type APIAuthenticationMessage ¶
type APIAuthenticationMessage struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Nonce string `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"` ApiKey string `protobuf:"bytes,3,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"` Source APIAuthenticationMessage_Source `protobuf:"varint,4,opt,name=source,proto3,enum=ProtobufClient.APIAuthenticationMessage_Source" json:"source,omitempty"` Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"` Subscriptions []string `protobuf:"bytes,6,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` // Deprecated: Do not use. ClientSubscriptions []*ClientSubscription `protobuf:"bytes,7,rep,name=client_subscriptions,json=clientSubscriptions,proto3" json:"client_subscriptions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*APIAuthenticationMessage) Descriptor ¶
func (*APIAuthenticationMessage) Descriptor() ([]byte, []int)
func (*APIAuthenticationMessage) GetApiKey ¶
func (m *APIAuthenticationMessage) GetApiKey() string
func (*APIAuthenticationMessage) GetClientSubscriptions ¶
func (m *APIAuthenticationMessage) GetClientSubscriptions() []*ClientSubscription
func (*APIAuthenticationMessage) GetNonce ¶
func (m *APIAuthenticationMessage) GetNonce() string
func (*APIAuthenticationMessage) GetSource ¶
func (m *APIAuthenticationMessage) GetSource() APIAuthenticationMessage_Source
func (*APIAuthenticationMessage) GetSubscriptions
deprecated
func (m *APIAuthenticationMessage) GetSubscriptions() []string
Deprecated: Do not use.
func (*APIAuthenticationMessage) GetToken ¶
func (m *APIAuthenticationMessage) GetToken() string
func (*APIAuthenticationMessage) GetVersion ¶
func (m *APIAuthenticationMessage) GetVersion() string
func (*APIAuthenticationMessage) Marshal ¶
func (m *APIAuthenticationMessage) Marshal() (dAtA []byte, err error)
func (*APIAuthenticationMessage) MarshalTo ¶
func (m *APIAuthenticationMessage) MarshalTo(dAtA []byte) (int, error)
func (*APIAuthenticationMessage) ProtoMessage ¶
func (*APIAuthenticationMessage) ProtoMessage()
func (*APIAuthenticationMessage) Reset ¶
func (m *APIAuthenticationMessage) Reset()
func (*APIAuthenticationMessage) Size ¶
func (m *APIAuthenticationMessage) Size() (n int)
func (*APIAuthenticationMessage) String ¶
func (m *APIAuthenticationMessage) String() string
func (*APIAuthenticationMessage) Unmarshal ¶
func (m *APIAuthenticationMessage) Unmarshal(dAtA []byte) error
func (*APIAuthenticationMessage) XXX_DiscardUnknown ¶
func (m *APIAuthenticationMessage) XXX_DiscardUnknown()
func (*APIAuthenticationMessage) XXX_Marshal ¶
func (m *APIAuthenticationMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*APIAuthenticationMessage) XXX_Merge ¶
func (dst *APIAuthenticationMessage) XXX_Merge(src proto.Message)
func (*APIAuthenticationMessage) XXX_Size ¶
func (m *APIAuthenticationMessage) XXX_Size() int
func (*APIAuthenticationMessage) XXX_Unmarshal ¶
func (m *APIAuthenticationMessage) XXX_Unmarshal(b []byte) error
type APIAuthenticationMessage_Source ¶
type APIAuthenticationMessage_Source int32
const ( APIAuthenticationMessage_UNKNOWN APIAuthenticationMessage_Source = 0 APIAuthenticationMessage_GOLANG_SDK APIAuthenticationMessage_Source = 1 APIAuthenticationMessage_JAVASCRIPT_SDK APIAuthenticationMessage_Source = 2 APIAuthenticationMessage_NODE_SDK APIAuthenticationMessage_Source = 3 APIAuthenticationMessage_RUST_SDK APIAuthenticationMessage_Source = 5 APIAuthenticationMessage_CW_WEB APIAuthenticationMessage_Source = 4 )
func (APIAuthenticationMessage_Source) EnumDescriptor ¶
func (APIAuthenticationMessage_Source) EnumDescriptor() ([]byte, []int)
func (APIAuthenticationMessage_Source) String ¶
func (x APIAuthenticationMessage_Source) String() string
type ClientIdentificationMessage ¶
type ClientIdentificationMessage struct { Useragent string `protobuf:"bytes,1,opt,name=useragent,proto3" json:"useragent,omitempty"` Revision string `protobuf:"bytes,2,opt,name=revision,proto3" json:"revision,omitempty"` Integration string `protobuf:"bytes,3,opt,name=integration,proto3" json:"integration,omitempty"` Locale string `protobuf:"bytes,4,opt,name=locale,proto3" json:"locale,omitempty"` Subscriptions []string `protobuf:"bytes,5,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` // Deprecated: Do not use. ClientSubscriptions []*ClientSubscription `protobuf:"bytes,6,rep,name=clientSubscriptions,proto3" json:"clientSubscriptions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ClientIdentificationMessage is the first message sent is from the client to the server, identifying itself and the subscriptions it desires.
func (*ClientIdentificationMessage) Descriptor ¶
func (*ClientIdentificationMessage) Descriptor() ([]byte, []int)
func (*ClientIdentificationMessage) GetClientSubscriptions ¶
func (m *ClientIdentificationMessage) GetClientSubscriptions() []*ClientSubscription
func (*ClientIdentificationMessage) GetIntegration ¶
func (m *ClientIdentificationMessage) GetIntegration() string
func (*ClientIdentificationMessage) GetLocale ¶
func (m *ClientIdentificationMessage) GetLocale() string
func (*ClientIdentificationMessage) GetRevision ¶
func (m *ClientIdentificationMessage) GetRevision() string
func (*ClientIdentificationMessage) GetSubscriptions
deprecated
func (m *ClientIdentificationMessage) GetSubscriptions() []string
Deprecated: Do not use.
func (*ClientIdentificationMessage) GetUseragent ¶
func (m *ClientIdentificationMessage) GetUseragent() string
func (*ClientIdentificationMessage) Marshal ¶
func (m *ClientIdentificationMessage) Marshal() (dAtA []byte, err error)
func (*ClientIdentificationMessage) MarshalTo ¶
func (m *ClientIdentificationMessage) MarshalTo(dAtA []byte) (int, error)
func (*ClientIdentificationMessage) ProtoMessage ¶
func (*ClientIdentificationMessage) ProtoMessage()
func (*ClientIdentificationMessage) Reset ¶
func (m *ClientIdentificationMessage) Reset()
func (*ClientIdentificationMessage) Size ¶
func (m *ClientIdentificationMessage) Size() (n int)
func (*ClientIdentificationMessage) String ¶
func (m *ClientIdentificationMessage) String() string
func (*ClientIdentificationMessage) Unmarshal ¶
func (m *ClientIdentificationMessage) Unmarshal(dAtA []byte) error
func (*ClientIdentificationMessage) XXX_DiscardUnknown ¶
func (m *ClientIdentificationMessage) XXX_DiscardUnknown()
func (*ClientIdentificationMessage) XXX_Marshal ¶
func (m *ClientIdentificationMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientIdentificationMessage) XXX_Merge ¶
func (dst *ClientIdentificationMessage) XXX_Merge(src proto.Message)
func (*ClientIdentificationMessage) XXX_Size ¶
func (m *ClientIdentificationMessage) XXX_Size() int
func (*ClientIdentificationMessage) XXX_Unmarshal ¶
func (m *ClientIdentificationMessage) XXX_Unmarshal(b []byte) error
type ClientMessage ¶
type ClientMessage struct { // Types that are valid to be assigned to Body: // *ClientMessage_Identification // *ClientMessage_Subscribe // *ClientMessage_Unsubscribe // *ClientMessage_WebAuthentication // *ClientMessage_ApiAuthentication // *ClientMessage_ClientSession Body isClientMessage_Body `protobuf_oneof:"body"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ClientMessage is a wrapper message used to describe the supplied client message and pass metadata about the client.
func DeserializeClientMessage ¶
func DeserializeClientMessage(msgData []byte) (msg ClientMessage, err error)
DeserializeClientMessage decodes the client message and switches based on the message format. This is needed because older clients may be pushing ClientIdentificationMessages not wrapped in the ClientMessage envelope.
func (*ClientMessage) Descriptor ¶
func (*ClientMessage) Descriptor() ([]byte, []int)
func (*ClientMessage) GetApiAuthentication ¶
func (m *ClientMessage) GetApiAuthentication() *APIAuthenticationMessage
func (*ClientMessage) GetBody ¶
func (m *ClientMessage) GetBody() isClientMessage_Body
func (*ClientMessage) GetClientSession ¶
func (m *ClientMessage) GetClientSession() *ClientSessionMessage
func (*ClientMessage) GetIdentification ¶
func (m *ClientMessage) GetIdentification() *ClientIdentificationMessage
func (*ClientMessage) GetSubscribe ¶
func (m *ClientMessage) GetSubscribe() *ClientSubscribeMessage
func (*ClientMessage) GetUnsubscribe ¶
func (m *ClientMessage) GetUnsubscribe() *ClientUnsubscribeMessage
func (*ClientMessage) GetWebAuthentication ¶
func (m *ClientMessage) GetWebAuthentication() *WebAuthenticationMessage
func (*ClientMessage) Marshal ¶
func (m *ClientMessage) Marshal() (dAtA []byte, err error)
func (*ClientMessage) ProtoMessage ¶
func (*ClientMessage) ProtoMessage()
func (*ClientMessage) Reset ¶
func (m *ClientMessage) Reset()
func (*ClientMessage) Size ¶
func (m *ClientMessage) Size() (n int)
func (*ClientMessage) String ¶
func (m *ClientMessage) String() string
func (*ClientMessage) Unmarshal ¶
func (m *ClientMessage) Unmarshal(dAtA []byte) error
func (*ClientMessage) XXX_DiscardUnknown ¶
func (m *ClientMessage) XXX_DiscardUnknown()
func (*ClientMessage) XXX_Marshal ¶
func (m *ClientMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientMessage) XXX_Merge ¶
func (dst *ClientMessage) XXX_Merge(src proto.Message)
func (*ClientMessage) XXX_OneofFuncs ¶
func (*ClientMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*ClientMessage) XXX_Size ¶
func (m *ClientMessage) XXX_Size() int
func (*ClientMessage) XXX_Unmarshal ¶
func (m *ClientMessage) XXX_Unmarshal(b []byte) error
type ClientMessage_ApiAuthentication ¶
type ClientMessage_ApiAuthentication struct {
ApiAuthentication *APIAuthenticationMessage `protobuf:"bytes,5,opt,name=apiAuthentication,proto3,oneof"`
}
func (*ClientMessage_ApiAuthentication) MarshalTo ¶
func (m *ClientMessage_ApiAuthentication) MarshalTo(dAtA []byte) (int, error)
func (*ClientMessage_ApiAuthentication) Size ¶
func (m *ClientMessage_ApiAuthentication) Size() (n int)
type ClientMessage_ClientSession ¶
type ClientMessage_ClientSession struct {
ClientSession *ClientSessionMessage `protobuf:"bytes,6,opt,name=clientSession,proto3,oneof"`
}
func (*ClientMessage_ClientSession) MarshalTo ¶
func (m *ClientMessage_ClientSession) MarshalTo(dAtA []byte) (int, error)
func (*ClientMessage_ClientSession) Size ¶
func (m *ClientMessage_ClientSession) Size() (n int)
type ClientMessage_Identification ¶
type ClientMessage_Identification struct {
Identification *ClientIdentificationMessage `protobuf:"bytes,1,opt,name=identification,proto3,oneof"`
}
func (*ClientMessage_Identification) MarshalTo ¶
func (m *ClientMessage_Identification) MarshalTo(dAtA []byte) (int, error)
func (*ClientMessage_Identification) Size ¶
func (m *ClientMessage_Identification) Size() (n int)
type ClientMessage_Subscribe ¶
type ClientMessage_Subscribe struct {
Subscribe *ClientSubscribeMessage `protobuf:"bytes,2,opt,name=subscribe,proto3,oneof"`
}
func (*ClientMessage_Subscribe) MarshalTo ¶
func (m *ClientMessage_Subscribe) MarshalTo(dAtA []byte) (int, error)
func (*ClientMessage_Subscribe) Size ¶
func (m *ClientMessage_Subscribe) Size() (n int)
type ClientMessage_Unsubscribe ¶
type ClientMessage_Unsubscribe struct {
Unsubscribe *ClientUnsubscribeMessage `protobuf:"bytes,3,opt,name=unsubscribe,proto3,oneof"`
}
func (*ClientMessage_Unsubscribe) MarshalTo ¶
func (m *ClientMessage_Unsubscribe) MarshalTo(dAtA []byte) (int, error)
func (*ClientMessage_Unsubscribe) Size ¶
func (m *ClientMessage_Unsubscribe) Size() (n int)
type ClientMessage_WebAuthentication ¶
type ClientMessage_WebAuthentication struct {
WebAuthentication *WebAuthenticationMessage `protobuf:"bytes,4,opt,name=webAuthentication,proto3,oneof"`
}
func (*ClientMessage_WebAuthentication) MarshalTo ¶
func (m *ClientMessage_WebAuthentication) MarshalTo(dAtA []byte) (int, error)
func (*ClientMessage_WebAuthentication) Size ¶
func (m *ClientMessage_WebAuthentication) Size() (n int)
type ClientSessionMessage ¶
type ClientSessionMessage struct { // Types that are valid to be assigned to SessionConfig: // *ClientSessionMessage_Session_ // *ClientSessionMessage_AnonymousTradingSession_ SessionConfig isClientSessionMessage_SessionConfig `protobuf_oneof:"SessionConfig"` Identification *ClientIdentificationMessage `protobuf:"bytes,3,opt,name=identification,proto3" json:"identification,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClientSessionMessage) Descriptor ¶
func (*ClientSessionMessage) Descriptor() ([]byte, []int)
func (*ClientSessionMessage) GetAnonymousTradingSession ¶
func (m *ClientSessionMessage) GetAnonymousTradingSession() *ClientSessionMessage_AnonymousTradingSession
func (*ClientSessionMessage) GetIdentification ¶
func (m *ClientSessionMessage) GetIdentification() *ClientIdentificationMessage
func (*ClientSessionMessage) GetSession ¶
func (m *ClientSessionMessage) GetSession() *ClientSessionMessage_Session
func (*ClientSessionMessage) GetSessionConfig ¶
func (m *ClientSessionMessage) GetSessionConfig() isClientSessionMessage_SessionConfig
func (*ClientSessionMessage) Marshal ¶
func (m *ClientSessionMessage) Marshal() (dAtA []byte, err error)
func (*ClientSessionMessage) MarshalTo ¶
func (m *ClientSessionMessage) MarshalTo(dAtA []byte) (int, error)
func (*ClientSessionMessage) ProtoMessage ¶
func (*ClientSessionMessage) ProtoMessage()
func (*ClientSessionMessage) Reset ¶
func (m *ClientSessionMessage) Reset()
func (*ClientSessionMessage) Size ¶
func (m *ClientSessionMessage) Size() (n int)
func (*ClientSessionMessage) String ¶
func (m *ClientSessionMessage) String() string
func (*ClientSessionMessage) Unmarshal ¶
func (m *ClientSessionMessage) Unmarshal(dAtA []byte) error
func (*ClientSessionMessage) XXX_DiscardUnknown ¶
func (m *ClientSessionMessage) XXX_DiscardUnknown()
func (*ClientSessionMessage) XXX_Marshal ¶
func (m *ClientSessionMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientSessionMessage) XXX_Merge ¶
func (dst *ClientSessionMessage) XXX_Merge(src proto.Message)
func (*ClientSessionMessage) XXX_OneofFuncs ¶
func (*ClientSessionMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*ClientSessionMessage) XXX_Size ¶
func (m *ClientSessionMessage) XXX_Size() int
func (*ClientSessionMessage) XXX_Unmarshal ¶
func (m *ClientSessionMessage) XXX_Unmarshal(b []byte) error
type ClientSessionMessage_AnonymousTradingSession ¶
type ClientSessionMessage_AnonymousTradingSession struct { Exchange string `protobuf:"bytes,1,opt,name=exchange,proto3" json:"exchange,omitempty"` Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` Expiration int64 `protobuf:"varint,3,opt,name=expiration,proto3" json:"expiration,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClientSessionMessage_AnonymousTradingSession) Descriptor ¶
func (*ClientSessionMessage_AnonymousTradingSession) Descriptor() ([]byte, []int)
func (*ClientSessionMessage_AnonymousTradingSession) GetExchange ¶
func (m *ClientSessionMessage_AnonymousTradingSession) GetExchange() string
func (*ClientSessionMessage_AnonymousTradingSession) GetExpiration ¶
func (m *ClientSessionMessage_AnonymousTradingSession) GetExpiration() int64
func (*ClientSessionMessage_AnonymousTradingSession) GetToken ¶
func (m *ClientSessionMessage_AnonymousTradingSession) GetToken() string
func (*ClientSessionMessage_AnonymousTradingSession) Marshal ¶
func (m *ClientSessionMessage_AnonymousTradingSession) Marshal() (dAtA []byte, err error)
func (*ClientSessionMessage_AnonymousTradingSession) MarshalTo ¶
func (m *ClientSessionMessage_AnonymousTradingSession) MarshalTo(dAtA []byte) (int, error)
func (*ClientSessionMessage_AnonymousTradingSession) ProtoMessage ¶
func (*ClientSessionMessage_AnonymousTradingSession) ProtoMessage()
func (*ClientSessionMessage_AnonymousTradingSession) Reset ¶
func (m *ClientSessionMessage_AnonymousTradingSession) Reset()
func (*ClientSessionMessage_AnonymousTradingSession) Size ¶
func (m *ClientSessionMessage_AnonymousTradingSession) Size() (n int)
func (*ClientSessionMessage_AnonymousTradingSession) String ¶
func (m *ClientSessionMessage_AnonymousTradingSession) String() string
func (*ClientSessionMessage_AnonymousTradingSession) Unmarshal ¶
func (m *ClientSessionMessage_AnonymousTradingSession) Unmarshal(dAtA []byte) error
func (*ClientSessionMessage_AnonymousTradingSession) XXX_DiscardUnknown ¶
func (m *ClientSessionMessage_AnonymousTradingSession) XXX_DiscardUnknown()
func (*ClientSessionMessage_AnonymousTradingSession) XXX_Marshal ¶
func (m *ClientSessionMessage_AnonymousTradingSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientSessionMessage_AnonymousTradingSession) XXX_Merge ¶
func (dst *ClientSessionMessage_AnonymousTradingSession) XXX_Merge(src proto.Message)
func (*ClientSessionMessage_AnonymousTradingSession) XXX_Size ¶
func (m *ClientSessionMessage_AnonymousTradingSession) XXX_Size() int
func (*ClientSessionMessage_AnonymousTradingSession) XXX_Unmarshal ¶
func (m *ClientSessionMessage_AnonymousTradingSession) XXX_Unmarshal(b []byte) error
type ClientSessionMessage_AnonymousTradingSession_ ¶
type ClientSessionMessage_AnonymousTradingSession_ struct {
AnonymousTradingSession *ClientSessionMessage_AnonymousTradingSession `protobuf:"bytes,2,opt,name=anonymousTradingSession,proto3,oneof"`
}
func (*ClientSessionMessage_AnonymousTradingSession_) MarshalTo ¶
func (m *ClientSessionMessage_AnonymousTradingSession_) MarshalTo(dAtA []byte) (int, error)
func (*ClientSessionMessage_AnonymousTradingSession_) Size ¶
func (m *ClientSessionMessage_AnonymousTradingSession_) Size() (n int)
type ClientSessionMessage_Session ¶
type ClientSessionMessage_Session struct { UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` Expires int64 `protobuf:"varint,2,opt,name=expires,proto3" json:"expires,omitempty"` Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"` MfaToken string `protobuf:"bytes,4,opt,name=mfaToken,proto3" json:"mfaToken,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClientSessionMessage_Session) Descriptor ¶
func (*ClientSessionMessage_Session) Descriptor() ([]byte, []int)
func (*ClientSessionMessage_Session) GetExpires ¶
func (m *ClientSessionMessage_Session) GetExpires() int64
func (*ClientSessionMessage_Session) GetMfaToken ¶
func (m *ClientSessionMessage_Session) GetMfaToken() string
func (*ClientSessionMessage_Session) GetToken ¶
func (m *ClientSessionMessage_Session) GetToken() string
func (*ClientSessionMessage_Session) GetUserId ¶
func (m *ClientSessionMessage_Session) GetUserId() string
func (*ClientSessionMessage_Session) Marshal ¶
func (m *ClientSessionMessage_Session) Marshal() (dAtA []byte, err error)
func (*ClientSessionMessage_Session) MarshalTo ¶
func (m *ClientSessionMessage_Session) MarshalTo(dAtA []byte) (int, error)
func (*ClientSessionMessage_Session) ProtoMessage ¶
func (*ClientSessionMessage_Session) ProtoMessage()
func (*ClientSessionMessage_Session) Reset ¶
func (m *ClientSessionMessage_Session) Reset()
func (*ClientSessionMessage_Session) Size ¶
func (m *ClientSessionMessage_Session) Size() (n int)
func (*ClientSessionMessage_Session) String ¶
func (m *ClientSessionMessage_Session) String() string
func (*ClientSessionMessage_Session) Unmarshal ¶
func (m *ClientSessionMessage_Session) Unmarshal(dAtA []byte) error
func (*ClientSessionMessage_Session) XXX_DiscardUnknown ¶
func (m *ClientSessionMessage_Session) XXX_DiscardUnknown()
func (*ClientSessionMessage_Session) XXX_Marshal ¶
func (m *ClientSessionMessage_Session) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientSessionMessage_Session) XXX_Merge ¶
func (dst *ClientSessionMessage_Session) XXX_Merge(src proto.Message)
func (*ClientSessionMessage_Session) XXX_Size ¶
func (m *ClientSessionMessage_Session) XXX_Size() int
func (*ClientSessionMessage_Session) XXX_Unmarshal ¶
func (m *ClientSessionMessage_Session) XXX_Unmarshal(b []byte) error
type ClientSessionMessage_Session_ ¶
type ClientSessionMessage_Session_ struct {
Session *ClientSessionMessage_Session `protobuf:"bytes,1,opt,name=session,proto3,oneof"`
}
func (*ClientSessionMessage_Session_) MarshalTo ¶
func (m *ClientSessionMessage_Session_) MarshalTo(dAtA []byte) (int, error)
func (*ClientSessionMessage_Session_) Size ¶
func (m *ClientSessionMessage_Session_) Size() (n int)
type ClientSubscribeMessage ¶
type ClientSubscribeMessage struct { SubscriptionKeys []string `protobuf:"bytes,1,rep,name=subscriptionKeys,proto3" json:"subscriptionKeys,omitempty"` // Deprecated: Do not use. Subscriptions []*ClientSubscription `protobuf:"bytes,2,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SubscribeMessage informs the Stream Hub to subscribe the current web socket to the supplied channel.
func (*ClientSubscribeMessage) Descriptor ¶
func (*ClientSubscribeMessage) Descriptor() ([]byte, []int)
func (*ClientSubscribeMessage) GetSubscriptionKeys
deprecated
func (m *ClientSubscribeMessage) GetSubscriptionKeys() []string
Deprecated: Do not use.
func (*ClientSubscribeMessage) GetSubscriptions ¶
func (m *ClientSubscribeMessage) GetSubscriptions() []*ClientSubscription
func (*ClientSubscribeMessage) Marshal ¶
func (m *ClientSubscribeMessage) Marshal() (dAtA []byte, err error)
func (*ClientSubscribeMessage) MarshalTo ¶
func (m *ClientSubscribeMessage) MarshalTo(dAtA []byte) (int, error)
func (*ClientSubscribeMessage) ProtoMessage ¶
func (*ClientSubscribeMessage) ProtoMessage()
func (*ClientSubscribeMessage) Reset ¶
func (m *ClientSubscribeMessage) Reset()
func (*ClientSubscribeMessage) Size ¶
func (m *ClientSubscribeMessage) Size() (n int)
func (*ClientSubscribeMessage) String ¶
func (m *ClientSubscribeMessage) String() string
func (*ClientSubscribeMessage) Unmarshal ¶
func (m *ClientSubscribeMessage) Unmarshal(dAtA []byte) error
func (*ClientSubscribeMessage) XXX_DiscardUnknown ¶
func (m *ClientSubscribeMessage) XXX_DiscardUnknown()
func (*ClientSubscribeMessage) XXX_Marshal ¶
func (m *ClientSubscribeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientSubscribeMessage) XXX_Merge ¶
func (dst *ClientSubscribeMessage) XXX_Merge(src proto.Message)
func (*ClientSubscribeMessage) XXX_Size ¶
func (m *ClientSubscribeMessage) XXX_Size() int
func (*ClientSubscribeMessage) XXX_Unmarshal ¶
func (m *ClientSubscribeMessage) XXX_Unmarshal(b []byte) error
type ClientSubscription ¶
type ClientSubscription struct { // Types that are valid to be assigned to Body: // *ClientSubscription_StreamSubscription // *ClientSubscription_TradeSubscription // *ClientSubscription_TriggerSubscription Body isClientSubscription_Body `protobuf_oneof:"body"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func SubFromString ¶
func SubFromString(kind SubscriptionType, key string) *ClientSubscription
SubFromString converts a given legacy string-based key to ClientSubscription.
func SubsFromString ¶
func SubsFromString(kind SubscriptionType, keys []string) []*ClientSubscription
SubsFromString converts a given list of legacy string-based keys to list ClientSubscription.
func (*ClientSubscription) Descriptor ¶
func (*ClientSubscription) Descriptor() ([]byte, []int)
func (*ClientSubscription) GetBody ¶
func (m *ClientSubscription) GetBody() isClientSubscription_Body
func (*ClientSubscription) GetStreamSubscription ¶
func (m *ClientSubscription) GetStreamSubscription() *StreamSubscription
func (*ClientSubscription) GetTradeSubscription ¶
func (m *ClientSubscription) GetTradeSubscription() *TradeSubscription
func (*ClientSubscription) GetTriggerSubscription ¶
func (m *ClientSubscription) GetTriggerSubscription() *TriggerSubscription
func (*ClientSubscription) Marshal ¶
func (m *ClientSubscription) Marshal() (dAtA []byte, err error)
func (*ClientSubscription) MarshalTo ¶
func (m *ClientSubscription) MarshalTo(dAtA []byte) (int, error)
func (*ClientSubscription) ProtoMessage ¶
func (*ClientSubscription) ProtoMessage()
func (*ClientSubscription) Reset ¶
func (m *ClientSubscription) Reset()
func (*ClientSubscription) Size ¶
func (m *ClientSubscription) Size() (n int)
func (*ClientSubscription) String ¶
func (m *ClientSubscription) String() string
func (*ClientSubscription) Unmarshal ¶
func (m *ClientSubscription) Unmarshal(dAtA []byte) error
func (*ClientSubscription) XXX_DiscardUnknown ¶
func (m *ClientSubscription) XXX_DiscardUnknown()
func (*ClientSubscription) XXX_Marshal ¶
func (m *ClientSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientSubscription) XXX_Merge ¶
func (dst *ClientSubscription) XXX_Merge(src proto.Message)
func (*ClientSubscription) XXX_OneofFuncs ¶
func (*ClientSubscription) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*ClientSubscription) XXX_Size ¶
func (m *ClientSubscription) XXX_Size() int
func (*ClientSubscription) XXX_Unmarshal ¶
func (m *ClientSubscription) XXX_Unmarshal(b []byte) error
type ClientSubscription_StreamSubscription ¶
type ClientSubscription_StreamSubscription struct {
StreamSubscription *StreamSubscription `protobuf:"bytes,1,opt,name=stream_subscription,json=streamSubscription,proto3,oneof"`
}
func (*ClientSubscription_StreamSubscription) MarshalTo ¶
func (m *ClientSubscription_StreamSubscription) MarshalTo(dAtA []byte) (int, error)
func (*ClientSubscription_StreamSubscription) Size ¶
func (m *ClientSubscription_StreamSubscription) Size() (n int)
type ClientSubscription_TradeSubscription ¶
type ClientSubscription_TradeSubscription struct {
TradeSubscription *TradeSubscription `protobuf:"bytes,2,opt,name=trade_subscription,json=tradeSubscription,proto3,oneof"`
}
func (*ClientSubscription_TradeSubscription) MarshalTo ¶
func (m *ClientSubscription_TradeSubscription) MarshalTo(dAtA []byte) (int, error)
func (*ClientSubscription_TradeSubscription) Size ¶
func (m *ClientSubscription_TradeSubscription) Size() (n int)
type ClientSubscription_TriggerSubscription ¶
type ClientSubscription_TriggerSubscription struct {
TriggerSubscription *TriggerSubscription `protobuf:"bytes,3,opt,name=trigger_subscription,json=triggerSubscription,proto3,oneof"`
}
func (*ClientSubscription_TriggerSubscription) MarshalTo ¶
func (m *ClientSubscription_TriggerSubscription) MarshalTo(dAtA []byte) (int, error)
func (*ClientSubscription_TriggerSubscription) Size ¶
func (m *ClientSubscription_TriggerSubscription) Size() (n int)
type ClientUnsubscribeMessage ¶
type ClientUnsubscribeMessage struct { SubscriptionKeys []string `protobuf:"bytes,1,rep,name=subscriptionKeys,proto3" json:"subscriptionKeys,omitempty"` // Deprecated: Do not use. Subscriptions []*ClientSubscription `protobuf:"bytes,2,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
UnsubscribeMessage informs the Stream Hub to unsubscribe the current web socket from the supplied channel.
func (*ClientUnsubscribeMessage) Descriptor ¶
func (*ClientUnsubscribeMessage) Descriptor() ([]byte, []int)
func (*ClientUnsubscribeMessage) GetSubscriptionKeys
deprecated
func (m *ClientUnsubscribeMessage) GetSubscriptionKeys() []string
Deprecated: Do not use.
func (*ClientUnsubscribeMessage) GetSubscriptions ¶
func (m *ClientUnsubscribeMessage) GetSubscriptions() []*ClientSubscription
func (*ClientUnsubscribeMessage) Marshal ¶
func (m *ClientUnsubscribeMessage) Marshal() (dAtA []byte, err error)
func (*ClientUnsubscribeMessage) MarshalTo ¶
func (m *ClientUnsubscribeMessage) MarshalTo(dAtA []byte) (int, error)
func (*ClientUnsubscribeMessage) ProtoMessage ¶
func (*ClientUnsubscribeMessage) ProtoMessage()
func (*ClientUnsubscribeMessage) Reset ¶
func (m *ClientUnsubscribeMessage) Reset()
func (*ClientUnsubscribeMessage) Size ¶
func (m *ClientUnsubscribeMessage) Size() (n int)
func (*ClientUnsubscribeMessage) String ¶
func (m *ClientUnsubscribeMessage) String() string
func (*ClientUnsubscribeMessage) Unmarshal ¶
func (m *ClientUnsubscribeMessage) Unmarshal(dAtA []byte) error
func (*ClientUnsubscribeMessage) XXX_DiscardUnknown ¶
func (m *ClientUnsubscribeMessage) XXX_DiscardUnknown()
func (*ClientUnsubscribeMessage) XXX_Marshal ¶
func (m *ClientUnsubscribeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientUnsubscribeMessage) XXX_Merge ¶
func (dst *ClientUnsubscribeMessage) XXX_Merge(src proto.Message)
func (*ClientUnsubscribeMessage) XXX_Size ¶
func (m *ClientUnsubscribeMessage) XXX_Size() int
func (*ClientUnsubscribeMessage) XXX_Unmarshal ¶
func (m *ClientUnsubscribeMessage) XXX_Unmarshal(b []byte) error
type StreamSubscription ¶
type StreamSubscription struct { Resource string `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StreamSubscription) Descriptor ¶
func (*StreamSubscription) Descriptor() ([]byte, []int)
func (*StreamSubscription) GetResource ¶
func (m *StreamSubscription) GetResource() string
func (*StreamSubscription) Marshal ¶
func (m *StreamSubscription) Marshal() (dAtA []byte, err error)
func (*StreamSubscription) MarshalTo ¶
func (m *StreamSubscription) MarshalTo(dAtA []byte) (int, error)
func (*StreamSubscription) ProtoMessage ¶
func (*StreamSubscription) ProtoMessage()
func (*StreamSubscription) Reset ¶
func (m *StreamSubscription) Reset()
func (*StreamSubscription) Size ¶
func (m *StreamSubscription) Size() (n int)
func (*StreamSubscription) String ¶
func (m *StreamSubscription) String() string
func (*StreamSubscription) Unmarshal ¶
func (m *StreamSubscription) Unmarshal(dAtA []byte) error
func (*StreamSubscription) XXX_DiscardUnknown ¶
func (m *StreamSubscription) XXX_DiscardUnknown()
func (*StreamSubscription) XXX_Marshal ¶
func (m *StreamSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamSubscription) XXX_Merge ¶
func (dst *StreamSubscription) XXX_Merge(src proto.Message)
func (*StreamSubscription) XXX_Size ¶
func (m *StreamSubscription) XXX_Size() int
func (*StreamSubscription) XXX_Unmarshal ¶
func (m *StreamSubscription) XXX_Unmarshal(b []byte) error
type SubscriptionType ¶
type SubscriptionType int
const ( SubscriptionTypeUnknown SubscriptionType = iota SubscriptionTypeStream SubscriptionTypeTrade )
type TradeSessionAuth ¶
type TradeSessionAuth struct { ApiKey string `protobuf:"bytes,1,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"` ApiSecret string `protobuf:"bytes,2,opt,name=api_secret,json=apiSecret,proto3" json:"api_secret,omitempty"` CustomerId string `protobuf:"bytes,3,opt,name=customer_id,json=customerId,proto3" json:"customer_id,omitempty"` KeyPassphrase string `protobuf:"bytes,4,opt,name=key_passphrase,json=keyPassphrase,proto3" json:"key_passphrase,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TradeSessionAuth) Descriptor ¶
func (*TradeSessionAuth) Descriptor() ([]byte, []int)
func (*TradeSessionAuth) GetApiKey ¶
func (m *TradeSessionAuth) GetApiKey() string
func (*TradeSessionAuth) GetApiSecret ¶
func (m *TradeSessionAuth) GetApiSecret() string
func (*TradeSessionAuth) GetCustomerId ¶
func (m *TradeSessionAuth) GetCustomerId() string
func (*TradeSessionAuth) GetKeyPassphrase ¶
func (m *TradeSessionAuth) GetKeyPassphrase() string
func (*TradeSessionAuth) Marshal ¶
func (m *TradeSessionAuth) Marshal() (dAtA []byte, err error)
func (*TradeSessionAuth) ProtoMessage ¶
func (*TradeSessionAuth) ProtoMessage()
func (*TradeSessionAuth) Reset ¶
func (m *TradeSessionAuth) Reset()
func (*TradeSessionAuth) Size ¶
func (m *TradeSessionAuth) Size() (n int)
func (*TradeSessionAuth) String ¶
func (m *TradeSessionAuth) String() string
func (*TradeSessionAuth) Unmarshal ¶
func (m *TradeSessionAuth) Unmarshal(dAtA []byte) error
func (*TradeSessionAuth) XXX_DiscardUnknown ¶
func (m *TradeSessionAuth) XXX_DiscardUnknown()
func (*TradeSessionAuth) XXX_Marshal ¶
func (m *TradeSessionAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TradeSessionAuth) XXX_Merge ¶
func (dst *TradeSessionAuth) XXX_Merge(src proto.Message)
func (*TradeSessionAuth) XXX_Size ¶
func (m *TradeSessionAuth) XXX_Size() int
func (*TradeSessionAuth) XXX_Unmarshal ¶
func (m *TradeSessionAuth) XXX_Unmarshal(b []byte) error
type TradeSubscription ¶
type TradeSubscription struct { MarketId string `protobuf:"bytes,1,opt,name=marketId,proto3" json:"marketId,omitempty"` // optional: use if supplying different exchange keys Auth *TradeSessionAuth `protobuf:"bytes,2,opt,name=auth,proto3" json:"auth,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TradeSubscription) Descriptor ¶
func (*TradeSubscription) Descriptor() ([]byte, []int)
func (*TradeSubscription) GetAuth ¶
func (m *TradeSubscription) GetAuth() *TradeSessionAuth
func (*TradeSubscription) GetMarketId ¶
func (m *TradeSubscription) GetMarketId() string
func (*TradeSubscription) Marshal ¶
func (m *TradeSubscription) Marshal() (dAtA []byte, err error)
func (*TradeSubscription) MarshalTo ¶
func (m *TradeSubscription) MarshalTo(dAtA []byte) (int, error)
func (*TradeSubscription) ProtoMessage ¶
func (*TradeSubscription) ProtoMessage()
func (*TradeSubscription) Reset ¶
func (m *TradeSubscription) Reset()
func (*TradeSubscription) Size ¶
func (m *TradeSubscription) Size() (n int)
func (*TradeSubscription) String ¶
func (m *TradeSubscription) String() string
func (*TradeSubscription) Unmarshal ¶
func (m *TradeSubscription) Unmarshal(dAtA []byte) error
func (*TradeSubscription) XXX_DiscardUnknown ¶
func (m *TradeSubscription) XXX_DiscardUnknown()
func (*TradeSubscription) XXX_Marshal ¶
func (m *TradeSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TradeSubscription) XXX_Merge ¶
func (dst *TradeSubscription) XXX_Merge(src proto.Message)
func (*TradeSubscription) XXX_Size ¶
func (m *TradeSubscription) XXX_Size() int
func (*TradeSubscription) XXX_Unmarshal ¶
func (m *TradeSubscription) XXX_Unmarshal(b []byte) error
type TriggerSubscription ¶
type TriggerSubscription struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TriggerSubscription) Descriptor ¶
func (*TriggerSubscription) Descriptor() ([]byte, []int)
func (*TriggerSubscription) Marshal ¶
func (m *TriggerSubscription) Marshal() (dAtA []byte, err error)
func (*TriggerSubscription) MarshalTo ¶
func (m *TriggerSubscription) MarshalTo(dAtA []byte) (int, error)
func (*TriggerSubscription) ProtoMessage ¶
func (*TriggerSubscription) ProtoMessage()
func (*TriggerSubscription) Reset ¶
func (m *TriggerSubscription) Reset()
func (*TriggerSubscription) Size ¶
func (m *TriggerSubscription) Size() (n int)
func (*TriggerSubscription) String ¶
func (m *TriggerSubscription) String() string
func (*TriggerSubscription) Unmarshal ¶
func (m *TriggerSubscription) Unmarshal(dAtA []byte) error
func (*TriggerSubscription) XXX_DiscardUnknown ¶
func (m *TriggerSubscription) XXX_DiscardUnknown()
func (*TriggerSubscription) XXX_Marshal ¶
func (m *TriggerSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TriggerSubscription) XXX_Merge ¶
func (dst *TriggerSubscription) XXX_Merge(src proto.Message)
func (*TriggerSubscription) XXX_Size ¶
func (m *TriggerSubscription) XXX_Size() int
func (*TriggerSubscription) XXX_Unmarshal ¶
func (m *TriggerSubscription) XXX_Unmarshal(b []byte) error
type WebAuthenticationMessage ¶
type WebAuthenticationMessage struct { Identification *ClientIdentificationMessage `protobuf:"bytes,1,opt,name=identification,proto3" json:"identification,omitempty"` Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` Nonce string `protobuf:"bytes,3,opt,name=nonce,proto3" json:"nonce,omitempty"` AccessList []string `protobuf:"bytes,4,rep,name=access_list,json=accessList,proto3" json:"access_list,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WebAuthenticationMessage) Descriptor ¶
func (*WebAuthenticationMessage) Descriptor() ([]byte, []int)
func (*WebAuthenticationMessage) GetAccessList ¶
func (m *WebAuthenticationMessage) GetAccessList() []string
func (*WebAuthenticationMessage) GetIdentification ¶
func (m *WebAuthenticationMessage) GetIdentification() *ClientIdentificationMessage
func (*WebAuthenticationMessage) GetNonce ¶
func (m *WebAuthenticationMessage) GetNonce() string
func (*WebAuthenticationMessage) GetToken ¶
func (m *WebAuthenticationMessage) GetToken() string
func (*WebAuthenticationMessage) Marshal ¶
func (m *WebAuthenticationMessage) Marshal() (dAtA []byte, err error)
func (*WebAuthenticationMessage) MarshalTo ¶
func (m *WebAuthenticationMessage) MarshalTo(dAtA []byte) (int, error)
func (*WebAuthenticationMessage) ProtoMessage ¶
func (*WebAuthenticationMessage) ProtoMessage()
func (*WebAuthenticationMessage) Reset ¶
func (m *WebAuthenticationMessage) Reset()
func (*WebAuthenticationMessage) Size ¶
func (m *WebAuthenticationMessage) Size() (n int)
func (*WebAuthenticationMessage) String ¶
func (m *WebAuthenticationMessage) String() string
func (*WebAuthenticationMessage) Unmarshal ¶
func (m *WebAuthenticationMessage) Unmarshal(dAtA []byte) error
func (*WebAuthenticationMessage) XXX_DiscardUnknown ¶
func (m *WebAuthenticationMessage) XXX_DiscardUnknown()
func (*WebAuthenticationMessage) XXX_Marshal ¶
func (m *WebAuthenticationMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WebAuthenticationMessage) XXX_Merge ¶
func (dst *WebAuthenticationMessage) XXX_Merge(src proto.Message)
func (*WebAuthenticationMessage) XXX_Size ¶
func (m *WebAuthenticationMessage) XXX_Size() int
func (*WebAuthenticationMessage) XXX_Unmarshal ¶
func (m *WebAuthenticationMessage) XXX_Unmarshal(b []byte) error
type WebAuthenticationResult ¶
type WebAuthenticationResult struct { Status WebAuthenticationResult_Status `protobuf:"varint,1,opt,name=status,proto3,enum=ProtobufClient.WebAuthenticationResult_Status" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WebAuthenticationResult) Descriptor ¶
func (*WebAuthenticationResult) Descriptor() ([]byte, []int)
func (*WebAuthenticationResult) GetStatus ¶
func (m *WebAuthenticationResult) GetStatus() WebAuthenticationResult_Status
func (*WebAuthenticationResult) Marshal ¶
func (m *WebAuthenticationResult) Marshal() (dAtA []byte, err error)
func (*WebAuthenticationResult) MarshalTo ¶
func (m *WebAuthenticationResult) MarshalTo(dAtA []byte) (int, error)
func (*WebAuthenticationResult) ProtoMessage ¶
func (*WebAuthenticationResult) ProtoMessage()
func (*WebAuthenticationResult) Reset ¶
func (m *WebAuthenticationResult) Reset()
func (*WebAuthenticationResult) Size ¶
func (m *WebAuthenticationResult) Size() (n int)
func (*WebAuthenticationResult) String ¶
func (m *WebAuthenticationResult) String() string
func (*WebAuthenticationResult) Unmarshal ¶
func (m *WebAuthenticationResult) Unmarshal(dAtA []byte) error
func (*WebAuthenticationResult) XXX_DiscardUnknown ¶
func (m *WebAuthenticationResult) XXX_DiscardUnknown()
func (*WebAuthenticationResult) XXX_Marshal ¶
func (m *WebAuthenticationResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WebAuthenticationResult) XXX_Merge ¶
func (dst *WebAuthenticationResult) XXX_Merge(src proto.Message)
func (*WebAuthenticationResult) XXX_Size ¶
func (m *WebAuthenticationResult) XXX_Size() int
func (*WebAuthenticationResult) XXX_Unmarshal ¶
func (m *WebAuthenticationResult) XXX_Unmarshal(b []byte) error
type WebAuthenticationResult_Status ¶
type WebAuthenticationResult_Status int32
const ( WebAuthenticationResult_UNKNOWN WebAuthenticationResult_Status = 0 WebAuthenticationResult_AUTHENTICATED WebAuthenticationResult_Status = 1 WebAuthenticationResult_INVALID_SESSION WebAuthenticationResult_Status = 2 WebAuthenticationResult_MFA_REQUIRED WebAuthenticationResult_Status = 3 )
func (WebAuthenticationResult_Status) EnumDescriptor ¶
func (WebAuthenticationResult_Status) EnumDescriptor() ([]byte, []int)
func (WebAuthenticationResult_Status) String ¶
func (x WebAuthenticationResult_Status) String() string