ProtobufStream

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthStream = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStream   = fmt.Errorf("proto: integer overflow")
)
View Source 
var AuthenticationResult_Status_name = map[int32]string{
	0: "UNKNOWN",
	1: "AUTHENTICATED",
	2: "BAD_NONCE",
	3: "BAD_TOKEN",
	4: "TOKEN_EXPIRED",
	5: "READONLY_KEY",
	6: "ACCESS_DENIED",
}
View Source 
var AuthenticationResult_Status_value = map[string]int32{
	"UNKNOWN":       0,
	"AUTHENTICATED": 1,
	"BAD_NONCE":     2,
	"BAD_TOKEN":     3,
	"TOKEN_EXPIRED": 4,
	"READONLY_KEY":  5,
	"ACCESS_DENIED": 6,
}

Functions

This section is empty.

Types

type AuthenticationResult 

type AuthenticationResult struct {
	Status               AuthenticationResult_Status `protobuf:"varint,1,opt,name=status,proto3,enum=ProtobufStream.AuthenticationResult_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*AuthenticationResult) Descriptor 

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

func (*AuthenticationResult) GetStatus 

func (m *AuthenticationResult) GetStatus() AuthenticationResult_Status

func (*AuthenticationResult) Marshal 

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

func (*AuthenticationResult) MarshalTo 

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

func (*AuthenticationResult) ProtoMessage 

func (*AuthenticationResult) ProtoMessage()

func (*AuthenticationResult) Reset 

func (m *AuthenticationResult) Reset()

func (*AuthenticationResult) Size 

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

func (*AuthenticationResult) String 

func (m *AuthenticationResult) String() string

func (*AuthenticationResult) Unmarshal 

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

func (*AuthenticationResult) XXX_DiscardUnknown 

func (m *AuthenticationResult) XXX_DiscardUnknown()

func (*AuthenticationResult) XXX_Marshal 

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

func (*AuthenticationResult) XXX_Merge 

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

func (*AuthenticationResult) XXX_Size 

func (m *AuthenticationResult) XXX_Size() int

func (*AuthenticationResult) XXX_Unmarshal 

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

type AuthenticationResult_Status 

type AuthenticationResult_Status int32
const (
	AuthenticationResult_UNKNOWN       AuthenticationResult_Status = 0
	AuthenticationResult_AUTHENTICATED AuthenticationResult_Status = 1
	AuthenticationResult_BAD_NONCE     AuthenticationResult_Status = 2
	AuthenticationResult_BAD_TOKEN     AuthenticationResult_Status = 3
	AuthenticationResult_TOKEN_EXPIRED AuthenticationResult_Status = 4
	AuthenticationResult_READONLY_KEY  AuthenticationResult_Status = 5
	AuthenticationResult_ACCESS_DENIED AuthenticationResult_Status = 6
)

func (AuthenticationResult_Status) EnumDescriptor 

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

func (AuthenticationResult_Status) String 

func (x AuthenticationResult_Status) String() string

type BandwidthUpdate 

type BandwidthUpdate struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	BytesRemaining       int64    `protobuf:"varint,2,opt,name=bytesRemaining,proto3" json:"bytesRemaining,omitempty"`
	BytesUsed            int64    `protobuf:"varint,3,opt,name=bytesUsed,proto3" json:"bytesUsed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

BandwidthUpdate is sent periodically to update stream api clients on their bandwidth usage. - Ok indicates if you have remaining bandwidth to stream. - bytesRemaining is the number of bytes you can stream until the next billing period. - bytesUsed is the number of bytes you have streamed since the last billing period.

func (*BandwidthUpdate) Descriptor 

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

func (*BandwidthUpdate) GetBytesRemaining 

func (m *BandwidthUpdate) GetBytesRemaining() int64

func (*BandwidthUpdate) GetBytesUsed 

func (m *BandwidthUpdate) GetBytesUsed() int64

func (*BandwidthUpdate) GetOk 

func (m *BandwidthUpdate) GetOk() bool

func (*BandwidthUpdate) Marshal 

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

func (*BandwidthUpdate) MarshalTo 

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

func (*BandwidthUpdate) ProtoMessage 

func (*BandwidthUpdate) ProtoMessage()

func (*BandwidthUpdate) Reset 

func (m *BandwidthUpdate) Reset()

func (*BandwidthUpdate) Size 

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

func (*BandwidthUpdate) String 

func (m *BandwidthUpdate) String() string

func (*BandwidthUpdate) Unmarshal 

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

func (*BandwidthUpdate) XXX_DiscardUnknown 

func (m *BandwidthUpdate) XXX_DiscardUnknown()

func (*BandwidthUpdate) XXX_Marshal 

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

func (*BandwidthUpdate) XXX_Merge 

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

func (*BandwidthUpdate) XXX_Size 

func (m *BandwidthUpdate) XXX_Size() int

func (*BandwidthUpdate) XXX_Unmarshal 

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

type MissedMessages 

type MissedMessages struct {
	NumMissedMessages    int64    `protobuf:"varint,1,opt,name=numMissedMessages,proto3" json:"numMissedMessages,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MissedMessages is sent by stream to the clients if stream's internal buffer is overflown by the messages, so some messages were missed. Normally it could only happen if a client subscribes to too many channels.

func (*MissedMessages) Descriptor 

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

func (*MissedMessages) GetNumMissedMessages 

func (m *MissedMessages) GetNumMissedMessages() int64

func (*MissedMessages) Marshal 

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

func (*MissedMessages) MarshalTo 

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

func (*MissedMessages) ProtoMessage 

func (*MissedMessages) ProtoMessage()

func (*MissedMessages) Reset 

func (m *MissedMessages) Reset()

func (*MissedMessages) Size 

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

func (*MissedMessages) String 

func (m *MissedMessages) String() string

func (*MissedMessages) Unmarshal 

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

func (*MissedMessages) XXX_DiscardUnknown 

func (m *MissedMessages) XXX_DiscardUnknown()

func (*MissedMessages) XXX_Marshal 

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

func (*MissedMessages) XXX_Merge 

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

func (*MissedMessages) XXX_Size 

func (m *MissedMessages) XXX_Size() int

func (*MissedMessages) XXX_Unmarshal 

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

type StreamMessage 

type StreamMessage struct {
	// Types that are valid to be assigned to Body:
	//	*StreamMessage_AuthenticationResult
	//	*StreamMessage_SubscriptionResult
	//	*StreamMessage_UnsubscriptionResult
	//	*StreamMessage_MissedMessages
	//	*StreamMessage_MarketUpdate
	//	*StreamMessage_PairUpdate
	//	*StreamMessage_AssetUpdate
	//	*StreamMessage_IndexUpdate
	//	*StreamMessage_BandwidthUpdate
	Body                 isStreamMessage_Body `protobuf_oneof:"body"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*StreamMessage) Descriptor 

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

func (*StreamMessage) GetAssetUpdate 

func (m *StreamMessage) GetAssetUpdate() *markets.AssetUpdateMessage

func (*StreamMessage) GetAuthenticationResult 

func (m *StreamMessage) GetAuthenticationResult() *AuthenticationResult

func (*StreamMessage) GetBandwidthUpdate 

func (m *StreamMessage) GetBandwidthUpdate() *BandwidthUpdate

func (*StreamMessage) GetBody 

func (m *StreamMessage) GetBody() isStreamMessage_Body

func (*StreamMessage) GetIndexUpdate 

func (m *StreamMessage) GetIndexUpdate() *markets.IndexUpdateMessage

func (*StreamMessage) GetMarketUpdate 

func (m *StreamMessage) GetMarketUpdate() *markets.MarketUpdateMessage

func (*StreamMessage) GetMissedMessages 

func (m *StreamMessage) GetMissedMessages() *MissedMessages

func (*StreamMessage) GetPairUpdate 

func (m *StreamMessage) GetPairUpdate() *markets.PairUpdateMessage

func (*StreamMessage) GetSubscriptionResult 

func (m *StreamMessage) GetSubscriptionResult() *SubscriptionResult

func (*StreamMessage) GetUnsubscriptionResult 

func (m *StreamMessage) GetUnsubscriptionResult() *UnsubscriptionResult

func (*StreamMessage) Marshal 

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

func (*StreamMessage) MarshalTo 

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

func (*StreamMessage) ProtoMessage 

func (*StreamMessage) ProtoMessage()

func (*StreamMessage) Reset 

func (m *StreamMessage) Reset()

func (*StreamMessage) Size 

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

func (*StreamMessage) String 

func (m *StreamMessage) String() string

func (*StreamMessage) Unmarshal 

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

func (*StreamMessage) XXX_DiscardUnknown 

func (m *StreamMessage) XXX_DiscardUnknown()

func (*StreamMessage) XXX_Marshal 

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

func (*StreamMessage) XXX_Merge 

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

func (*StreamMessage) XXX_OneofFuncs 

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

func (m *StreamMessage) XXX_Size() int

func (*StreamMessage) XXX_Unmarshal 

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

type StreamMessage_AssetUpdate 

type StreamMessage_AssetUpdate struct {
	AssetUpdate *markets.AssetUpdateMessage `protobuf:"bytes,4,opt,name=assetUpdate,proto3,oneof"`
}

func (*StreamMessage_AssetUpdate) MarshalTo 

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

func (*StreamMessage_AssetUpdate) Size 

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

type StreamMessage_AuthenticationResult 

type StreamMessage_AuthenticationResult struct {
	AuthenticationResult *AuthenticationResult `protobuf:"bytes,1,opt,name=authenticationResult,proto3,oneof"`
}

func (*StreamMessage_AuthenticationResult) MarshalTo 

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

func (*StreamMessage_AuthenticationResult) Size 

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

type StreamMessage_BandwidthUpdate 

type StreamMessage_BandwidthUpdate struct {
	BandwidthUpdate *BandwidthUpdate `protobuf:"bytes,9,opt,name=bandwidthUpdate,proto3,oneof"`
}

func (*StreamMessage_BandwidthUpdate) MarshalTo 

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

func (*StreamMessage_BandwidthUpdate) Size 

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

type StreamMessage_IndexUpdate 

type StreamMessage_IndexUpdate struct {
	IndexUpdate *markets.IndexUpdateMessage `protobuf:"bytes,8,opt,name=indexUpdate,proto3,oneof"`
}

func (*StreamMessage_IndexUpdate) MarshalTo 

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

func (*StreamMessage_IndexUpdate) Size 

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

type StreamMessage_MarketUpdate 

type StreamMessage_MarketUpdate struct {
	MarketUpdate *markets.MarketUpdateMessage `protobuf:"bytes,2,opt,name=marketUpdate,proto3,oneof"`
}

func (*StreamMessage_MarketUpdate) MarshalTo 

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

func (*StreamMessage_MarketUpdate) Size 

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

type StreamMessage_MissedMessages 

type StreamMessage_MissedMessages struct {
	MissedMessages *MissedMessages `protobuf:"bytes,7,opt,name=missedMessages,proto3,oneof"`
}

func (*StreamMessage_MissedMessages) MarshalTo 

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

func (*StreamMessage_MissedMessages) Size 

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

type StreamMessage_PairUpdate 

type StreamMessage_PairUpdate struct {
	PairUpdate *markets.PairUpdateMessage `protobuf:"bytes,3,opt,name=pairUpdate,proto3,oneof"`
}

func (*StreamMessage_PairUpdate) MarshalTo 

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

func (*StreamMessage_PairUpdate) Size 

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

type StreamMessage_SubscriptionResult 

type StreamMessage_SubscriptionResult struct {
	SubscriptionResult *SubscriptionResult `protobuf:"bytes,5,opt,name=subscriptionResult,proto3,oneof"`
}

func (*StreamMessage_SubscriptionResult) MarshalTo 

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

func (*StreamMessage_SubscriptionResult) Size 

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

type StreamMessage_UnsubscriptionResult 

type StreamMessage_UnsubscriptionResult struct {
	UnsubscriptionResult *UnsubscriptionResult `protobuf:"bytes,6,opt,name=unsubscriptionResult,proto3,oneof"`
}

func (*StreamMessage_UnsubscriptionResult) MarshalTo 

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

func (*StreamMessage_UnsubscriptionResult) Size 

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

type SubscribeError 

type SubscribeError struct {
	Key                  string                     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Deprecated: Do not use.
	Error                string                     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Subscription         *client.ClientSubscription `protobuf:"bytes,3,opt,name=subscription,proto3" json:"subscription,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

SubscribeError represents an error of a single key: it contains the key and the error message explaining why subscription has failed. Sent as part of SubscriptionResult.

func (*SubscribeError) Descriptor 

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

func (*SubscribeError) GetError 

func (m *SubscribeError) GetError() string

func (*SubscribeError) GetKey deprecated 

func (m *SubscribeError) GetKey() string

Deprecated: Do not use.

func (*SubscribeError) GetSubscription 

func (m *SubscribeError) GetSubscription() *client.ClientSubscription

func (*SubscribeError) Marshal 

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

func (*SubscribeError) MarshalTo 

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

func (*SubscribeError) ProtoMessage 

func (*SubscribeError) ProtoMessage()

func (*SubscribeError) Reset 

func (m *SubscribeError) Reset()

func (*SubscribeError) Size 

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

func (*SubscribeError) String 

func (m *SubscribeError) String() string

func (*SubscribeError) Unmarshal 

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

func (*SubscribeError) XXX_DiscardUnknown 

func (m *SubscribeError) XXX_DiscardUnknown()

func (*SubscribeError) XXX_Marshal 

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

func (*SubscribeError) XXX_Merge 

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

func (*SubscribeError) XXX_Size 

func (m *SubscribeError) XXX_Size() int

func (*SubscribeError) XXX_Unmarshal 

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

type SubscriptionResult 

type SubscriptionResult struct {
	// Successful subscriptions
	Subscribed []string `protobuf:"bytes,1,rep,name=subscribed,proto3" json:"subscribed,omitempty"` // Deprecated: Do not use.
	// Faied subscriptions
	Failed []*SubscribeError `protobuf:"bytes,2,rep,name=failed,proto3" json:"failed,omitempty"`
	// Current status: list of the keys to which the client is now subscribed
	Status *SubscriptionStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// Successful subscriptions
	Subscriptions        []*client.ClientSubscription `protobuf:"bytes,4,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

SubscriptionResult is sent to clients after subscription to some key(s) is attempted. It happens after successful authentication (if authentication message contained initial subscriptions) as well as after ClientSubscribeMessage.

func (*SubscriptionResult) Descriptor 

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

func (*SubscriptionResult) GetFailed 

func (m *SubscriptionResult) GetFailed() []*SubscribeError

func (*SubscriptionResult) GetStatus 

func (m *SubscriptionResult) GetStatus() *SubscriptionStatus

func (*SubscriptionResult) GetSubscribed deprecated 

func (m *SubscriptionResult) GetSubscribed() []string

Deprecated: Do not use.

func (*SubscriptionResult) GetSubscriptions 

func (m *SubscriptionResult) GetSubscriptions() []*client.ClientSubscription

func (*SubscriptionResult) Marshal 

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

func (*SubscriptionResult) MarshalTo 

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

func (*SubscriptionResult) ProtoMessage 

func (*SubscriptionResult) ProtoMessage()

func (*SubscriptionResult) Reset 

func (m *SubscriptionResult) Reset()

func (*SubscriptionResult) Size 

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

func (*SubscriptionResult) String 

func (m *SubscriptionResult) String() string

func (*SubscriptionResult) Unmarshal 

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

func (*SubscriptionResult) XXX_DiscardUnknown 

func (m *SubscriptionResult) XXX_DiscardUnknown()

func (*SubscriptionResult) XXX_Marshal 

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

func (*SubscriptionResult) XXX_Merge 

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

func (*SubscriptionResult) XXX_Size 

func (m *SubscriptionResult) XXX_Size() int

func (*SubscriptionResult) XXX_Unmarshal 

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

type SubscriptionStatus 

type SubscriptionStatus struct {
	Keys                 []string                     `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` // Deprecated: Do not use.
	Subscriptions        []*client.ClientSubscription `protobuf:"bytes,2,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

SubscriptionStatus contains the key to which the client is subscribed right now. Sent as part of SubscriptionResult and UnsubscriptionResult.

func (*SubscriptionStatus) Descriptor 

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

func (*SubscriptionStatus) GetKeys deprecated 

func (m *SubscriptionStatus) GetKeys() []string

Deprecated: Do not use.

func (*SubscriptionStatus) GetSubscriptions 

func (m *SubscriptionStatus) GetSubscriptions() []*client.ClientSubscription

func (*SubscriptionStatus) Marshal 

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

func (*SubscriptionStatus) MarshalTo 

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

func (*SubscriptionStatus) ProtoMessage 

func (*SubscriptionStatus) ProtoMessage()

func (*SubscriptionStatus) Reset 

func (m *SubscriptionStatus) Reset()

func (*SubscriptionStatus) Size 

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

func (*SubscriptionStatus) String 

func (m *SubscriptionStatus) String() string

func (*SubscriptionStatus) Unmarshal 

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

func (*SubscriptionStatus) XXX_DiscardUnknown 

func (m *SubscriptionStatus) XXX_DiscardUnknown()

func (*SubscriptionStatus) XXX_Marshal 

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

func (*SubscriptionStatus) XXX_Merge 

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

func (*SubscriptionStatus) XXX_Size 

func (m *SubscriptionStatus) XXX_Size() int

func (*SubscriptionStatus) XXX_Unmarshal 

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

type UnsubscribeError 

type UnsubscribeError struct {
	Key                  string                     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Deprecated: Do not use.
	Error                string                     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Subscription         *client.ClientSubscription `protobuf:"bytes,3,opt,name=subscription,proto3" json:"subscription,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

UnsubscribeError represents an error of a single key: it contains the key and the error message explaining why unsubscription has failed. Sent as part of UnsubscriptionResult.

func (*UnsubscribeError) Descriptor 

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

func (*UnsubscribeError) GetError 

func (m *UnsubscribeError) GetError() string

func (*UnsubscribeError) GetKey deprecated 

func (m *UnsubscribeError) GetKey() string

Deprecated: Do not use.

func (*UnsubscribeError) GetSubscription 

func (m *UnsubscribeError) GetSubscription() *client.ClientSubscription

func (*UnsubscribeError) Marshal 

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

func (*UnsubscribeError) MarshalTo 

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

func (*UnsubscribeError) ProtoMessage 

func (*UnsubscribeError) ProtoMessage()

func (*UnsubscribeError) Reset 

func (m *UnsubscribeError) Reset()

func (*UnsubscribeError) Size 

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

func (*UnsubscribeError) String 

func (m *UnsubscribeError) String() string

func (*UnsubscribeError) Unmarshal 

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

func (*UnsubscribeError) XXX_DiscardUnknown 

func (m *UnsubscribeError) XXX_DiscardUnknown()

func (*UnsubscribeError) XXX_Marshal 

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

func (*UnsubscribeError) XXX_Merge 

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

func (*UnsubscribeError) XXX_Size 

func (m *UnsubscribeError) XXX_Size() int

func (*UnsubscribeError) XXX_Unmarshal 

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

type UnsubscriptionResult 

type UnsubscriptionResult struct {
	// Successful unsubscriptions
	Unsubscribed []string `protobuf:"bytes,1,rep,name=unsubscribed,proto3" json:"unsubscribed,omitempty"` // Deprecated: Do not use.
	// Faied unsubscriptions
	Failed []*UnsubscribeError `protobuf:"bytes,2,rep,name=failed,proto3" json:"failed,omitempty"`
	// Current status: list of the keys to which the client is now subscribed
	Status *SubscriptionStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// Successful unsubscriptions
	Subscriptions        []*client.ClientSubscription `protobuf:"bytes,4,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

UnsubscriptionResult is sent to clients in response to ClientUnsubscribeMessage.

func (*UnsubscriptionResult) Descriptor 

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

func (*UnsubscriptionResult) GetFailed 

func (m *UnsubscriptionResult) GetFailed() []*UnsubscribeError

func (*UnsubscriptionResult) GetStatus 

func (m *UnsubscriptionResult) GetStatus() *SubscriptionStatus

func (*UnsubscriptionResult) GetSubscriptions 

func (m *UnsubscriptionResult) GetSubscriptions() []*client.ClientSubscription

func (*UnsubscriptionResult) GetUnsubscribed deprecated 

func (m *UnsubscriptionResult) GetUnsubscribed() []string

Deprecated: Do not use.

func (*UnsubscriptionResult) Marshal 

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

func (*UnsubscriptionResult) MarshalTo 

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

func (*UnsubscriptionResult) ProtoMessage 

func (*UnsubscriptionResult) ProtoMessage()

func (*UnsubscriptionResult) Reset 

func (m *UnsubscriptionResult) Reset()

func (*UnsubscriptionResult) Size 

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

func (*UnsubscriptionResult) String 

func (m *UnsubscriptionResult) String() string

func (*UnsubscriptionResult) Unmarshal 

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

func (*UnsubscriptionResult) XXX_DiscardUnknown 

func (m *UnsubscriptionResult) XXX_DiscardUnknown()

func (*UnsubscriptionResult) XXX_Marshal 

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

func (*UnsubscriptionResult) XXX_Merge 

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

func (*UnsubscriptionResult) XXX_Size 

func (m *UnsubscriptionResult) XXX_Size() int

func (*UnsubscriptionResult) XXX_Unmarshal 

func (m *UnsubscriptionResult) 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.