ProtobufClient

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 20, 2019 License: BSD-2-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthClient = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowClient   = fmt.Errorf("proto: integer overflow")
)
View Source
var APIAuthenticationMessage_Source_name = map[int32]string{
	0: "UNKNOWN",
	1: "GOLANG_SDK",
	2: "JAVASCRIPT_SDK",
	3: "NODE_SDK",
	5: "RUST_SDK",
	4: "CW_WEB",
}
View Source
var APIAuthenticationMessage_Source_value = map[string]int32{
	"UNKNOWN":        0,
	"GOLANG_SDK":     1,
	"JAVASCRIPT_SDK": 2,
	"NODE_SDK":       3,
	"RUST_SDK":       5,
	"CW_WEB":         4,
}
View Source
var WebAuthenticationResult_Status_name = map[int32]string{
	0: "UNKNOWN",
	1: "AUTHENTICATED",
	2: "INVALID_SESSION",
	3: "MFA_REQUIRED",
}
View Source
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 (*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

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) MarshalTo

func (m *ClientMessage) MarshalTo(dAtA []byte) (int, 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 (*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) GetExchange

func (*ClientSessionMessage_AnonymousTradingSession) GetExpiration

func (*ClientSessionMessage_AnonymousTradingSession) GetToken

func (*ClientSessionMessage_AnonymousTradingSession) Marshal

func (m *ClientSessionMessage_AnonymousTradingSession) Marshal() (dAtA []byte, err error)

func (*ClientSessionMessage_AnonymousTradingSession) MarshalTo

func (*ClientSessionMessage_AnonymousTradingSession) ProtoMessage

func (*ClientSessionMessage_AnonymousTradingSession) Reset

func (*ClientSessionMessage_AnonymousTradingSession) Size

func (*ClientSessionMessage_AnonymousTradingSession) String

func (*ClientSessionMessage_AnonymousTradingSession) Unmarshal

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 (*ClientSessionMessage_AnonymousTradingSession) XXX_Size

func (*ClientSessionMessage_AnonymousTradingSession) XXX_Unmarshal

type ClientSessionMessage_AnonymousTradingSession_

type ClientSessionMessage_AnonymousTradingSession_ struct {
	AnonymousTradingSession *ClientSessionMessage_AnonymousTradingSession `protobuf:"bytes,2,opt,name=anonymousTradingSession,proto3,oneof"`
}

func (*ClientSessionMessage_AnonymousTradingSession_) MarshalTo

func (*ClientSessionMessage_AnonymousTradingSession_) Size

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 (*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

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

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

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) MarshalTo

func (m *TradeSessionAuth) MarshalTo(dAtA []byte) (int, 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 (*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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL