ProtobufBroker

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: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBroker = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBroker   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthPrivate = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPrivate   = fmt.Errorf("proto: integer overflow")
)
View Source 
var FundingType_name = map[int32]string{
	0: "Spot",
	1: "Margin",
}
View Source 
var FundingType_value = map[string]int32{
	"Spot":   0,
	"Margin": 1,
}
View Source 
var PrivateOrder_PriceParamType_name = map[int32]string{
	0: "AbsoluteValue",
	1: "OffsetValue",
	2: "PrecentageOffsetValue",
}
View Source 
var PrivateOrder_PriceParamType_value = map[string]int32{
	"AbsoluteValue":         0,
	"OffsetValue":           1,
	"PrecentageOffsetValue": 2,
}
View Source 
var PrivateOrder_Type_name = map[int32]string{
	0:  "Market",
	1:  "Limit",
	2:  "StopLoss",
	3:  "StopLossLimit",
	4:  "TakeProfit",
	5:  "TakeProfitLimit",
	6:  "StopLossTakeProfit",
	7:  "StopLossTakeProfitLimit",
	8:  "TrailingStopLoss",
	9:  "TrailingStopLossLimit",
	10: "StopLossAndLimit",
	11: "FillOrKill",
	12: "SettlePosition",
}
View Source 
var PrivateOrder_Type_value = map[string]int32{
	"Market":                  0,
	"Limit":                   1,
	"StopLoss":                2,
	"StopLossLimit":           3,
	"TakeProfit":              4,
	"TakeProfitLimit":         5,
	"StopLossTakeProfit":      6,
	"StopLossTakeProfitLimit": 7,
	"TrailingStopLoss":        8,
	"TrailingStopLossLimit":   9,
	"StopLossAndLimit":        10,
	"FillOrKill":              11,
	"SettlePosition":          12,
}

Functions

This section is empty.

Types

type APIAccessorStatusUpdate 

type APIAccessorStatusUpdate struct {
	HasAccess            bool     `protobuf:"varint,1,opt,name=hasAccess,proto3" json:"hasAccess,omitempty"`
	Status               int32    `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	StatusString         string   `protobuf:"bytes,3,opt,name=statusString,proto3" json:"statusString,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*APIAccessorStatusUpdate) Descriptor 

func (*APIAccessorStatusUpdate) Descriptor() ([]byte, []int)

func (*APIAccessorStatusUpdate) GetHasAccess 

func (m *APIAccessorStatusUpdate) GetHasAccess() bool

func (*APIAccessorStatusUpdate) GetStatus 

func (m *APIAccessorStatusUpdate) GetStatus() int32

func (*APIAccessorStatusUpdate) GetStatusString 

func (m *APIAccessorStatusUpdate) GetStatusString() string

func (*APIAccessorStatusUpdate) Marshal 

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

func (*APIAccessorStatusUpdate) MarshalTo 

func (m *APIAccessorStatusUpdate) MarshalTo(dAtA []byte) (int, error)

func (*APIAccessorStatusUpdate) ProtoMessage 

func (*APIAccessorStatusUpdate) ProtoMessage()

func (*APIAccessorStatusUpdate) Reset 

func (m *APIAccessorStatusUpdate) Reset()

func (*APIAccessorStatusUpdate) Size 

func (m *APIAccessorStatusUpdate) Size() (n int)

func (*APIAccessorStatusUpdate) String 

func (m *APIAccessorStatusUpdate) String() string

func (*APIAccessorStatusUpdate) Unmarshal 

func (m *APIAccessorStatusUpdate) Unmarshal(dAtA []byte) error

func (*APIAccessorStatusUpdate) XXX_DiscardUnknown 

func (m *APIAccessorStatusUpdate) XXX_DiscardUnknown()

func (*APIAccessorStatusUpdate) XXX_Marshal 

func (m *APIAccessorStatusUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*APIAccessorStatusUpdate) XXX_Merge 

func (dst *APIAccessorStatusUpdate) XXX_Merge(src proto.Message)

func (*APIAccessorStatusUpdate) XXX_Size 

func (m *APIAccessorStatusUpdate) XXX_Size() int

func (*APIAccessorStatusUpdate) XXX_Unmarshal 

func (m *APIAccessorStatusUpdate) XXX_Unmarshal(b []byte) error

type AnonymousSessionStatusUpdate 

type AnonymousSessionStatusUpdate struct {
	Expiration           int64    `protobuf:"varint,1,opt,name=expiration,proto3" json:"expiration,omitempty"`
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AnonymousSessionStatusUpdate) Descriptor 

func (*AnonymousSessionStatusUpdate) Descriptor() ([]byte, []int)

func (*AnonymousSessionStatusUpdate) GetExpiration 

func (m *AnonymousSessionStatusUpdate) GetExpiration() int64

func (*AnonymousSessionStatusUpdate) GetToken 

func (m *AnonymousSessionStatusUpdate) GetToken() string

func (*AnonymousSessionStatusUpdate) Marshal 

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

func (*AnonymousSessionStatusUpdate) MarshalTo 

func (m *AnonymousSessionStatusUpdate) MarshalTo(dAtA []byte) (int, error)

func (*AnonymousSessionStatusUpdate) ProtoMessage 

func (*AnonymousSessionStatusUpdate) ProtoMessage()

func (*AnonymousSessionStatusUpdate) Reset 

func (m *AnonymousSessionStatusUpdate) Reset()

func (*AnonymousSessionStatusUpdate) Size 

func (m *AnonymousSessionStatusUpdate) Size() (n int)

func (*AnonymousSessionStatusUpdate) String 

func (m *AnonymousSessionStatusUpdate) String() string

func (*AnonymousSessionStatusUpdate) Unmarshal 

func (m *AnonymousSessionStatusUpdate) Unmarshal(dAtA []byte) error

func (*AnonymousSessionStatusUpdate) XXX_DiscardUnknown 

func (m *AnonymousSessionStatusUpdate) XXX_DiscardUnknown()

func (*AnonymousSessionStatusUpdate) XXX_Marshal 

func (m *AnonymousSessionStatusUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnonymousSessionStatusUpdate) XXX_Merge 

func (dst *AnonymousSessionStatusUpdate) XXX_Merge(src proto.Message)

func (*AnonymousSessionStatusUpdate) XXX_Size 

func (m *AnonymousSessionStatusUpdate) XXX_Size() int

func (*AnonymousSessionStatusUpdate) XXX_Unmarshal 

func (m *AnonymousSessionStatusUpdate) XXX_Unmarshal(b []byte) error

type Balance 

type Balance struct {
	Currency             string   `protobuf:"bytes,1,opt,name=currency,proto3" json:"currency,omitempty"`
	Amount               float32  `protobuf:"fixed32,2,opt,name=amount,proto3" json:"amount,omitempty"`
	AmountString         string   `protobuf:"bytes,3,opt,name=amountString,proto3" json:"amountString,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Balance) Descriptor 

func (*Balance) Descriptor() ([]byte, []int)

func (*Balance) GetAmount 

func (m *Balance) GetAmount() float32

func (*Balance) GetAmountString 

func (m *Balance) GetAmountString() string

func (*Balance) GetCurrency 

func (m *Balance) GetCurrency() string

func (*Balance) Marshal 

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

func (*Balance) MarshalTo 

func (m *Balance) MarshalTo(dAtA []byte) (int, error)

func (*Balance) ProtoMessage 

func (*Balance) ProtoMessage()

func (*Balance) Reset 

func (m *Balance) Reset()

func (*Balance) Size 

func (m *Balance) Size() (n int)

func (*Balance) String 

func (m *Balance) String() string

func (*Balance) Unmarshal 

func (m *Balance) Unmarshal(dAtA []byte) error

func (*Balance) XXX_DiscardUnknown 

func (m *Balance) XXX_DiscardUnknown()

func (*Balance) XXX_Marshal 

func (m *Balance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Balance) XXX_Merge 

func (dst *Balance) XXX_Merge(src proto.Message)

func (*Balance) XXX_Size 

func (m *Balance) XXX_Size() int

func (*Balance) XXX_Unmarshal 

func (m *Balance) XXX_Unmarshal(b []byte) error

type Balances 

type Balances struct {
	FundingType          FundingType `protobuf:"varint,1,opt,name=fundingType,proto3,enum=ProtobufBroker.FundingType" json:"fundingType,omitempty"`
	Balances             []*Balance  `protobuf:"bytes,2,rep,name=balances,proto3" json:"balances,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Balances) Descriptor 

func (*Balances) Descriptor() ([]byte, []int)

func (*Balances) GetBalances 

func (m *Balances) GetBalances() []*Balance

func (*Balances) GetFundingType 

func (m *Balances) GetFundingType() FundingType

func (*Balances) Marshal 

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

func (*Balances) MarshalTo 

func (m *Balances) MarshalTo(dAtA []byte) (int, error)

func (*Balances) ProtoMessage 

func (*Balances) ProtoMessage()

func (*Balances) Reset 

func (m *Balances) Reset()

func (*Balances) Size 

func (m *Balances) Size() (n int)

func (*Balances) String 

func (m *Balances) String() string

func (*Balances) Unmarshal 

func (m *Balances) Unmarshal(dAtA []byte) error

func (*Balances) XXX_DiscardUnknown 

func (m *Balances) XXX_DiscardUnknown()

func (*Balances) XXX_Marshal 

func (m *Balances) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Balances) XXX_Merge 

func (dst *Balances) XXX_Merge(src proto.Message)

func (*Balances) XXX_Size 

func (m *Balances) XXX_Size() int

func (*Balances) XXX_Unmarshal 

func (m *Balances) XXX_Unmarshal(b []byte) error

type BalancesUpdate 

type BalancesUpdate struct {
	// This field represents available balances, this was the
	// default until we introduced the ability to split between
	// total and available balances.
	Balances []*Balances `protobuf:"bytes,1,rep,name=balances,proto3" json:"balances,omitempty"`
	// This field contains total balances only.
	Total                []*Balances `protobuf:"bytes,2,rep,name=total,proto3" json:"total,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*BalancesUpdate) Descriptor 

func (*BalancesUpdate) Descriptor() ([]byte, []int)

func (*BalancesUpdate) GetBalances 

func (m *BalancesUpdate) GetBalances() []*Balances

func (*BalancesUpdate) GetTotal 

func (m *BalancesUpdate) GetTotal() []*Balances

func (*BalancesUpdate) Marshal 

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

func (*BalancesUpdate) MarshalTo 

func (m *BalancesUpdate) MarshalTo(dAtA []byte) (int, error)

func (*BalancesUpdate) ProtoMessage 

func (*BalancesUpdate) ProtoMessage()

func (*BalancesUpdate) Reset 

func (m *BalancesUpdate) Reset()

func (*BalancesUpdate) Size 

func (m *BalancesUpdate) Size() (n int)

func (*BalancesUpdate) String 

func (m *BalancesUpdate) String() string

func (*BalancesUpdate) Unmarshal 

func (m *BalancesUpdate) Unmarshal(dAtA []byte) error

func (*BalancesUpdate) XXX_DiscardUnknown 

func (m *BalancesUpdate) XXX_DiscardUnknown()

func (*BalancesUpdate) XXX_Marshal 

func (m *BalancesUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BalancesUpdate) XXX_Merge 

func (dst *BalancesUpdate) XXX_Merge(src proto.Message)

func (*BalancesUpdate) XXX_Size 

func (m *BalancesUpdate) XXX_Size() int

func (*BalancesUpdate) XXX_Unmarshal 

func (m *BalancesUpdate) XXX_Unmarshal(b []byte) error

type BrokerRequest 

type BrokerRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// marketId can be 0 if there is just one session associated with the
	// connection.
	MarketId int64 `protobuf:"varint,7,opt,name=marketId,proto3" json:"marketId,omitempty"`
	// Types that are valid to be assigned to Request:
	//	*BrokerRequest_PlaceOrderRequest
	//	*BrokerRequest_CancelOrderRequest
	//	*BrokerRequest_ReplaceOrderRequest
	//	*BrokerRequest_SyncRequest
	//	*BrokerRequest_ClosePositionRequest
	Request              isBrokerRequest_Request `protobuf_oneof:"Request"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*BrokerRequest) Descriptor 

func (*BrokerRequest) Descriptor() ([]byte, []int)

func (*BrokerRequest) GetCancelOrderRequest 

func (m *BrokerRequest) GetCancelOrderRequest() *CancelOrderRequest

func (*BrokerRequest) GetClosePositionRequest 

func (m *BrokerRequest) GetClosePositionRequest() *ClosePositionRequest

func (*BrokerRequest) GetId 

func (m *BrokerRequest) GetId() string

func (*BrokerRequest) GetMarketId 

func (m *BrokerRequest) GetMarketId() int64

func (*BrokerRequest) GetPlaceOrderRequest 

func (m *BrokerRequest) GetPlaceOrderRequest() *PlaceOrderRequest

func (*BrokerRequest) GetReplaceOrderRequest 

func (m *BrokerRequest) GetReplaceOrderRequest() *ReplaceOrderRequest

func (*BrokerRequest) GetRequest 

func (m *BrokerRequest) GetRequest() isBrokerRequest_Request

func (*BrokerRequest) GetSyncRequest 

func (m *BrokerRequest) GetSyncRequest() *SyncRequest

func (*BrokerRequest) Marshal 

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

func (*BrokerRequest) MarshalTo 

func (m *BrokerRequest) MarshalTo(dAtA []byte) (int, error)

func (*BrokerRequest) ProtoMessage 

func (*BrokerRequest) ProtoMessage()

func (*BrokerRequest) Reset 

func (m *BrokerRequest) Reset()

func (*BrokerRequest) Size 

func (m *BrokerRequest) Size() (n int)

func (*BrokerRequest) String 

func (m *BrokerRequest) String() string

func (*BrokerRequest) Unmarshal 

func (m *BrokerRequest) Unmarshal(dAtA []byte) error

func (*BrokerRequest) XXX_DiscardUnknown 

func (m *BrokerRequest) XXX_DiscardUnknown()

func (*BrokerRequest) XXX_Marshal 

func (m *BrokerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BrokerRequest) XXX_Merge 

func (dst *BrokerRequest) XXX_Merge(src proto.Message)

func (*BrokerRequest) XXX_OneofFuncs 

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

func (m *BrokerRequest) XXX_Size() int

func (*BrokerRequest) XXX_Unmarshal 

func (m *BrokerRequest) XXX_Unmarshal(b []byte) error

type BrokerRequest_CancelOrderRequest 

type BrokerRequest_CancelOrderRequest struct {
	CancelOrderRequest *CancelOrderRequest `protobuf:"bytes,3,opt,name=cancelOrderRequest,proto3,oneof"`
}

func (*BrokerRequest_CancelOrderRequest) MarshalTo 

func (m *BrokerRequest_CancelOrderRequest) MarshalTo(dAtA []byte) (int, error)

func (*BrokerRequest_CancelOrderRequest) Size 

func (m *BrokerRequest_CancelOrderRequest) Size() (n int)

type BrokerRequest_ClosePositionRequest 

type BrokerRequest_ClosePositionRequest struct {
	ClosePositionRequest *ClosePositionRequest `protobuf:"bytes,5,opt,name=closePositionRequest,proto3,oneof"`
}

func (*BrokerRequest_ClosePositionRequest) MarshalTo 

func (m *BrokerRequest_ClosePositionRequest) MarshalTo(dAtA []byte) (int, error)

func (*BrokerRequest_ClosePositionRequest) Size 

func (m *BrokerRequest_ClosePositionRequest) Size() (n int)

type BrokerRequest_PlaceOrderRequest 

type BrokerRequest_PlaceOrderRequest struct {
	PlaceOrderRequest *PlaceOrderRequest `protobuf:"bytes,2,opt,name=placeOrderRequest,proto3,oneof"`
}

func (*BrokerRequest_PlaceOrderRequest) MarshalTo 

func (m *BrokerRequest_PlaceOrderRequest) MarshalTo(dAtA []byte) (int, error)

func (*BrokerRequest_PlaceOrderRequest) Size 

func (m *BrokerRequest_PlaceOrderRequest) Size() (n int)

type BrokerRequest_ReplaceOrderRequest 

type BrokerRequest_ReplaceOrderRequest struct {
	ReplaceOrderRequest *ReplaceOrderRequest `protobuf:"bytes,6,opt,name=replaceOrderRequest,proto3,oneof"`
}

func (*BrokerRequest_ReplaceOrderRequest) MarshalTo 

func (m *BrokerRequest_ReplaceOrderRequest) MarshalTo(dAtA []byte) (int, error)

func (*BrokerRequest_ReplaceOrderRequest) Size 

func (m *BrokerRequest_ReplaceOrderRequest) Size() (n int)

type BrokerRequest_SyncRequest 

type BrokerRequest_SyncRequest struct {
	SyncRequest *SyncRequest `protobuf:"bytes,4,opt,name=syncRequest,proto3,oneof"`
}

func (*BrokerRequest_SyncRequest) MarshalTo 

func (m *BrokerRequest_SyncRequest) MarshalTo(dAtA []byte) (int, error)

func (*BrokerRequest_SyncRequest) Size 

func (m *BrokerRequest_SyncRequest) Size() (n int)

type BrokerSessionMessage 

type BrokerSessionMessage struct {
	// Types that are valid to be assigned to SessionConfig:
	//	*BrokerSessionMessage_Session_
	//	*BrokerSessionMessage_AnonymousTradingSession_
	SessionConfig        isBrokerSessionMessage_SessionConfig `protobuf_oneof:"SessionConfig"`
	MarketId             int64                                `protobuf:"varint,3,opt,name=marketId,proto3" json:"marketId,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

DEPRECATION WARNING this isn't used anymore in favor of ProtobufClient.ClientSessionMessage

func (*BrokerSessionMessage) Descriptor 

func (*BrokerSessionMessage) Descriptor() ([]byte, []int)

func (*BrokerSessionMessage) GetAnonymousTradingSession 

func (m *BrokerSessionMessage) GetAnonymousTradingSession() *BrokerSessionMessage_AnonymousTradingSession

func (*BrokerSessionMessage) GetMarketId 

func (m *BrokerSessionMessage) GetMarketId() int64

func (*BrokerSessionMessage) GetSession 

func (m *BrokerSessionMessage) GetSession() *BrokerSessionMessage_Session

func (*BrokerSessionMessage) GetSessionConfig 

func (m *BrokerSessionMessage) GetSessionConfig() isBrokerSessionMessage_SessionConfig

func (*BrokerSessionMessage) Marshal 

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

func (*BrokerSessionMessage) MarshalTo 

func (m *BrokerSessionMessage) MarshalTo(dAtA []byte) (int, error)

func (*BrokerSessionMessage) ProtoMessage 

func (*BrokerSessionMessage) ProtoMessage()

func (*BrokerSessionMessage) Reset 

func (m *BrokerSessionMessage) Reset()

func (*BrokerSessionMessage) Size 

func (m *BrokerSessionMessage) Size() (n int)

func (*BrokerSessionMessage) String 

func (m *BrokerSessionMessage) String() string

func (*BrokerSessionMessage) Unmarshal 

func (m *BrokerSessionMessage) Unmarshal(dAtA []byte) error

func (*BrokerSessionMessage) XXX_DiscardUnknown 

func (m *BrokerSessionMessage) XXX_DiscardUnknown()

func (*BrokerSessionMessage) XXX_Marshal 

func (m *BrokerSessionMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BrokerSessionMessage) XXX_Merge 

func (dst *BrokerSessionMessage) XXX_Merge(src proto.Message)

func (*BrokerSessionMessage) XXX_OneofFuncs 

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

func (m *BrokerSessionMessage) XXX_Size() int

func (*BrokerSessionMessage) XXX_Unmarshal 

func (m *BrokerSessionMessage) XXX_Unmarshal(b []byte) error

type BrokerSessionMessage_AnonymousTradingSession 

type BrokerSessionMessage_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 (*BrokerSessionMessage_AnonymousTradingSession) Descriptor 

func (*BrokerSessionMessage_AnonymousTradingSession) Descriptor() ([]byte, []int)

func (*BrokerSessionMessage_AnonymousTradingSession) GetExchange 

func (m *BrokerSessionMessage_AnonymousTradingSession) GetExchange() string

func (*BrokerSessionMessage_AnonymousTradingSession) GetExpiration 

func (m *BrokerSessionMessage_AnonymousTradingSession) GetExpiration() int64

func (*BrokerSessionMessage_AnonymousTradingSession) GetToken 

func (m *BrokerSessionMessage_AnonymousTradingSession) GetToken() string

func (*BrokerSessionMessage_AnonymousTradingSession) Marshal 

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

func (*BrokerSessionMessage_AnonymousTradingSession) MarshalTo 

func (m *BrokerSessionMessage_AnonymousTradingSession) MarshalTo(dAtA []byte) (int, error)

func (*BrokerSessionMessage_AnonymousTradingSession) ProtoMessage 

func (*BrokerSessionMessage_AnonymousTradingSession) ProtoMessage()

func (*BrokerSessionMessage_AnonymousTradingSession) Reset 

func (m *BrokerSessionMessage_AnonymousTradingSession) Reset()

func (*BrokerSessionMessage_AnonymousTradingSession) Size 

func (m *BrokerSessionMessage_AnonymousTradingSession) Size() (n int)

func (*BrokerSessionMessage_AnonymousTradingSession) String 

func (m *BrokerSessionMessage_AnonymousTradingSession) String() string

func (*BrokerSessionMessage_AnonymousTradingSession) Unmarshal 

func (m *BrokerSessionMessage_AnonymousTradingSession) Unmarshal(dAtA []byte) error

func (*BrokerSessionMessage_AnonymousTradingSession) XXX_DiscardUnknown 

func (m *BrokerSessionMessage_AnonymousTradingSession) XXX_DiscardUnknown()

func (*BrokerSessionMessage_AnonymousTradingSession) XXX_Marshal 

func (m *BrokerSessionMessage_AnonymousTradingSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BrokerSessionMessage_AnonymousTradingSession) XXX_Merge 

func (dst *BrokerSessionMessage_AnonymousTradingSession) XXX_Merge(src proto.Message)

func (*BrokerSessionMessage_AnonymousTradingSession) XXX_Size 

func (m *BrokerSessionMessage_AnonymousTradingSession) XXX_Size() int

func (*BrokerSessionMessage_AnonymousTradingSession) XXX_Unmarshal 

func (m *BrokerSessionMessage_AnonymousTradingSession) XXX_Unmarshal(b []byte) error

type BrokerSessionMessage_AnonymousTradingSession_ 

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

func (*BrokerSessionMessage_AnonymousTradingSession_) MarshalTo 

func (m *BrokerSessionMessage_AnonymousTradingSession_) MarshalTo(dAtA []byte) (int, error)

func (*BrokerSessionMessage_AnonymousTradingSession_) Size 

func (m *BrokerSessionMessage_AnonymousTradingSession_) Size() (n int)

type BrokerSessionMessage_Session 

type BrokerSessionMessage_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 (*BrokerSessionMessage_Session) Descriptor 

func (*BrokerSessionMessage_Session) Descriptor() ([]byte, []int)

func (*BrokerSessionMessage_Session) GetExpires 

func (m *BrokerSessionMessage_Session) GetExpires() int64

func (*BrokerSessionMessage_Session) GetMfaToken 

func (m *BrokerSessionMessage_Session) GetMfaToken() string

func (*BrokerSessionMessage_Session) GetToken 

func (m *BrokerSessionMessage_Session) GetToken() string

func (*BrokerSessionMessage_Session) GetUserId 

func (m *BrokerSessionMessage_Session) GetUserId() string

func (*BrokerSessionMessage_Session) Marshal 

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

func (*BrokerSessionMessage_Session) MarshalTo 

func (m *BrokerSessionMessage_Session) MarshalTo(dAtA []byte) (int, error)

func (*BrokerSessionMessage_Session) ProtoMessage 

func (*BrokerSessionMessage_Session) ProtoMessage()

func (*BrokerSessionMessage_Session) Reset 

func (m *BrokerSessionMessage_Session) Reset()

func (*BrokerSessionMessage_Session) Size 

func (m *BrokerSessionMessage_Session) Size() (n int)

func (*BrokerSessionMessage_Session) String 

func (m *BrokerSessionMessage_Session) String() string

func (*BrokerSessionMessage_Session) Unmarshal 

func (m *BrokerSessionMessage_Session) Unmarshal(dAtA []byte) error

func (*BrokerSessionMessage_Session) XXX_DiscardUnknown 

func (m *BrokerSessionMessage_Session) XXX_DiscardUnknown()

func (*BrokerSessionMessage_Session) XXX_Marshal 

func (m *BrokerSessionMessage_Session) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BrokerSessionMessage_Session) XXX_Merge 

func (dst *BrokerSessionMessage_Session) XXX_Merge(src proto.Message)

func (*BrokerSessionMessage_Session) XXX_Size 

func (m *BrokerSessionMessage_Session) XXX_Size() int

func (*BrokerSessionMessage_Session) XXX_Unmarshal 

func (m *BrokerSessionMessage_Session) XXX_Unmarshal(b []byte) error

type BrokerSessionMessage_Session_ 

type BrokerSessionMessage_Session_ struct {
	Session *BrokerSessionMessage_Session `protobuf:"bytes,1,opt,name=session,proto3,oneof"`
}

func (*BrokerSessionMessage_Session_) MarshalTo 

func (m *BrokerSessionMessage_Session_) MarshalTo(dAtA []byte) (int, error)

func (*BrokerSessionMessage_Session_) Size 

func (m *BrokerSessionMessage_Session_) Size() (n int)

type BrokerUpdateMessage 

type BrokerUpdateMessage struct {
	MarketId int64 `protobuf:"varint,11,opt,name=marketId,proto3" json:"marketId,omitempty"`
	// Types that are valid to be assigned to Update:
	//	*BrokerUpdateMessage_OrdersUpdate
	//	*BrokerUpdateMessage_TradesUpdate
	//	*BrokerUpdateMessage_BalancesUpdate
	//	*BrokerUpdateMessage_PositionsUpdate
	//	*BrokerUpdateMessage_RequestResolutionUpdate
	//	*BrokerUpdateMessage_AnonymousSessionStatusUpdate
	//	*BrokerUpdateMessage_PermissionsUpdate
	//	*BrokerUpdateMessage_SessionStatusUpdate
	//	*BrokerUpdateMessage_ApiAccessorStatusUpdate
	//	*BrokerUpdateMessage_AuthenticationResult
	//	*BrokerUpdateMessage_SubscriptionResult
	//	*BrokerUpdateMessage_WebAuthenticationResult
	Update               isBrokerUpdateMessage_Update `protobuf_oneof:"Update"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*BrokerUpdateMessage) Descriptor 

func (*BrokerUpdateMessage) Descriptor() ([]byte, []int)

func (*BrokerUpdateMessage) GetAnonymousSessionStatusUpdate 

func (m *BrokerUpdateMessage) GetAnonymousSessionStatusUpdate() *AnonymousSessionStatusUpdate

func (*BrokerUpdateMessage) GetApiAccessorStatusUpdate 

func (m *BrokerUpdateMessage) GetApiAccessorStatusUpdate() *APIAccessorStatusUpdate

func (*BrokerUpdateMessage) GetAuthenticationResult 

func (m *BrokerUpdateMessage) GetAuthenticationResult() *stream.AuthenticationResult

func (*BrokerUpdateMessage) GetBalancesUpdate 

func (m *BrokerUpdateMessage) GetBalancesUpdate() *BalancesUpdate

func (*BrokerUpdateMessage) GetMarketId 

func (m *BrokerUpdateMessage) GetMarketId() int64

func (*BrokerUpdateMessage) GetOrdersUpdate 

func (m *BrokerUpdateMessage) GetOrdersUpdate() *OrdersUpdate

func (*BrokerUpdateMessage) GetPermissionsUpdate 

func (m *BrokerUpdateMessage) GetPermissionsUpdate() *PermissionsUpdate

func (*BrokerUpdateMessage) GetPositionsUpdate 

func (m *BrokerUpdateMessage) GetPositionsUpdate() *PositionsUpdate

func (*BrokerUpdateMessage) GetRequestResolutionUpdate 

func (m *BrokerUpdateMessage) GetRequestResolutionUpdate() *RequestResolutionUpdate

func (*BrokerUpdateMessage) GetSessionStatusUpdate 

func (m *BrokerUpdateMessage) GetSessionStatusUpdate() *SessionStatusUpdate

func (*BrokerUpdateMessage) GetSubscriptionResult 

func (m *BrokerUpdateMessage) GetSubscriptionResult() *stream.SubscriptionResult

func (*BrokerUpdateMessage) GetTradesUpdate 

func (m *BrokerUpdateMessage) GetTradesUpdate() *TradesUpdate

func (*BrokerUpdateMessage) GetUpdate 

func (m *BrokerUpdateMessage) GetUpdate() isBrokerUpdateMessage_Update

func (*BrokerUpdateMessage) GetWebAuthenticationResult 

func (m *BrokerUpdateMessage) GetWebAuthenticationResult() *client.WebAuthenticationResult

func (*BrokerUpdateMessage) Marshal 

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

func (*BrokerUpdateMessage) MarshalTo 

func (m *BrokerUpdateMessage) MarshalTo(dAtA []byte) (int, error)

func (*BrokerUpdateMessage) ProtoMessage 

func (*BrokerUpdateMessage) ProtoMessage()

func (*BrokerUpdateMessage) Reset 

func (m *BrokerUpdateMessage) Reset()

func (*BrokerUpdateMessage) Size 

func (m *BrokerUpdateMessage) Size() (n int)

func (*BrokerUpdateMessage) String 

func (m *BrokerUpdateMessage) String() string

func (*BrokerUpdateMessage) Unmarshal 

func (m *BrokerUpdateMessage) Unmarshal(dAtA []byte) error

func (*BrokerUpdateMessage) XXX_DiscardUnknown 

func (m *BrokerUpdateMessage) XXX_DiscardUnknown()

func (*BrokerUpdateMessage) XXX_Marshal 

func (m *BrokerUpdateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BrokerUpdateMessage) XXX_Merge 

func (dst *BrokerUpdateMessage) XXX_Merge(src proto.Message)

func (*BrokerUpdateMessage) XXX_OneofFuncs 

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

func (m *BrokerUpdateMessage) XXX_Size() int

func (*BrokerUpdateMessage) XXX_Unmarshal 

func (m *BrokerUpdateMessage) XXX_Unmarshal(b []byte) error

type BrokerUpdateMessage_AnonymousSessionStatusUpdate 

type BrokerUpdateMessage_AnonymousSessionStatusUpdate struct {
	AnonymousSessionStatusUpdate *AnonymousSessionStatusUpdate `protobuf:"bytes,5,opt,name=anonymousSessionStatusUpdate,proto3,oneof"`
}

func (*BrokerUpdateMessage_AnonymousSessionStatusUpdate) MarshalTo 

func (m *BrokerUpdateMessage_AnonymousSessionStatusUpdate) MarshalTo(dAtA []byte) (int, error)

func (*BrokerUpdateMessage_AnonymousSessionStatusUpdate) Size 

func (m *BrokerUpdateMessage_AnonymousSessionStatusUpdate) Size() (n int)

type BrokerUpdateMessage_ApiAccessorStatusUpdate 

type BrokerUpdateMessage_ApiAccessorStatusUpdate struct {
	ApiAccessorStatusUpdate *APIAccessorStatusUpdate `protobuf:"bytes,9,opt,name=apiAccessorStatusUpdate,proto3,oneof"`
}

func (*BrokerUpdateMessage_ApiAccessorStatusUpdate) MarshalTo 

func (m *BrokerUpdateMessage_ApiAccessorStatusUpdate) MarshalTo(dAtA []byte) (int, error)

func (*BrokerUpdateMessage_ApiAccessorStatusUpdate) Size 

func (m *BrokerUpdateMessage_ApiAccessorStatusUpdate) Size() (n int)

type BrokerUpdateMessage_AuthenticationResult 

type BrokerUpdateMessage_AuthenticationResult struct {
	AuthenticationResult *stream.AuthenticationResult `protobuf:"bytes,10,opt,name=authenticationResult,proto3,oneof"`
}

func (*BrokerUpdateMessage_AuthenticationResult) MarshalTo 

func (m *BrokerUpdateMessage_AuthenticationResult) MarshalTo(dAtA []byte) (int, error)

func (*BrokerUpdateMessage_AuthenticationResult) Size 

func (m *BrokerUpdateMessage_AuthenticationResult) Size() (n int)

type BrokerUpdateMessage_BalancesUpdate 

type BrokerUpdateMessage_BalancesUpdate struct {
	BalancesUpdate *BalancesUpdate `protobuf:"bytes,3,opt,name=balancesUpdate,proto3,oneof"`
}

func (*BrokerUpdateMessage_BalancesUpdate) MarshalTo 

func (m *BrokerUpdateMessage_BalancesUpdate) MarshalTo(dAtA []byte) (int, error)

func (*BrokerUpdateMessage_BalancesUpdate) Size 

func (m *BrokerUpdateMessage_BalancesUpdate) Size() (n int)

type BrokerUpdateMessage_OrdersUpdate 

type BrokerUpdateMessage_OrdersUpdate struct {
	OrdersUpdate *OrdersUpdate `protobuf:"bytes,1,opt,name=ordersUpdate,proto3,oneof"`
}

func (*BrokerUpdateMessage_OrdersUpdate) MarshalTo 

func (m *BrokerUpdateMessage_OrdersUpdate) MarshalTo(dAtA []byte) (int, error)

func (*BrokerUpdateMessage_OrdersUpdate) Size 

func (m *BrokerUpdateMessage_OrdersUpdate) Size() (n int)

type BrokerUpdateMessage_PermissionsUpdate 

type BrokerUpdateMessage_PermissionsUpdate struct {
	PermissionsUpdate *PermissionsUpdate `protobuf:"bytes,6,opt,name=permissionsUpdate,proto3,oneof"`
}

func (*BrokerUpdateMessage_PermissionsUpdate) MarshalTo 

func (m *BrokerUpdateMessage_PermissionsUpdate) MarshalTo(dAtA []byte) (int, error)

func (*BrokerUpdateMessage_PermissionsUpdate) Size 

func (m *BrokerUpdateMessage_PermissionsUpdate) Size() (n int)

type BrokerUpdateMessage_PositionsUpdate 

type BrokerUpdateMessage_PositionsUpdate struct {
	PositionsUpdate *PositionsUpdate `protobuf:"bytes,8,opt,name=positionsUpdate,proto3,oneof"`
}

func (*BrokerUpdateMessage_PositionsUpdate) MarshalTo 

func (m *BrokerUpdateMessage_PositionsUpdate) MarshalTo(dAtA []byte) (int, error)

func (*BrokerUpdateMessage_PositionsUpdate) Size 

func (m *BrokerUpdateMessage_PositionsUpdate) Size() (n int)

type BrokerUpdateMessage_RequestResolutionUpdate 

type BrokerUpdateMessage_RequestResolutionUpdate struct {
	RequestResolutionUpdate *RequestResolutionUpdate `protobuf:"bytes,4,opt,name=requestResolutionUpdate,proto3,oneof"`
}

func (*BrokerUpdateMessage_RequestResolutionUpdate) MarshalTo 

func (m *BrokerUpdateMessage_RequestResolutionUpdate) MarshalTo(dAtA []byte) (int, error)

func (*BrokerUpdateMessage_RequestResolutionUpdate) Size 

func (m *BrokerUpdateMessage_RequestResolutionUpdate) Size() (n int)

type BrokerUpdateMessage_SessionStatusUpdate 

type BrokerUpdateMessage_SessionStatusUpdate struct {
	SessionStatusUpdate *SessionStatusUpdate `protobuf:"bytes,7,opt,name=sessionStatusUpdate,proto3,oneof"`
}

func (*BrokerUpdateMessage_SessionStatusUpdate) MarshalTo 

func (m *BrokerUpdateMessage_SessionStatusUpdate) MarshalTo(dAtA []byte) (int, error)

func (*BrokerUpdateMessage_SessionStatusUpdate) Size 

func (m *BrokerUpdateMessage_SessionStatusUpdate) Size() (n int)

type BrokerUpdateMessage_SubscriptionResult 

type BrokerUpdateMessage_SubscriptionResult struct {
	SubscriptionResult *stream.SubscriptionResult `protobuf:"bytes,12,opt,name=subscriptionResult,proto3,oneof"`
}

func (*BrokerUpdateMessage_SubscriptionResult) MarshalTo 

func (m *BrokerUpdateMessage_SubscriptionResult) MarshalTo(dAtA []byte) (int, error)

func (*BrokerUpdateMessage_SubscriptionResult) Size 

func (m *BrokerUpdateMessage_SubscriptionResult) Size() (n int)

type BrokerUpdateMessage_TradesUpdate 

type BrokerUpdateMessage_TradesUpdate struct {
	TradesUpdate *TradesUpdate `protobuf:"bytes,2,opt,name=tradesUpdate,proto3,oneof"`
}

func (*BrokerUpdateMessage_TradesUpdate) MarshalTo 

func (m *BrokerUpdateMessage_TradesUpdate) MarshalTo(dAtA []byte) (int, error)

func (*BrokerUpdateMessage_TradesUpdate) Size 

func (m *BrokerUpdateMessage_TradesUpdate) Size() (n int)

type BrokerUpdateMessage_WebAuthenticationResult 

type BrokerUpdateMessage_WebAuthenticationResult struct {
	WebAuthenticationResult *client.WebAuthenticationResult `protobuf:"bytes,14,opt,name=webAuthenticationResult,proto3,oneof"`
}

func (*BrokerUpdateMessage_WebAuthenticationResult) MarshalTo 

func (m *BrokerUpdateMessage_WebAuthenticationResult) MarshalTo(dAtA []byte) (int, error)

func (*BrokerUpdateMessage_WebAuthenticationResult) Size 

func (m *BrokerUpdateMessage_WebAuthenticationResult) Size() (n int)

type CancelOrderRequest 

type CancelOrderRequest struct {
	OrderId              string   `protobuf:"bytes,2,opt,name=orderId,proto3" json:"orderId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CancelOrderRequest) Descriptor 

func (*CancelOrderRequest) Descriptor() ([]byte, []int)

func (*CancelOrderRequest) GetOrderId 

func (m *CancelOrderRequest) GetOrderId() string

func (*CancelOrderRequest) Marshal 

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

func (*CancelOrderRequest) MarshalTo 

func (m *CancelOrderRequest) MarshalTo(dAtA []byte) (int, error)

func (*CancelOrderRequest) ProtoMessage 

func (*CancelOrderRequest) ProtoMessage()

func (*CancelOrderRequest) Reset 

func (m *CancelOrderRequest) Reset()

func (*CancelOrderRequest) Size 

func (m *CancelOrderRequest) Size() (n int)

func (*CancelOrderRequest) String 

func (m *CancelOrderRequest) String() string

func (*CancelOrderRequest) Unmarshal 

func (m *CancelOrderRequest) Unmarshal(dAtA []byte) error

func (*CancelOrderRequest) XXX_DiscardUnknown 

func (m *CancelOrderRequest) XXX_DiscardUnknown()

func (*CancelOrderRequest) XXX_Marshal 

func (m *CancelOrderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelOrderRequest) XXX_Merge 

func (dst *CancelOrderRequest) XXX_Merge(src proto.Message)

func (*CancelOrderRequest) XXX_Size 

func (m *CancelOrderRequest) XXX_Size() int

func (*CancelOrderRequest) XXX_Unmarshal 

func (m *CancelOrderRequest) XXX_Unmarshal(b []byte) error

type CancelOrderResult 

type CancelOrderResult struct {
	OrderId              string   `protobuf:"bytes,1,opt,name=orderId,proto3" json:"orderId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CancelOrderResult) Descriptor 

func (*CancelOrderResult) Descriptor() ([]byte, []int)

func (*CancelOrderResult) GetOrderId 

func (m *CancelOrderResult) GetOrderId() string

func (*CancelOrderResult) Marshal 

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

func (*CancelOrderResult) MarshalTo 

func (m *CancelOrderResult) MarshalTo(dAtA []byte) (int, error)

func (*CancelOrderResult) ProtoMessage 

func (*CancelOrderResult) ProtoMessage()

func (*CancelOrderResult) Reset 

func (m *CancelOrderResult) Reset()

func (*CancelOrderResult) Size 

func (m *CancelOrderResult) Size() (n int)

func (*CancelOrderResult) String 

func (m *CancelOrderResult) String() string

func (*CancelOrderResult) Unmarshal 

func (m *CancelOrderResult) Unmarshal(dAtA []byte) error

func (*CancelOrderResult) XXX_DiscardUnknown 

func (m *CancelOrderResult) XXX_DiscardUnknown()

func (*CancelOrderResult) XXX_Marshal 

func (m *CancelOrderResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelOrderResult) XXX_Merge 

func (dst *CancelOrderResult) XXX_Merge(src proto.Message)

func (*CancelOrderResult) XXX_Size 

func (m *CancelOrderResult) XXX_Size() int

func (*CancelOrderResult) XXX_Unmarshal 

func (m *CancelOrderResult) XXX_Unmarshal(b []byte) error

type ClosePositionRequest 

type ClosePositionRequest struct {
	PositionId           string   `protobuf:"bytes,2,opt,name=positionId,proto3" json:"positionId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClosePositionRequest) Descriptor 

func (*ClosePositionRequest) Descriptor() ([]byte, []int)

func (*ClosePositionRequest) GetPositionId 

func (m *ClosePositionRequest) GetPositionId() string

func (*ClosePositionRequest) Marshal 

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

func (*ClosePositionRequest) MarshalTo 

func (m *ClosePositionRequest) MarshalTo(dAtA []byte) (int, error)

func (*ClosePositionRequest) ProtoMessage 

func (*ClosePositionRequest) ProtoMessage()

func (*ClosePositionRequest) Reset 

func (m *ClosePositionRequest) Reset()

func (*ClosePositionRequest) Size 

func (m *ClosePositionRequest) Size() (n int)

func (*ClosePositionRequest) String 

func (m *ClosePositionRequest) String() string

func (*ClosePositionRequest) Unmarshal 

func (m *ClosePositionRequest) Unmarshal(dAtA []byte) error

func (*ClosePositionRequest) XXX_DiscardUnknown 

func (m *ClosePositionRequest) XXX_DiscardUnknown()

func (*ClosePositionRequest) XXX_Marshal 

func (m *ClosePositionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClosePositionRequest) XXX_Merge 

func (dst *ClosePositionRequest) XXX_Merge(src proto.Message)

func (*ClosePositionRequest) XXX_Size 

func (m *ClosePositionRequest) XXX_Size() int

func (*ClosePositionRequest) XXX_Unmarshal 

func (m *ClosePositionRequest) XXX_Unmarshal(b []byte) error

type FundingType 

type FundingType int32
const (
	FundingType_Spot   FundingType = 0
	FundingType_Margin FundingType = 1
)

func (FundingType) EnumDescriptor 

func (FundingType) EnumDescriptor() ([]byte, []int)

func (FundingType) String 

func (x FundingType) String() string

type OrdersUpdate 

type OrdersUpdate struct {
	Orders               []*PrivateOrder `protobuf:"bytes,1,rep,name=orders,proto3" json:"orders,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*OrdersUpdate) Descriptor 

func (*OrdersUpdate) Descriptor() ([]byte, []int)

func (*OrdersUpdate) GetOrders 

func (m *OrdersUpdate) GetOrders() []*PrivateOrder

func (*OrdersUpdate) Marshal 

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

func (*OrdersUpdate) MarshalTo 

func (m *OrdersUpdate) MarshalTo(dAtA []byte) (int, error)

func (*OrdersUpdate) ProtoMessage 

func (*OrdersUpdate) ProtoMessage()

func (*OrdersUpdate) Reset 

func (m *OrdersUpdate) Reset()

func (*OrdersUpdate) Size 

func (m *OrdersUpdate) Size() (n int)

func (*OrdersUpdate) String 

func (m *OrdersUpdate) String() string

func (*OrdersUpdate) Unmarshal 

func (m *OrdersUpdate) Unmarshal(dAtA []byte) error

func (*OrdersUpdate) XXX_DiscardUnknown 

func (m *OrdersUpdate) XXX_DiscardUnknown()

func (*OrdersUpdate) XXX_Marshal 

func (m *OrdersUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OrdersUpdate) XXX_Merge 

func (dst *OrdersUpdate) XXX_Merge(src proto.Message)

func (*OrdersUpdate) XXX_Size 

func (m *OrdersUpdate) XXX_Size() int

func (*OrdersUpdate) XXX_Unmarshal 

func (m *OrdersUpdate) XXX_Unmarshal(b []byte) error

type PermissionsUpdate 

type PermissionsUpdate struct {
	OrderTypes           []PrivateOrder_Type               `protobuf:"varint,1,rep,name=orderTypes,proto3,enum=ProtobufBroker.PrivateOrder_Type" json:"orderTypes,omitempty"`
	FundingTypes         []FundingType                     `protobuf:"varint,2,rep,name=fundingTypes,proto3,enum=ProtobufBroker.FundingType" json:"fundingTypes,omitempty"`
	Agreements           []*PermissionsUpdate_Agreement    `protobuf:"bytes,4,rep,name=agreements,proto3" json:"agreements,omitempty"`
	LeverageLevels       *PermissionsUpdate_LeverageLevels `protobuf:"bytes,6,opt,name=leverageLevels,proto3" json:"leverageLevels,omitempty"`
	SupportsOrderExpiry  bool                              `protobuf:"varint,7,opt,name=supportsOrderExpiry,proto3" json:"supportsOrderExpiry,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*PermissionsUpdate) Descriptor 

func (*PermissionsUpdate) Descriptor() ([]byte, []int)

func (*PermissionsUpdate) GetAgreements 

func (m *PermissionsUpdate) GetAgreements() []*PermissionsUpdate_Agreement

func (*PermissionsUpdate) GetFundingTypes 

func (m *PermissionsUpdate) GetFundingTypes() []FundingType

func (*PermissionsUpdate) GetLeverageLevels 

func (m *PermissionsUpdate) GetLeverageLevels() *PermissionsUpdate_LeverageLevels

func (*PermissionsUpdate) GetOrderTypes 

func (m *PermissionsUpdate) GetOrderTypes() []PrivateOrder_Type

func (*PermissionsUpdate) GetSupportsOrderExpiry 

func (m *PermissionsUpdate) GetSupportsOrderExpiry() bool

func (*PermissionsUpdate) Marshal 

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

func (*PermissionsUpdate) MarshalTo 

func (m *PermissionsUpdate) MarshalTo(dAtA []byte) (int, error)

func (*PermissionsUpdate) ProtoMessage 

func (*PermissionsUpdate) ProtoMessage()

func (*PermissionsUpdate) Reset 

func (m *PermissionsUpdate) Reset()

func (*PermissionsUpdate) Size 

func (m *PermissionsUpdate) Size() (n int)

func (*PermissionsUpdate) String 

func (m *PermissionsUpdate) String() string

func (*PermissionsUpdate) Unmarshal 

func (m *PermissionsUpdate) Unmarshal(dAtA []byte) error

func (*PermissionsUpdate) XXX_DiscardUnknown 

func (m *PermissionsUpdate) XXX_DiscardUnknown()

func (*PermissionsUpdate) XXX_Marshal 

func (m *PermissionsUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PermissionsUpdate) XXX_Merge 

func (dst *PermissionsUpdate) XXX_Merge(src proto.Message)

func (*PermissionsUpdate) XXX_Size 

func (m *PermissionsUpdate) XXX_Size() int

func (*PermissionsUpdate) XXX_Unmarshal 

func (m *PermissionsUpdate) XXX_Unmarshal(b []byte) error

type PermissionsUpdate_Agreement 

type PermissionsUpdate_Agreement struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Body                 string   `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PermissionsUpdate_Agreement) Descriptor 

func (*PermissionsUpdate_Agreement) Descriptor() ([]byte, []int)

func (*PermissionsUpdate_Agreement) GetBody 

func (m *PermissionsUpdate_Agreement) GetBody() string

func (*PermissionsUpdate_Agreement) GetKey 

func (m *PermissionsUpdate_Agreement) GetKey() string

func (*PermissionsUpdate_Agreement) Marshal 

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

func (*PermissionsUpdate_Agreement) MarshalTo 

func (m *PermissionsUpdate_Agreement) MarshalTo(dAtA []byte) (int, error)

func (*PermissionsUpdate_Agreement) ProtoMessage 

func (*PermissionsUpdate_Agreement) ProtoMessage()

func (*PermissionsUpdate_Agreement) Reset 

func (m *PermissionsUpdate_Agreement) Reset()

func (*PermissionsUpdate_Agreement) Size 

func (m *PermissionsUpdate_Agreement) Size() (n int)

func (*PermissionsUpdate_Agreement) String 

func (m *PermissionsUpdate_Agreement) String() string

func (*PermissionsUpdate_Agreement) Unmarshal 

func (m *PermissionsUpdate_Agreement) Unmarshal(dAtA []byte) error

func (*PermissionsUpdate_Agreement) XXX_DiscardUnknown 

func (m *PermissionsUpdate_Agreement) XXX_DiscardUnknown()

func (*PermissionsUpdate_Agreement) XXX_Marshal 

func (m *PermissionsUpdate_Agreement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PermissionsUpdate_Agreement) XXX_Merge 

func (dst *PermissionsUpdate_Agreement) XXX_Merge(src proto.Message)

func (*PermissionsUpdate_Agreement) XXX_Size 

func (m *PermissionsUpdate_Agreement) XXX_Size() int

func (*PermissionsUpdate_Agreement) XXX_Unmarshal 

func (m *PermissionsUpdate_Agreement) XXX_Unmarshal(b []byte) error

type PermissionsUpdate_LeverageLevels 

type PermissionsUpdate_LeverageLevels struct {
	Buy                  []string `protobuf:"bytes,1,rep,name=buy,proto3" json:"buy,omitempty"`
	Sell                 []string `protobuf:"bytes,2,rep,name=sell,proto3" json:"sell,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PermissionsUpdate_LeverageLevels) Descriptor 

func (*PermissionsUpdate_LeverageLevels) Descriptor() ([]byte, []int)

func (*PermissionsUpdate_LeverageLevels) GetBuy 

func (m *PermissionsUpdate_LeverageLevels) GetBuy() []string

func (*PermissionsUpdate_LeverageLevels) GetSell 

func (m *PermissionsUpdate_LeverageLevels) GetSell() []string

func (*PermissionsUpdate_LeverageLevels) Marshal 

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

func (*PermissionsUpdate_LeverageLevels) MarshalTo 

func (m *PermissionsUpdate_LeverageLevels) MarshalTo(dAtA []byte) (int, error)

func (*PermissionsUpdate_LeverageLevels) ProtoMessage 

func (*PermissionsUpdate_LeverageLevels) ProtoMessage()

func (*PermissionsUpdate_LeverageLevels) Reset 

func (m *PermissionsUpdate_LeverageLevels) Reset()

func (*PermissionsUpdate_LeverageLevels) Size 

func (m *PermissionsUpdate_LeverageLevels) Size() (n int)

func (*PermissionsUpdate_LeverageLevels) String 

func (m *PermissionsUpdate_LeverageLevels) String() string

func (*PermissionsUpdate_LeverageLevels) Unmarshal 

func (m *PermissionsUpdate_LeverageLevels) Unmarshal(dAtA []byte) error

func (*PermissionsUpdate_LeverageLevels) XXX_DiscardUnknown 

func (m *PermissionsUpdate_LeverageLevels) XXX_DiscardUnknown()

func (*PermissionsUpdate_LeverageLevels) XXX_Marshal 

func (m *PermissionsUpdate_LeverageLevels) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PermissionsUpdate_LeverageLevels) XXX_Merge 

func (dst *PermissionsUpdate_LeverageLevels) XXX_Merge(src proto.Message)

func (*PermissionsUpdate_LeverageLevels) XXX_Size 

func (m *PermissionsUpdate_LeverageLevels) XXX_Size() int

func (*PermissionsUpdate_LeverageLevels) XXX_Unmarshal 

func (m *PermissionsUpdate_LeverageLevels) XXX_Unmarshal(b []byte) error

type PlaceOrderRequest 

type PlaceOrderRequest struct {
	Order                *PrivateOrder `protobuf:"bytes,2,opt,name=order,proto3" json:"order,omitempty"`
	ClosingOrder         *PrivateOrder `protobuf:"bytes,3,opt,name=closingOrder,proto3" json:"closingOrder,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*PlaceOrderRequest) Descriptor 

func (*PlaceOrderRequest) Descriptor() ([]byte, []int)

func (*PlaceOrderRequest) GetClosingOrder 

func (m *PlaceOrderRequest) GetClosingOrder() *PrivateOrder

func (*PlaceOrderRequest) GetOrder 

func (m *PlaceOrderRequest) GetOrder() *PrivateOrder

func (*PlaceOrderRequest) Marshal 

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

func (*PlaceOrderRequest) MarshalTo 

func (m *PlaceOrderRequest) MarshalTo(dAtA []byte) (int, error)

func (*PlaceOrderRequest) ProtoMessage 

func (*PlaceOrderRequest) ProtoMessage()

func (*PlaceOrderRequest) Reset 

func (m *PlaceOrderRequest) Reset()

func (*PlaceOrderRequest) Size 

func (m *PlaceOrderRequest) Size() (n int)

func (*PlaceOrderRequest) String 

func (m *PlaceOrderRequest) String() string

func (*PlaceOrderRequest) Unmarshal 

func (m *PlaceOrderRequest) Unmarshal(dAtA []byte) error

func (*PlaceOrderRequest) XXX_DiscardUnknown 

func (m *PlaceOrderRequest) XXX_DiscardUnknown()

func (*PlaceOrderRequest) XXX_Marshal 

func (m *PlaceOrderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlaceOrderRequest) XXX_Merge 

func (dst *PlaceOrderRequest) XXX_Merge(src proto.Message)

func (*PlaceOrderRequest) XXX_Size 

func (m *PlaceOrderRequest) XXX_Size() int

func (*PlaceOrderRequest) XXX_Unmarshal 

func (m *PlaceOrderRequest) XXX_Unmarshal(b []byte) error

type PlaceOrderResult 

type PlaceOrderResult struct {
	Order *PrivateOrder `protobuf:"bytes,2,opt,name=order,proto3" json:"order,omitempty"`
	// Deprecated
	OrderId              string   `protobuf:"bytes,1,opt,name=orderId,proto3" json:"orderId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PlaceOrderResult) Descriptor 

func (*PlaceOrderResult) Descriptor() ([]byte, []int)

func (*PlaceOrderResult) GetOrder 

func (m *PlaceOrderResult) GetOrder() *PrivateOrder

func (*PlaceOrderResult) GetOrderId 

func (m *PlaceOrderResult) GetOrderId() string

func (*PlaceOrderResult) Marshal 

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

func (*PlaceOrderResult) MarshalTo 

func (m *PlaceOrderResult) MarshalTo(dAtA []byte) (int, error)

func (*PlaceOrderResult) ProtoMessage 

func (*PlaceOrderResult) ProtoMessage()

func (*PlaceOrderResult) Reset 

func (m *PlaceOrderResult) Reset()

func (*PlaceOrderResult) Size 

func (m *PlaceOrderResult) Size() (n int)

func (*PlaceOrderResult) String 

func (m *PlaceOrderResult) String() string

func (*PlaceOrderResult) Unmarshal 

func (m *PlaceOrderResult) Unmarshal(dAtA []byte) error

func (*PlaceOrderResult) XXX_DiscardUnknown 

func (m *PlaceOrderResult) XXX_DiscardUnknown()

func (*PlaceOrderResult) XXX_Marshal 

func (m *PlaceOrderResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlaceOrderResult) XXX_Merge 

func (dst *PlaceOrderResult) XXX_Merge(src proto.Message)

func (*PlaceOrderResult) XXX_Size 

func (m *PlaceOrderResult) XXX_Size() int

func (*PlaceOrderResult) XXX_Unmarshal 

func (m *PlaceOrderResult) XXX_Unmarshal(b []byte) error

type PositionsUpdate 

type PositionsUpdate struct {
	Positions            []*PrivatePosition `protobuf:"bytes,1,rep,name=positions,proto3" json:"positions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*PositionsUpdate) Descriptor 

func (*PositionsUpdate) Descriptor() ([]byte, []int)

func (*PositionsUpdate) GetPositions 

func (m *PositionsUpdate) GetPositions() []*PrivatePosition

func (*PositionsUpdate) Marshal 

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

func (*PositionsUpdate) MarshalTo 

func (m *PositionsUpdate) MarshalTo(dAtA []byte) (int, error)

func (*PositionsUpdate) ProtoMessage 

func (*PositionsUpdate) ProtoMessage()

func (*PositionsUpdate) Reset 

func (m *PositionsUpdate) Reset()

func (*PositionsUpdate) Size 

func (m *PositionsUpdate) Size() (n int)

func (*PositionsUpdate) String 

func (m *PositionsUpdate) String() string

func (*PositionsUpdate) Unmarshal 

func (m *PositionsUpdate) Unmarshal(dAtA []byte) error

func (*PositionsUpdate) XXX_DiscardUnknown 

func (m *PositionsUpdate) XXX_DiscardUnknown()

func (*PositionsUpdate) XXX_Marshal 

func (m *PositionsUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PositionsUpdate) XXX_Merge 

func (dst *PositionsUpdate) XXX_Merge(src proto.Message)

func (*PositionsUpdate) XXX_Size 

func (m *PositionsUpdate) XXX_Size() int

func (*PositionsUpdate) XXX_Unmarshal 

func (m *PositionsUpdate) XXX_Unmarshal(b []byte) error

type PrivateOrder 

type PrivateOrder struct {
	Id                 string                     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Time               int64                      `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	Price              float32                    `protobuf:"fixed32,3,opt,name=price,proto3" json:"price,omitempty"`
	Amount             float32                    `protobuf:"fixed32,4,opt,name=amount,proto3" json:"amount,omitempty"`
	Side               int32                      `protobuf:"varint,5,opt,name=side,proto3" json:"side,omitempty"`
	Type               PrivateOrder_Type          `protobuf:"varint,6,opt,name=type,proto3,enum=ProtobufBroker.PrivateOrder_Type" json:"type,omitempty"`
	FundingType        FundingType                `protobuf:"varint,7,opt,name=fundingType,proto3,enum=ProtobufBroker.FundingType" json:"fundingType,omitempty"`
	PriceParams        []*PrivateOrder_PriceParam `protobuf:"bytes,8,rep,name=priceParams,proto3" json:"priceParams,omitempty"`
	AmountParam        float32                    `protobuf:"fixed32,9,opt,name=amountParam,proto3" json:"amountParam,omitempty"`
	AmountParamString  string                     `protobuf:"bytes,16,opt,name=amountParamString,proto3" json:"amountParamString,omitempty"`
	AmountFilledString string                     `protobuf:"bytes,17,opt,name=amountFilledString,proto3" json:"amountFilledString,omitempty"`
	Leverage           string                     `protobuf:"bytes,10,opt,name=leverage,proto3" json:"leverage,omitempty"`
	// For trailing orders
	// DEPRECATED; use strings instead
	CurrentStop             float32                    `protobuf:"fixed32,11,opt,name=currentStop,proto3" json:"currentStop,omitempty"`
	InitialStop             float32                    `protobuf:"fixed32,12,opt,name=initialStop,proto3" json:"initialStop,omitempty"`
	CurrentStopString       string                     `protobuf:"bytes,18,opt,name=currentStopString,proto3" json:"currentStopString,omitempty"`
	InitialStopString       string                     `protobuf:"bytes,19,opt,name=initialStopString,proto3" json:"initialStopString,omitempty"`
	StartTime               int64                      `protobuf:"varint,13,opt,name=startTime,proto3" json:"startTime,omitempty"`
	ExpireTime              int64                      `protobuf:"varint,14,opt,name=expireTime,proto3" json:"expireTime,omitempty"`
	Rate                    float32                    `protobuf:"fixed32,15,opt,name=rate,proto3" json:"rate,omitempty"`
	HasClosingOrder         bool                       `protobuf:"varint,20,opt,name=hasClosingOrder,proto3" json:"hasClosingOrder,omitempty"`
	ClosingOrderType        PrivateOrder_Type          `protobuf:"varint,21,opt,name=closingOrderType,proto3,enum=ProtobufBroker.PrivateOrder_Type" json:"closingOrderType,omitempty"`
	ClosingOrderPriceParams []*PrivateOrder_PriceParam `protobuf:"bytes,22,rep,name=closingOrderPriceParams,proto3" json:"closingOrderPriceParams,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}                   `json:"-"`
	XXX_unrecognized        []byte                     `json:"-"`
	XXX_sizecache           int32                      `json:"-"`
}

func (*PrivateOrder) Descriptor 

func (*PrivateOrder) Descriptor() ([]byte, []int)

func (*PrivateOrder) GetAmount 

func (m *PrivateOrder) GetAmount() float32

func (*PrivateOrder) GetAmountFilledString 

func (m *PrivateOrder) GetAmountFilledString() string

func (*PrivateOrder) GetAmountParam 

func (m *PrivateOrder) GetAmountParam() float32

func (*PrivateOrder) GetAmountParamString 

func (m *PrivateOrder) GetAmountParamString() string

func (*PrivateOrder) GetClosingOrderPriceParams 

func (m *PrivateOrder) GetClosingOrderPriceParams() []*PrivateOrder_PriceParam

func (*PrivateOrder) GetClosingOrderType 

func (m *PrivateOrder) GetClosingOrderType() PrivateOrder_Type

func (*PrivateOrder) GetCurrentStop 

func (m *PrivateOrder) GetCurrentStop() float32

func (*PrivateOrder) GetCurrentStopString 

func (m *PrivateOrder) GetCurrentStopString() string

func (*PrivateOrder) GetExpireTime 

func (m *PrivateOrder) GetExpireTime() int64

func (*PrivateOrder) GetFundingType 

func (m *PrivateOrder) GetFundingType() FundingType

func (*PrivateOrder) GetHasClosingOrder 

func (m *PrivateOrder) GetHasClosingOrder() bool

func (*PrivateOrder) GetId 

func (m *PrivateOrder) GetId() string

func (*PrivateOrder) GetInitialStop 

func (m *PrivateOrder) GetInitialStop() float32

func (*PrivateOrder) GetInitialStopString 

func (m *PrivateOrder) GetInitialStopString() string

func (*PrivateOrder) GetLeverage 

func (m *PrivateOrder) GetLeverage() string

func (*PrivateOrder) GetPrice 

func (m *PrivateOrder) GetPrice() float32

func (*PrivateOrder) GetPriceParams 

func (m *PrivateOrder) GetPriceParams() []*PrivateOrder_PriceParam

func (*PrivateOrder) GetRate 

func (m *PrivateOrder) GetRate() float32

func (*PrivateOrder) GetSide 

func (m *PrivateOrder) GetSide() int32

func (*PrivateOrder) GetStartTime 

func (m *PrivateOrder) GetStartTime() int64

func (*PrivateOrder) GetTime 

func (m *PrivateOrder) GetTime() int64

func (*PrivateOrder) GetType 

func (m *PrivateOrder) GetType() PrivateOrder_Type

func (*PrivateOrder) Marshal 

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

func (*PrivateOrder) MarshalTo 

func (m *PrivateOrder) MarshalTo(dAtA []byte) (int, error)

func (*PrivateOrder) ProtoMessage 

func (*PrivateOrder) ProtoMessage()

func (*PrivateOrder) Reset 

func (m *PrivateOrder) Reset()

func (*PrivateOrder) Size 

func (m *PrivateOrder) Size() (n int)

func (*PrivateOrder) String 

func (m *PrivateOrder) String() string

func (*PrivateOrder) Unmarshal 

func (m *PrivateOrder) Unmarshal(dAtA []byte) error

func (*PrivateOrder) XXX_DiscardUnknown 

func (m *PrivateOrder) XXX_DiscardUnknown()

func (*PrivateOrder) XXX_Marshal 

func (m *PrivateOrder) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrivateOrder) XXX_Merge 

func (dst *PrivateOrder) XXX_Merge(src proto.Message)

func (*PrivateOrder) XXX_Size 

func (m *PrivateOrder) XXX_Size() int

func (*PrivateOrder) XXX_Unmarshal 

func (m *PrivateOrder) XXX_Unmarshal(b []byte) error

type PrivateOrder_PriceParam 

type PrivateOrder_PriceParam struct {
	Value                float32                     `protobuf:"fixed32,1,opt,name=value,proto3" json:"value,omitempty"`
	ValueString          string                      `protobuf:"bytes,3,opt,name=valueString,proto3" json:"valueString,omitempty"`
	Type                 PrivateOrder_PriceParamType `protobuf:"varint,2,opt,name=type,proto3,enum=ProtobufBroker.PrivateOrder_PriceParamType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*PrivateOrder_PriceParam) Descriptor 

func (*PrivateOrder_PriceParam) Descriptor() ([]byte, []int)

func (*PrivateOrder_PriceParam) GetType 

func (m *PrivateOrder_PriceParam) GetType() PrivateOrder_PriceParamType

func (*PrivateOrder_PriceParam) GetValue 

func (m *PrivateOrder_PriceParam) GetValue() float32

func (*PrivateOrder_PriceParam) GetValueString 

func (m *PrivateOrder_PriceParam) GetValueString() string

func (*PrivateOrder_PriceParam) Marshal 

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

func (*PrivateOrder_PriceParam) MarshalTo 

func (m *PrivateOrder_PriceParam) MarshalTo(dAtA []byte) (int, error)

func (*PrivateOrder_PriceParam) ProtoMessage 

func (*PrivateOrder_PriceParam) ProtoMessage()

func (*PrivateOrder_PriceParam) Reset 

func (m *PrivateOrder_PriceParam) Reset()

func (*PrivateOrder_PriceParam) Size 

func (m *PrivateOrder_PriceParam) Size() (n int)

func (*PrivateOrder_PriceParam) String 

func (m *PrivateOrder_PriceParam) String() string

func (*PrivateOrder_PriceParam) Unmarshal 

func (m *PrivateOrder_PriceParam) Unmarshal(dAtA []byte) error

func (*PrivateOrder_PriceParam) XXX_DiscardUnknown 

func (m *PrivateOrder_PriceParam) XXX_DiscardUnknown()

func (*PrivateOrder_PriceParam) XXX_Marshal 

func (m *PrivateOrder_PriceParam) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrivateOrder_PriceParam) XXX_Merge 

func (dst *PrivateOrder_PriceParam) XXX_Merge(src proto.Message)

func (*PrivateOrder_PriceParam) XXX_Size 

func (m *PrivateOrder_PriceParam) XXX_Size() int

func (*PrivateOrder_PriceParam) XXX_Unmarshal 

func (m *PrivateOrder_PriceParam) XXX_Unmarshal(b []byte) error

type PrivateOrder_PriceParamType 

type PrivateOrder_PriceParamType int32
const (
	PrivateOrder_AbsoluteValue         PrivateOrder_PriceParamType = 0
	PrivateOrder_OffsetValue           PrivateOrder_PriceParamType = 1
	PrivateOrder_PrecentageOffsetValue PrivateOrder_PriceParamType = 2
)

func (PrivateOrder_PriceParamType) EnumDescriptor 

func (PrivateOrder_PriceParamType) EnumDescriptor() ([]byte, []int)

func (PrivateOrder_PriceParamType) String 

func (x PrivateOrder_PriceParamType) String() string

type PrivateOrder_Type 

type PrivateOrder_Type int32
const (
	PrivateOrder_Market                  PrivateOrder_Type = 0
	PrivateOrder_Limit                   PrivateOrder_Type = 1
	PrivateOrder_StopLoss                PrivateOrder_Type = 2
	PrivateOrder_StopLossLimit           PrivateOrder_Type = 3
	PrivateOrder_TakeProfit              PrivateOrder_Type = 4
	PrivateOrder_TakeProfitLimit         PrivateOrder_Type = 5
	PrivateOrder_StopLossTakeProfit      PrivateOrder_Type = 6
	PrivateOrder_StopLossTakeProfitLimit PrivateOrder_Type = 7
	PrivateOrder_TrailingStopLoss        PrivateOrder_Type = 8
	PrivateOrder_TrailingStopLossLimit   PrivateOrder_Type = 9
	PrivateOrder_StopLossAndLimit        PrivateOrder_Type = 10
	PrivateOrder_FillOrKill              PrivateOrder_Type = 11
	PrivateOrder_SettlePosition          PrivateOrder_Type = 12
)

func (PrivateOrder_Type) EnumDescriptor 

func (PrivateOrder_Type) EnumDescriptor() ([]byte, []int)

func (PrivateOrder_Type) String 

func (x PrivateOrder_Type) String() string

type PrivatePosition 

type PrivatePosition struct {
	Id             string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Time           int64   `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	Side           int32   `protobuf:"varint,3,opt,name=side,proto3" json:"side,omitempty"`
	AvgPrice       float32 `protobuf:"fixed32,4,opt,name=avgPrice,proto3" json:"avgPrice,omitempty"`
	AvgPriceString string  `protobuf:"bytes,9,opt,name=avgPriceString,proto3" json:"avgPriceString,omitempty"`
	// DEPRECATED; use strings instead
	AmountOpen         float32  `protobuf:"fixed32,5,opt,name=amountOpen,proto3" json:"amountOpen,omitempty"`
	AmountClosed       float32  `protobuf:"fixed32,6,opt,name=amountClosed,proto3" json:"amountClosed,omitempty"`
	AmountOpenString   string   `protobuf:"bytes,10,opt,name=amountOpenString,proto3" json:"amountOpenString,omitempty"`
	AmountClosedString string   `protobuf:"bytes,11,opt,name=amountClosedString,proto3" json:"amountClosedString,omitempty"`
	OrderIds           []string `protobuf:"bytes,7,rep,name=orderIds,proto3" json:"orderIds,omitempty"`
	// NOTE:
	// Trade ids are sent as strings here, while historically they
	// have been represented as integers. We need to transition to using
	// strings everywhere because of the rectangle/square rule; using
	// ints is simply not compatible with some exchanges which use UUIDs (like Kraken lol)
	TradeIds             []string `protobuf:"bytes,8,rep,name=tradeIds,proto3" json:"tradeIds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrivatePosition) Descriptor 

func (*PrivatePosition) Descriptor() ([]byte, []int)

func (*PrivatePosition) GetAmountClosed 

func (m *PrivatePosition) GetAmountClosed() float32

func (*PrivatePosition) GetAmountClosedString 

func (m *PrivatePosition) GetAmountClosedString() string

func (*PrivatePosition) GetAmountOpen 

func (m *PrivatePosition) GetAmountOpen() float32

func (*PrivatePosition) GetAmountOpenString 

func (m *PrivatePosition) GetAmountOpenString() string

func (*PrivatePosition) GetAvgPrice 

func (m *PrivatePosition) GetAvgPrice() float32

func (*PrivatePosition) GetAvgPriceString 

func (m *PrivatePosition) GetAvgPriceString() string

func (*PrivatePosition) GetId 

func (m *PrivatePosition) GetId() string

func (*PrivatePosition) GetOrderIds 

func (m *PrivatePosition) GetOrderIds() []string

func (*PrivatePosition) GetSide 

func (m *PrivatePosition) GetSide() int32

func (*PrivatePosition) GetTime 

func (m *PrivatePosition) GetTime() int64

func (*PrivatePosition) GetTradeIds 

func (m *PrivatePosition) GetTradeIds() []string

func (*PrivatePosition) Marshal 

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

func (*PrivatePosition) MarshalTo 

func (m *PrivatePosition) MarshalTo(dAtA []byte) (int, error)

func (*PrivatePosition) ProtoMessage 

func (*PrivatePosition) ProtoMessage()

func (*PrivatePosition) Reset 

func (m *PrivatePosition) Reset()

func (*PrivatePosition) Size 

func (m *PrivatePosition) Size() (n int)

func (*PrivatePosition) String 

func (m *PrivatePosition) String() string

func (*PrivatePosition) Unmarshal 

func (m *PrivatePosition) Unmarshal(dAtA []byte) error

func (*PrivatePosition) XXX_DiscardUnknown 

func (m *PrivatePosition) XXX_DiscardUnknown()

func (*PrivatePosition) XXX_Marshal 

func (m *PrivatePosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrivatePosition) XXX_Merge 

func (dst *PrivatePosition) XXX_Merge(src proto.Message)

func (*PrivatePosition) XXX_Size 

func (m *PrivatePosition) XXX_Size() int

func (*PrivatePosition) XXX_Unmarshal 

func (m *PrivatePosition) XXX_Unmarshal(b []byte) error

type PrivateTrade 

type PrivateTrade struct {
	ExternalId   string  `protobuf:"bytes,7,opt,name=externalId,proto3" json:"externalId,omitempty"`
	OrderId      string  `protobuf:"bytes,8,opt,name=orderId,proto3" json:"orderId,omitempty"`
	Time         int64   `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	TimeMillis   int64   `protobuf:"varint,6,opt,name=timeMillis,proto3" json:"timeMillis,omitempty"`
	Price        float32 `protobuf:"fixed32,3,opt,name=price,proto3" json:"price,omitempty"`
	PriceString  string  `protobuf:"bytes,9,opt,name=priceString,proto3" json:"priceString,omitempty"`
	Amount       float32 `protobuf:"fixed32,4,opt,name=amount,proto3" json:"amount,omitempty"`
	AmountString string  `protobuf:"bytes,10,opt,name=amountString,proto3" json:"amountString,omitempty"`
	Side         int32   `protobuf:"varint,5,opt,name=side,proto3" json:"side,omitempty"`
	// Deprecated since we don't want to expose our SQL IDs
	Id                   int64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrivateTrade) Descriptor 

func (*PrivateTrade) Descriptor() ([]byte, []int)

func (*PrivateTrade) GetAmount 

func (m *PrivateTrade) GetAmount() float32

func (*PrivateTrade) GetAmountString 

func (m *PrivateTrade) GetAmountString() string

func (*PrivateTrade) GetExternalId 

func (m *PrivateTrade) GetExternalId() string

func (*PrivateTrade) GetId 

func (m *PrivateTrade) GetId() int64

func (*PrivateTrade) GetOrderId 

func (m *PrivateTrade) GetOrderId() string

func (*PrivateTrade) GetPrice 

func (m *PrivateTrade) GetPrice() float32

func (*PrivateTrade) GetPriceString 

func (m *PrivateTrade) GetPriceString() string

func (*PrivateTrade) GetSide 

func (m *PrivateTrade) GetSide() int32

func (*PrivateTrade) GetTime 

func (m *PrivateTrade) GetTime() int64

func (*PrivateTrade) GetTimeMillis 

func (m *PrivateTrade) GetTimeMillis() int64

func (*PrivateTrade) Marshal 

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

func (*PrivateTrade) MarshalTo 

func (m *PrivateTrade) MarshalTo(dAtA []byte) (int, error)

func (*PrivateTrade) ProtoMessage 

func (*PrivateTrade) ProtoMessage()

func (*PrivateTrade) Reset 

func (m *PrivateTrade) Reset()

func (*PrivateTrade) Size 

func (m *PrivateTrade) Size() (n int)

func (*PrivateTrade) String 

func (m *PrivateTrade) String() string

func (*PrivateTrade) Unmarshal 

func (m *PrivateTrade) Unmarshal(dAtA []byte) error

func (*PrivateTrade) XXX_DiscardUnknown 

func (m *PrivateTrade) XXX_DiscardUnknown()

func (*PrivateTrade) XXX_Marshal 

func (m *PrivateTrade) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrivateTrade) XXX_Merge 

func (dst *PrivateTrade) XXX_Merge(src proto.Message)

func (*PrivateTrade) XXX_Size 

func (m *PrivateTrade) XXX_Size() int

func (*PrivateTrade) XXX_Unmarshal 

func (m *PrivateTrade) XXX_Unmarshal(b []byte) error

type ReplaceOrderRequest 

type ReplaceOrderRequest struct {
	OrderId                 string        `protobuf:"bytes,1,opt,name=orderId,proto3" json:"orderId,omitempty"`
	Replacement             *PrivateOrder `protobuf:"bytes,2,opt,name=replacement,proto3" json:"replacement,omitempty"`
	ReplacementClosingOrder *PrivateOrder `protobuf:"bytes,3,opt,name=replacementClosingOrder,proto3" json:"replacementClosingOrder,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}      `json:"-"`
	XXX_unrecognized        []byte        `json:"-"`
	XXX_sizecache           int32         `json:"-"`
}

func (*ReplaceOrderRequest) Descriptor 

func (*ReplaceOrderRequest) Descriptor() ([]byte, []int)

func (*ReplaceOrderRequest) GetOrderId 

func (m *ReplaceOrderRequest) GetOrderId() string

func (*ReplaceOrderRequest) GetReplacement 

func (m *ReplaceOrderRequest) GetReplacement() *PrivateOrder

func (*ReplaceOrderRequest) GetReplacementClosingOrder 

func (m *ReplaceOrderRequest) GetReplacementClosingOrder() *PrivateOrder

func (*ReplaceOrderRequest) Marshal 

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

func (*ReplaceOrderRequest) MarshalTo 

func (m *ReplaceOrderRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReplaceOrderRequest) ProtoMessage 

func (*ReplaceOrderRequest) ProtoMessage()

func (*ReplaceOrderRequest) Reset 

func (m *ReplaceOrderRequest) Reset()

func (*ReplaceOrderRequest) Size 

func (m *ReplaceOrderRequest) Size() (n int)

func (*ReplaceOrderRequest) String 

func (m *ReplaceOrderRequest) String() string

func (*ReplaceOrderRequest) Unmarshal 

func (m *ReplaceOrderRequest) Unmarshal(dAtA []byte) error

func (*ReplaceOrderRequest) XXX_DiscardUnknown 

func (m *ReplaceOrderRequest) XXX_DiscardUnknown()

func (*ReplaceOrderRequest) XXX_Marshal 

func (m *ReplaceOrderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplaceOrderRequest) XXX_Merge 

func (dst *ReplaceOrderRequest) XXX_Merge(src proto.Message)

func (*ReplaceOrderRequest) XXX_Size 

func (m *ReplaceOrderRequest) XXX_Size() int

func (*ReplaceOrderRequest) XXX_Unmarshal 

func (m *ReplaceOrderRequest) XXX_Unmarshal(b []byte) error

type RequestResolutionUpdate 

type RequestResolutionUpdate struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Error   int32  `protobuf:"varint,2,opt,name=error,proto3" json:"error,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// Types that are valid to be assigned to Result:
	//	*RequestResolutionUpdate_PlaceOrderResult
	//	*RequestResolutionUpdate_CancelOrderResult
	Result               isRequestResolutionUpdate_Result `protobuf_oneof:"Result"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*RequestResolutionUpdate) Descriptor 

func (*RequestResolutionUpdate) Descriptor() ([]byte, []int)

func (*RequestResolutionUpdate) GetCancelOrderResult 

func (m *RequestResolutionUpdate) GetCancelOrderResult() *CancelOrderResult

func (*RequestResolutionUpdate) GetError 

func (m *RequestResolutionUpdate) GetError() int32

func (*RequestResolutionUpdate) GetId 

func (m *RequestResolutionUpdate) GetId() string

func (*RequestResolutionUpdate) GetMessage 

func (m *RequestResolutionUpdate) GetMessage() string

func (*RequestResolutionUpdate) GetPlaceOrderResult 

func (m *RequestResolutionUpdate) GetPlaceOrderResult() *PlaceOrderResult

func (*RequestResolutionUpdate) GetResult 

func (m *RequestResolutionUpdate) GetResult() isRequestResolutionUpdate_Result

func (*RequestResolutionUpdate) Marshal 

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

func (*RequestResolutionUpdate) MarshalTo 

func (m *RequestResolutionUpdate) MarshalTo(dAtA []byte) (int, error)

func (*RequestResolutionUpdate) ProtoMessage 

func (*RequestResolutionUpdate) ProtoMessage()

func (*RequestResolutionUpdate) Reset 

func (m *RequestResolutionUpdate) Reset()

func (*RequestResolutionUpdate) Size 

func (m *RequestResolutionUpdate) Size() (n int)

func (*RequestResolutionUpdate) String 

func (m *RequestResolutionUpdate) String() string

func (*RequestResolutionUpdate) Unmarshal 

func (m *RequestResolutionUpdate) Unmarshal(dAtA []byte) error

func (*RequestResolutionUpdate) XXX_DiscardUnknown 

func (m *RequestResolutionUpdate) XXX_DiscardUnknown()

func (*RequestResolutionUpdate) XXX_Marshal 

func (m *RequestResolutionUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestResolutionUpdate) XXX_Merge 

func (dst *RequestResolutionUpdate) XXX_Merge(src proto.Message)

func (*RequestResolutionUpdate) XXX_OneofFuncs 

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

func (m *RequestResolutionUpdate) XXX_Size() int

func (*RequestResolutionUpdate) XXX_Unmarshal 

func (m *RequestResolutionUpdate) XXX_Unmarshal(b []byte) error

type RequestResolutionUpdate_CancelOrderResult 

type RequestResolutionUpdate_CancelOrderResult struct {
	CancelOrderResult *CancelOrderResult `protobuf:"bytes,5,opt,name=cancelOrderResult,proto3,oneof"`
}

func (*RequestResolutionUpdate_CancelOrderResult) MarshalTo 

func (m *RequestResolutionUpdate_CancelOrderResult) MarshalTo(dAtA []byte) (int, error)

func (*RequestResolutionUpdate_CancelOrderResult) Size 

func (m *RequestResolutionUpdate_CancelOrderResult) Size() (n int)

type RequestResolutionUpdate_PlaceOrderResult 

type RequestResolutionUpdate_PlaceOrderResult struct {
	PlaceOrderResult *PlaceOrderResult `protobuf:"bytes,4,opt,name=placeOrderResult,proto3,oneof"`
}

func (*RequestResolutionUpdate_PlaceOrderResult) MarshalTo 

func (m *RequestResolutionUpdate_PlaceOrderResult) MarshalTo(dAtA []byte) (int, error)

func (*RequestResolutionUpdate_PlaceOrderResult) Size 

func (m *RequestResolutionUpdate_PlaceOrderResult) Size() (n int)

type SessionStatusUpdate 

type SessionStatusUpdate struct {
	Initialized bool `protobuf:"varint,1,opt,name=initialized,proto3" json:"initialized,omitempty"`
	// Syncing means poller is running
	Syncing bool `protobuf:"varint,2,opt,name=syncing,proto3" json:"syncing,omitempty"`
	// Last sync is last time poller finished running
	LastSyncTime int64 `protobuf:"varint,3,opt,name=lastSyncTime,proto3" json:"lastSyncTime,omitempty"`
	// Expose error from poller
	SyncError            int32    `protobuf:"varint,4,opt,name=syncError,proto3" json:"syncError,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SessionStatusUpdate) Descriptor 

func (*SessionStatusUpdate) Descriptor() ([]byte, []int)

func (*SessionStatusUpdate) GetInitialized 

func (m *SessionStatusUpdate) GetInitialized() bool

func (*SessionStatusUpdate) GetLastSyncTime 

func (m *SessionStatusUpdate) GetLastSyncTime() int64

func (*SessionStatusUpdate) GetSyncError 

func (m *SessionStatusUpdate) GetSyncError() int32

func (*SessionStatusUpdate) GetSyncing 

func (m *SessionStatusUpdate) GetSyncing() bool

func (*SessionStatusUpdate) Marshal 

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

func (*SessionStatusUpdate) MarshalTo 

func (m *SessionStatusUpdate) MarshalTo(dAtA []byte) (int, error)

func (*SessionStatusUpdate) ProtoMessage 

func (*SessionStatusUpdate) ProtoMessage()

func (*SessionStatusUpdate) Reset 

func (m *SessionStatusUpdate) Reset()

func (*SessionStatusUpdate) Size 

func (m *SessionStatusUpdate) Size() (n int)

func (*SessionStatusUpdate) String 

func (m *SessionStatusUpdate) String() string

func (*SessionStatusUpdate) Unmarshal 

func (m *SessionStatusUpdate) Unmarshal(dAtA []byte) error

func (*SessionStatusUpdate) XXX_DiscardUnknown 

func (m *SessionStatusUpdate) XXX_DiscardUnknown()

func (*SessionStatusUpdate) XXX_Marshal 

func (m *SessionStatusUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionStatusUpdate) XXX_Merge 

func (dst *SessionStatusUpdate) XXX_Merge(src proto.Message)

func (*SessionStatusUpdate) XXX_Size 

func (m *SessionStatusUpdate) XXX_Size() int

func (*SessionStatusUpdate) XXX_Unmarshal 

func (m *SessionStatusUpdate) XXX_Unmarshal(b []byte) error

type SyncRequest 

type SyncRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SyncRequest) Descriptor 

func (*SyncRequest) Descriptor() ([]byte, []int)

func (*SyncRequest) Marshal 

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

func (*SyncRequest) MarshalTo 

func (m *SyncRequest) MarshalTo(dAtA []byte) (int, error)

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) Reset 

func (m *SyncRequest) Reset()

func (*SyncRequest) Size 

func (m *SyncRequest) Size() (n int)

func (*SyncRequest) String 

func (m *SyncRequest) String() string

func (*SyncRequest) Unmarshal 

func (m *SyncRequest) Unmarshal(dAtA []byte) error

func (*SyncRequest) XXX_DiscardUnknown 

func (m *SyncRequest) XXX_DiscardUnknown()

func (*SyncRequest) XXX_Marshal 

func (m *SyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncRequest) XXX_Merge 

func (dst *SyncRequest) XXX_Merge(src proto.Message)

func (*SyncRequest) XXX_Size 

func (m *SyncRequest) XXX_Size() int

func (*SyncRequest) XXX_Unmarshal 

func (m *SyncRequest) XXX_Unmarshal(b []byte) error

type TradesUpdate 

type TradesUpdate struct {
	Trades               []*PrivateTrade `protobuf:"bytes,1,rep,name=trades,proto3" json:"trades,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*TradesUpdate) Descriptor 

func (*TradesUpdate) Descriptor() ([]byte, []int)

func (*TradesUpdate) GetTrades 

func (m *TradesUpdate) GetTrades() []*PrivateTrade

func (*TradesUpdate) Marshal 

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

func (*TradesUpdate) MarshalTo 

func (m *TradesUpdate) MarshalTo(dAtA []byte) (int, error)

func (*TradesUpdate) ProtoMessage 

func (*TradesUpdate) ProtoMessage()

func (*TradesUpdate) Reset 

func (m *TradesUpdate) Reset()

func (*TradesUpdate) Size 

func (m *TradesUpdate) Size() (n int)

func (*TradesUpdate) String 

func (m *TradesUpdate) String() string

func (*TradesUpdate) Unmarshal 

func (m *TradesUpdate) Unmarshal(dAtA []byte) error

func (*TradesUpdate) XXX_DiscardUnknown 

func (m *TradesUpdate) XXX_DiscardUnknown()

func (*TradesUpdate) XXX_Marshal 

func (m *TradesUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TradesUpdate) XXX_Merge 

func (dst *TradesUpdate) XXX_Merge(src proto.Message)

func (*TradesUpdate) XXX_Size 

func (m *TradesUpdate) XXX_Size() int

func (*TradesUpdate) XXX_Unmarshal 

func (m *TradesUpdate) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.