pb

package
v0.0.71 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2019 License: MPL-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMessagesServiceServer 

func RegisterMessagesServiceServer(s *grpc.Server, srv MessagesServiceServer)

Types

type Client 

type Client struct {
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(conn *grpc.ClientConn) *Client

func (*Client) CreateStream 

func (c *Client) CreateStream(ctx context.Context, streamId string, shardCount int) error

func (*Client) GetMessages 

func (c *Client) GetMessages(ctx context.Context, streamId string, shardId string, fromOffset uint64, count int) (uint64, []*StoredMessage, error)

func (*Client) GetStream 

func (c *Client) GetStream(ctx context.Context, streamId string) (*StreamConfig, error)

func (*Client) GetStreamStatistics 

func (c *Client) GetStreamStatistics(ctx context.Context, streamId string) (*StreamStatistics, error)

func (*Client) ListStreams 

func (c *Client) ListStreams(ctx context.Context) ([]*StreamConfig, error)

func (*Client) Put 

func (c *Client) Put(ctx context.Context, streamId string, shardKey string, payload []byte) error

func (*Client) PutBatch 

func (c *Client) PutBatch(ctx context.Context, payload []MessageBatch) error

type MessageBatch 

type MessageBatch struct {
	StreamID string
	ShardKey string
	Payload  []byte
}

type MessageCreateStreamInput 

type MessageCreateStreamInput struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	ShardCount           int64    `protobuf:"varint,2,opt,name=ShardCount,proto3" json:"ShardCount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessageCreateStreamInput) Descriptor 

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

func (*MessageCreateStreamInput) GetID 

func (m *MessageCreateStreamInput) GetID() string

func (*MessageCreateStreamInput) GetShardCount 

func (m *MessageCreateStreamInput) GetShardCount() int64

func (*MessageCreateStreamInput) ProtoMessage 

func (*MessageCreateStreamInput) ProtoMessage()

func (*MessageCreateStreamInput) Reset 

func (m *MessageCreateStreamInput) Reset()

func (*MessageCreateStreamInput) String 

func (m *MessageCreateStreamInput) String() string

func (*MessageCreateStreamInput) XXX_DiscardUnknown 

func (m *MessageCreateStreamInput) XXX_DiscardUnknown()

func (*MessageCreateStreamInput) XXX_Marshal 

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

func (*MessageCreateStreamInput) XXX_Merge 

func (m *MessageCreateStreamInput) XXX_Merge(src proto.Message)

func (*MessageCreateStreamInput) XXX_Size 

func (m *MessageCreateStreamInput) XXX_Size() int

func (*MessageCreateStreamInput) XXX_Unmarshal 

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

type MessageCreateStreamOutput 

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

func (*MessageCreateStreamOutput) Descriptor 

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

func (*MessageCreateStreamOutput) ProtoMessage 

func (*MessageCreateStreamOutput) ProtoMessage()

func (*MessageCreateStreamOutput) Reset 

func (m *MessageCreateStreamOutput) Reset()

func (*MessageCreateStreamOutput) String 

func (m *MessageCreateStreamOutput) String() string

func (*MessageCreateStreamOutput) XXX_DiscardUnknown 

func (m *MessageCreateStreamOutput) XXX_DiscardUnknown()

func (*MessageCreateStreamOutput) XXX_Marshal 

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

func (*MessageCreateStreamOutput) XXX_Merge 

func (m *MessageCreateStreamOutput) XXX_Merge(src proto.Message)

func (*MessageCreateStreamOutput) XXX_Size 

func (m *MessageCreateStreamOutput) XXX_Size() int

func (*MessageCreateStreamOutput) XXX_Unmarshal 

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

type MessageDeleteStreamInput 

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

func (*MessageDeleteStreamInput) Descriptor 

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

func (*MessageDeleteStreamInput) GetID 

func (m *MessageDeleteStreamInput) GetID() string

func (*MessageDeleteStreamInput) ProtoMessage 

func (*MessageDeleteStreamInput) ProtoMessage()

func (*MessageDeleteStreamInput) Reset 

func (m *MessageDeleteStreamInput) Reset()

func (*MessageDeleteStreamInput) String 

func (m *MessageDeleteStreamInput) String() string

func (*MessageDeleteStreamInput) XXX_DiscardUnknown 

func (m *MessageDeleteStreamInput) XXX_DiscardUnknown()

func (*MessageDeleteStreamInput) XXX_Marshal 

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

func (*MessageDeleteStreamInput) XXX_Merge 

func (m *MessageDeleteStreamInput) XXX_Merge(src proto.Message)

func (*MessageDeleteStreamInput) XXX_Size 

func (m *MessageDeleteStreamInput) XXX_Size() int

func (*MessageDeleteStreamInput) XXX_Unmarshal 

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

type MessageDeleteStreamOutput 

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

func (*MessageDeleteStreamOutput) Descriptor 

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

func (*MessageDeleteStreamOutput) ProtoMessage 

func (*MessageDeleteStreamOutput) ProtoMessage()

func (*MessageDeleteStreamOutput) Reset 

func (m *MessageDeleteStreamOutput) Reset()

func (*MessageDeleteStreamOutput) String 

func (m *MessageDeleteStreamOutput) String() string

func (*MessageDeleteStreamOutput) XXX_DiscardUnknown 

func (m *MessageDeleteStreamOutput) XXX_DiscardUnknown()

func (*MessageDeleteStreamOutput) XXX_Marshal 

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

func (*MessageDeleteStreamOutput) XXX_Merge 

func (m *MessageDeleteStreamOutput) XXX_Merge(src proto.Message)

func (*MessageDeleteStreamOutput) XXX_Size 

func (m *MessageDeleteStreamOutput) XXX_Size() int

func (*MessageDeleteStreamOutput) XXX_Unmarshal 

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

type MessageGetMessagesInput 

type MessageGetMessagesInput struct {
	StreamID             string   `protobuf:"bytes,1,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	ShardID              string   `protobuf:"bytes,2,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	Offset               uint64   `protobuf:"varint,3,opt,name=Offset,proto3" json:"Offset,omitempty"`
	MaxCount             uint64   `protobuf:"varint,4,opt,name=MaxCount,proto3" json:"MaxCount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessageGetMessagesInput) Descriptor 

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

func (*MessageGetMessagesInput) GetMaxCount 

func (m *MessageGetMessagesInput) GetMaxCount() uint64

func (*MessageGetMessagesInput) GetOffset 

func (m *MessageGetMessagesInput) GetOffset() uint64

func (*MessageGetMessagesInput) GetShardID 

func (m *MessageGetMessagesInput) GetShardID() string

func (*MessageGetMessagesInput) GetStreamID 

func (m *MessageGetMessagesInput) GetStreamID() string

func (*MessageGetMessagesInput) ProtoMessage 

func (*MessageGetMessagesInput) ProtoMessage()

func (*MessageGetMessagesInput) Reset 

func (m *MessageGetMessagesInput) Reset()

func (*MessageGetMessagesInput) String 

func (m *MessageGetMessagesInput) String() string

func (*MessageGetMessagesInput) XXX_DiscardUnknown 

func (m *MessageGetMessagesInput) XXX_DiscardUnknown()

func (*MessageGetMessagesInput) XXX_Marshal 

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

func (*MessageGetMessagesInput) XXX_Merge 

func (m *MessageGetMessagesInput) XXX_Merge(src proto.Message)

func (*MessageGetMessagesInput) XXX_Size 

func (m *MessageGetMessagesInput) XXX_Size() int

func (*MessageGetMessagesInput) XXX_Unmarshal 

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

type MessageGetMessagesOutput 

type MessageGetMessagesOutput struct {
	StreamID             string           `protobuf:"bytes,1,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	ShardID              string           `protobuf:"bytes,2,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	NextOffset           uint64           `protobuf:"varint,3,opt,name=NextOffset,proto3" json:"NextOffset,omitempty"`
	Messages             []*StoredMessage `protobuf:"bytes,4,rep,name=Messages,proto3" json:"Messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*MessageGetMessagesOutput) Descriptor 

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

func (*MessageGetMessagesOutput) GetMessages 

func (m *MessageGetMessagesOutput) GetMessages() []*StoredMessage

func (*MessageGetMessagesOutput) GetNextOffset 

func (m *MessageGetMessagesOutput) GetNextOffset() uint64

func (*MessageGetMessagesOutput) GetShardID 

func (m *MessageGetMessagesOutput) GetShardID() string

func (*MessageGetMessagesOutput) GetStreamID 

func (m *MessageGetMessagesOutput) GetStreamID() string

func (*MessageGetMessagesOutput) ProtoMessage 

func (*MessageGetMessagesOutput) ProtoMessage()

func (*MessageGetMessagesOutput) Reset 

func (m *MessageGetMessagesOutput) Reset()

func (*MessageGetMessagesOutput) String 

func (m *MessageGetMessagesOutput) String() string

func (*MessageGetMessagesOutput) XXX_DiscardUnknown 

func (m *MessageGetMessagesOutput) XXX_DiscardUnknown()

func (*MessageGetMessagesOutput) XXX_Marshal 

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

func (*MessageGetMessagesOutput) XXX_Merge 

func (m *MessageGetMessagesOutput) XXX_Merge(src proto.Message)

func (*MessageGetMessagesOutput) XXX_Size 

func (m *MessageGetMessagesOutput) XXX_Size() int

func (*MessageGetMessagesOutput) XXX_Unmarshal 

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

type MessageGetStreamInput 

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

func (*MessageGetStreamInput) Descriptor 

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

func (*MessageGetStreamInput) GetID 

func (m *MessageGetStreamInput) GetID() string

func (*MessageGetStreamInput) ProtoMessage 

func (*MessageGetStreamInput) ProtoMessage()

func (*MessageGetStreamInput) Reset 

func (m *MessageGetStreamInput) Reset()

func (*MessageGetStreamInput) String 

func (m *MessageGetStreamInput) String() string

func (*MessageGetStreamInput) XXX_DiscardUnknown 

func (m *MessageGetStreamInput) XXX_DiscardUnknown()

func (*MessageGetStreamInput) XXX_Marshal 

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

func (*MessageGetStreamInput) XXX_Merge 

func (m *MessageGetStreamInput) XXX_Merge(src proto.Message)

func (*MessageGetStreamInput) XXX_Size 

func (m *MessageGetStreamInput) XXX_Size() int

func (*MessageGetStreamInput) XXX_Unmarshal 

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

type MessageGetStreamOutput 

type MessageGetStreamOutput struct {
	ID                   string        `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Config               *StreamConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*MessageGetStreamOutput) Descriptor 

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

func (*MessageGetStreamOutput) GetConfig 

func (m *MessageGetStreamOutput) GetConfig() *StreamConfig

func (*MessageGetStreamOutput) GetID 

func (m *MessageGetStreamOutput) GetID() string

func (*MessageGetStreamOutput) ProtoMessage 

func (*MessageGetStreamOutput) ProtoMessage()

func (*MessageGetStreamOutput) Reset 

func (m *MessageGetStreamOutput) Reset()

func (*MessageGetStreamOutput) String 

func (m *MessageGetStreamOutput) String() string

func (*MessageGetStreamOutput) XXX_DiscardUnknown 

func (m *MessageGetStreamOutput) XXX_DiscardUnknown()

func (*MessageGetStreamOutput) XXX_Marshal 

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

func (*MessageGetStreamOutput) XXX_Merge 

func (m *MessageGetStreamOutput) XXX_Merge(src proto.Message)

func (*MessageGetStreamOutput) XXX_Size 

func (m *MessageGetStreamOutput) XXX_Size() int

func (*MessageGetStreamOutput) XXX_Unmarshal 

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

type MessageGetStreamStatisticsInput 

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

func (*MessageGetStreamStatisticsInput) Descriptor 

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

func (*MessageGetStreamStatisticsInput) GetID 

func (m *MessageGetStreamStatisticsInput) GetID() string

func (*MessageGetStreamStatisticsInput) ProtoMessage 

func (*MessageGetStreamStatisticsInput) ProtoMessage()

func (*MessageGetStreamStatisticsInput) Reset 

func (m *MessageGetStreamStatisticsInput) Reset()

func (*MessageGetStreamStatisticsInput) String 

func (m *MessageGetStreamStatisticsInput) String() string

func (*MessageGetStreamStatisticsInput) XXX_DiscardUnknown 

func (m *MessageGetStreamStatisticsInput) XXX_DiscardUnknown()

func (*MessageGetStreamStatisticsInput) XXX_Marshal 

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

func (*MessageGetStreamStatisticsInput) XXX_Merge 

func (m *MessageGetStreamStatisticsInput) XXX_Merge(src proto.Message)

func (*MessageGetStreamStatisticsInput) XXX_Size 

func (m *MessageGetStreamStatisticsInput) XXX_Size() int

func (*MessageGetStreamStatisticsInput) XXX_Unmarshal 

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

type MessageGetStreamStatisticsOutput 

type MessageGetStreamStatisticsOutput struct {
	ID                   string            `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Statistics           *StreamStatistics `protobuf:"bytes,2,opt,name=statistics,proto3" json:"statistics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*MessageGetStreamStatisticsOutput) Descriptor 

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

func (*MessageGetStreamStatisticsOutput) GetID 

func (m *MessageGetStreamStatisticsOutput) GetID() string

func (*MessageGetStreamStatisticsOutput) GetStatistics 

func (m *MessageGetStreamStatisticsOutput) GetStatistics() *StreamStatistics

func (*MessageGetStreamStatisticsOutput) ProtoMessage 

func (*MessageGetStreamStatisticsOutput) ProtoMessage()

func (*MessageGetStreamStatisticsOutput) Reset 

func (m *MessageGetStreamStatisticsOutput) Reset()

func (*MessageGetStreamStatisticsOutput) String 

func (m *MessageGetStreamStatisticsOutput) String() string

func (*MessageGetStreamStatisticsOutput) XXX_DiscardUnknown 

func (m *MessageGetStreamStatisticsOutput) XXX_DiscardUnknown()

func (*MessageGetStreamStatisticsOutput) XXX_Marshal 

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

func (*MessageGetStreamStatisticsOutput) XXX_Merge 

func (m *MessageGetStreamStatisticsOutput) XXX_Merge(src proto.Message)

func (*MessageGetStreamStatisticsOutput) XXX_Size 

func (m *MessageGetStreamStatisticsOutput) XXX_Size() int

func (*MessageGetStreamStatisticsOutput) XXX_Unmarshal 

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

type MessageListStreamInput 

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

func (*MessageListStreamInput) Descriptor 

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

func (*MessageListStreamInput) ProtoMessage 

func (*MessageListStreamInput) ProtoMessage()

func (*MessageListStreamInput) Reset 

func (m *MessageListStreamInput) Reset()

func (*MessageListStreamInput) String 

func (m *MessageListStreamInput) String() string

func (*MessageListStreamInput) XXX_DiscardUnknown 

func (m *MessageListStreamInput) XXX_DiscardUnknown()

func (*MessageListStreamInput) XXX_Marshal 

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

func (*MessageListStreamInput) XXX_Merge 

func (m *MessageListStreamInput) XXX_Merge(src proto.Message)

func (*MessageListStreamInput) XXX_Size 

func (m *MessageListStreamInput) XXX_Size() int

func (*MessageListStreamInput) XXX_Unmarshal 

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

type MessageListStreamOutput 

type MessageListStreamOutput struct {
	Streams              []*StreamConfig `protobuf:"bytes,1,rep,name=Streams,proto3" json:"Streams,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*MessageListStreamOutput) Descriptor 

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

func (*MessageListStreamOutput) GetStreams 

func (m *MessageListStreamOutput) GetStreams() []*StreamConfig

func (*MessageListStreamOutput) ProtoMessage 

func (*MessageListStreamOutput) ProtoMessage()

func (*MessageListStreamOutput) Reset 

func (m *MessageListStreamOutput) Reset()

func (*MessageListStreamOutput) String 

func (m *MessageListStreamOutput) String() string

func (*MessageListStreamOutput) XXX_DiscardUnknown 

func (m *MessageListStreamOutput) XXX_DiscardUnknown()

func (*MessageListStreamOutput) XXX_Marshal 

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

func (*MessageListStreamOutput) XXX_Merge 

func (m *MessageListStreamOutput) XXX_Merge(src proto.Message)

func (*MessageListStreamOutput) XXX_Size 

func (m *MessageListStreamOutput) XXX_Size() int

func (*MessageListStreamOutput) XXX_Unmarshal 

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

type MessagePutMessageBatchInput 

type MessagePutMessageBatchInput struct {
	Batches              []*MessagePutMessageInput `protobuf:"bytes,1,rep,name=Batches,proto3" json:"Batches,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*MessagePutMessageBatchInput) Descriptor 

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

func (*MessagePutMessageBatchInput) GetBatches 

func (m *MessagePutMessageBatchInput) GetBatches() []*MessagePutMessageInput

func (*MessagePutMessageBatchInput) ProtoMessage 

func (*MessagePutMessageBatchInput) ProtoMessage()

func (*MessagePutMessageBatchInput) Reset 

func (m *MessagePutMessageBatchInput) Reset()

func (*MessagePutMessageBatchInput) String 

func (m *MessagePutMessageBatchInput) String() string

func (*MessagePutMessageBatchInput) XXX_DiscardUnknown 

func (m *MessagePutMessageBatchInput) XXX_DiscardUnknown()

func (*MessagePutMessageBatchInput) XXX_Marshal 

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

func (*MessagePutMessageBatchInput) XXX_Merge 

func (m *MessagePutMessageBatchInput) XXX_Merge(src proto.Message)

func (*MessagePutMessageBatchInput) XXX_Size 

func (m *MessagePutMessageBatchInput) XXX_Size() int

func (*MessagePutMessageBatchInput) XXX_Unmarshal 

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

type MessagePutMessageBatchOutput 

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

func (*MessagePutMessageBatchOutput) Descriptor 

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

func (*MessagePutMessageBatchOutput) ProtoMessage 

func (*MessagePutMessageBatchOutput) ProtoMessage()

func (*MessagePutMessageBatchOutput) Reset 

func (m *MessagePutMessageBatchOutput) Reset()

func (*MessagePutMessageBatchOutput) String 

func (m *MessagePutMessageBatchOutput) String() string

func (*MessagePutMessageBatchOutput) XXX_DiscardUnknown 

func (m *MessagePutMessageBatchOutput) XXX_DiscardUnknown()

func (*MessagePutMessageBatchOutput) XXX_Marshal 

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

func (*MessagePutMessageBatchOutput) XXX_Merge 

func (m *MessagePutMessageBatchOutput) XXX_Merge(src proto.Message)

func (*MessagePutMessageBatchOutput) XXX_Size 

func (m *MessagePutMessageBatchOutput) XXX_Size() int

func (*MessagePutMessageBatchOutput) XXX_Unmarshal 

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

type MessagePutMessageInput 

type MessagePutMessageInput struct {
	StreamID             string   `protobuf:"bytes,1,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	ShardKey             string   `protobuf:"bytes,2,opt,name=ShardKey,proto3" json:"ShardKey,omitempty"`
	Payload              []byte   `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessagePutMessageInput) Descriptor 

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

func (*MessagePutMessageInput) GetPayload 

func (m *MessagePutMessageInput) GetPayload() []byte

func (*MessagePutMessageInput) GetShardKey 

func (m *MessagePutMessageInput) GetShardKey() string

func (*MessagePutMessageInput) GetStreamID 

func (m *MessagePutMessageInput) GetStreamID() string

func (*MessagePutMessageInput) ProtoMessage 

func (*MessagePutMessageInput) ProtoMessage()

func (*MessagePutMessageInput) Reset 

func (m *MessagePutMessageInput) Reset()

func (*MessagePutMessageInput) String 

func (m *MessagePutMessageInput) String() string

func (*MessagePutMessageInput) XXX_DiscardUnknown 

func (m *MessagePutMessageInput) XXX_DiscardUnknown()

func (*MessagePutMessageInput) XXX_Marshal 

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

func (*MessagePutMessageInput) XXX_Merge 

func (m *MessagePutMessageInput) XXX_Merge(src proto.Message)

func (*MessagePutMessageInput) XXX_Size 

func (m *MessagePutMessageInput) XXX_Size() int

func (*MessagePutMessageInput) XXX_Unmarshal 

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

type MessagePutMessageOutput 

type MessagePutMessageOutput struct {
	StreamID             string   `protobuf:"bytes,1,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	ShardID              string   `protobuf:"bytes,2,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	Offset               uint64   `protobuf:"varint,3,opt,name=Offset,proto3" json:"Offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessagePutMessageOutput) Descriptor 

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

func (*MessagePutMessageOutput) GetOffset 

func (m *MessagePutMessageOutput) GetOffset() uint64

func (*MessagePutMessageOutput) GetShardID 

func (m *MessagePutMessageOutput) GetShardID() string

func (*MessagePutMessageOutput) GetStreamID 

func (m *MessagePutMessageOutput) GetStreamID() string

func (*MessagePutMessageOutput) ProtoMessage 

func (*MessagePutMessageOutput) ProtoMessage()

func (*MessagePutMessageOutput) Reset 

func (m *MessagePutMessageOutput) Reset()

func (*MessagePutMessageOutput) String 

func (m *MessagePutMessageOutput) String() string

func (*MessagePutMessageOutput) XXX_DiscardUnknown 

func (m *MessagePutMessageOutput) XXX_DiscardUnknown()

func (*MessagePutMessageOutput) XXX_Marshal 

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

func (*MessagePutMessageOutput) XXX_Merge 

func (m *MessagePutMessageOutput) XXX_Merge(src proto.Message)

func (*MessagePutMessageOutput) XXX_Size 

func (m *MessagePutMessageOutput) XXX_Size() int

func (*MessagePutMessageOutput) XXX_Unmarshal 

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

type MessagesServiceClient 

type MessagesServiceClient interface {
	CreateStream(ctx context.Context, in *MessageCreateStreamInput, opts ...grpc.CallOption) (*MessageCreateStreamOutput, error)
	DeleteStream(ctx context.Context, in *MessageDeleteStreamInput, opts ...grpc.CallOption) (*MessageDeleteStreamOutput, error)
	ListStreams(ctx context.Context, in *MessageListStreamInput, opts ...grpc.CallOption) (*MessageListStreamOutput, error)
	GetStream(ctx context.Context, in *MessageGetStreamInput, opts ...grpc.CallOption) (*MessageGetStreamOutput, error)
	GetStreamStatistics(ctx context.Context, in *MessageGetStreamStatisticsInput, opts ...grpc.CallOption) (*MessageGetStreamStatisticsOutput, error)
	GetMessages(ctx context.Context, in *MessageGetMessagesInput, opts ...grpc.CallOption) (*MessageGetMessagesOutput, error)
	PutMessage(ctx context.Context, in *MessagePutMessageInput, opts ...grpc.CallOption) (*MessagePutMessageOutput, error)
	PutMessageBatch(ctx context.Context, in *MessagePutMessageBatchInput, opts ...grpc.CallOption) (*MessagePutMessageBatchOutput, error)
}

MessagesServiceClient is the client API for MessagesService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMessagesServiceClient 

func NewMessagesServiceClient(cc *grpc.ClientConn) MessagesServiceClient

type MessagesServiceServer 

type MessagesServiceServer interface {
	CreateStream(context.Context, *MessageCreateStreamInput) (*MessageCreateStreamOutput, error)
	DeleteStream(context.Context, *MessageDeleteStreamInput) (*MessageDeleteStreamOutput, error)
	ListStreams(context.Context, *MessageListStreamInput) (*MessageListStreamOutput, error)
	GetStream(context.Context, *MessageGetStreamInput) (*MessageGetStreamOutput, error)
	GetStreamStatistics(context.Context, *MessageGetStreamStatisticsInput) (*MessageGetStreamStatisticsOutput, error)
	GetMessages(context.Context, *MessageGetMessagesInput) (*MessageGetMessagesOutput, error)
	PutMessage(context.Context, *MessagePutMessageInput) (*MessagePutMessageOutput, error)
	PutMessageBatch(context.Context, *MessagePutMessageBatchInput) (*MessagePutMessageBatchOutput, error)
}

MessagesServiceServer is the server API for MessagesService service.

type MessagesStateTransition 

type MessagesStateTransition struct {
	// Types that are valid to be assigned to Event:
	//	*MessagesStateTransition_MessagePut
	//	*MessagesStateTransition_StreamCreated
	//	*MessagesStateTransition_StreamDeleted
	Event                isMessagesStateTransition_Event `protobuf_oneof:"Event"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*MessagesStateTransition) Descriptor 

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

func (*MessagesStateTransition) GetEvent 

func (m *MessagesStateTransition) GetEvent() isMessagesStateTransition_Event

func (*MessagesStateTransition) GetMessagePut 

func (m *MessagesStateTransition) GetMessagePut() *MessagesStateTransitionMessagePut

func (*MessagesStateTransition) GetStreamCreated 

func (m *MessagesStateTransition) GetStreamCreated() *MessagesStateTransitionStreamCreated

func (*MessagesStateTransition) GetStreamDeleted 

func (m *MessagesStateTransition) GetStreamDeleted() *MessagesStateTransitionStreamDeleted

func (*MessagesStateTransition) ProtoMessage 

func (*MessagesStateTransition) ProtoMessage()

func (*MessagesStateTransition) Reset 

func (m *MessagesStateTransition) Reset()

func (*MessagesStateTransition) String 

func (m *MessagesStateTransition) String() string

func (*MessagesStateTransition) XXX_DiscardUnknown 

func (m *MessagesStateTransition) XXX_DiscardUnknown()

func (*MessagesStateTransition) XXX_Marshal 

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

func (*MessagesStateTransition) XXX_Merge 

func (m *MessagesStateTransition) XXX_Merge(src proto.Message)

func (*MessagesStateTransition) XXX_OneofWrappers 

func (*MessagesStateTransition) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*MessagesStateTransition) XXX_Size 

func (m *MessagesStateTransition) XXX_Size() int

func (*MessagesStateTransition) XXX_Unmarshal 

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

type MessagesStateTransitionMessagePut 

type MessagesStateTransitionMessagePut struct {
	StreamID             string   `protobuf:"bytes,1,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	ShardID              string   `protobuf:"bytes,2,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	Offset               uint64   `protobuf:"varint,3,opt,name=Offset,proto3" json:"Offset,omitempty"`
	Payload              []byte   `protobuf:"bytes,4,opt,name=Payload,proto3" json:"Payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessagesStateTransitionMessagePut) Descriptor 

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

func (*MessagesStateTransitionMessagePut) GetOffset 

func (m *MessagesStateTransitionMessagePut) GetOffset() uint64

func (*MessagesStateTransitionMessagePut) GetPayload 

func (m *MessagesStateTransitionMessagePut) GetPayload() []byte

func (*MessagesStateTransitionMessagePut) GetShardID 

func (m *MessagesStateTransitionMessagePut) GetShardID() string

func (*MessagesStateTransitionMessagePut) GetStreamID 

func (m *MessagesStateTransitionMessagePut) GetStreamID() string

func (*MessagesStateTransitionMessagePut) ProtoMessage 

func (*MessagesStateTransitionMessagePut) ProtoMessage()

func (*MessagesStateTransitionMessagePut) Reset 

func (m *MessagesStateTransitionMessagePut) Reset()

func (*MessagesStateTransitionMessagePut) String 

func (m *MessagesStateTransitionMessagePut) String() string

func (*MessagesStateTransitionMessagePut) XXX_DiscardUnknown 

func (m *MessagesStateTransitionMessagePut) XXX_DiscardUnknown()

func (*MessagesStateTransitionMessagePut) XXX_Marshal 

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

func (*MessagesStateTransitionMessagePut) XXX_Merge 

func (m *MessagesStateTransitionMessagePut) XXX_Merge(src proto.Message)

func (*MessagesStateTransitionMessagePut) XXX_Size 

func (m *MessagesStateTransitionMessagePut) XXX_Size() int

func (*MessagesStateTransitionMessagePut) XXX_Unmarshal 

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

type MessagesStateTransitionSet 

type MessagesStateTransitionSet struct {
	Events               []*MessagesStateTransition `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*MessagesStateTransitionSet) Descriptor 

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

func (*MessagesStateTransitionSet) GetEvents 

func (m *MessagesStateTransitionSet) GetEvents() []*MessagesStateTransition

func (*MessagesStateTransitionSet) ProtoMessage 

func (*MessagesStateTransitionSet) ProtoMessage()

func (*MessagesStateTransitionSet) Reset 

func (m *MessagesStateTransitionSet) Reset()

func (*MessagesStateTransitionSet) String 

func (m *MessagesStateTransitionSet) String() string

func (*MessagesStateTransitionSet) XXX_DiscardUnknown 

func (m *MessagesStateTransitionSet) XXX_DiscardUnknown()

func (*MessagesStateTransitionSet) XXX_Marshal 

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

func (*MessagesStateTransitionSet) XXX_Merge 

func (m *MessagesStateTransitionSet) XXX_Merge(src proto.Message)

func (*MessagesStateTransitionSet) XXX_Size 

func (m *MessagesStateTransitionSet) XXX_Size() int

func (*MessagesStateTransitionSet) XXX_Unmarshal 

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

type MessagesStateTransitionStreamCreated 

type MessagesStateTransitionStreamCreated struct {
	Config               *StreamConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*MessagesStateTransitionStreamCreated) Descriptor 

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

func (*MessagesStateTransitionStreamCreated) GetConfig 

func (m *MessagesStateTransitionStreamCreated) GetConfig() *StreamConfig

func (*MessagesStateTransitionStreamCreated) ProtoMessage 

func (*MessagesStateTransitionStreamCreated) ProtoMessage()

func (*MessagesStateTransitionStreamCreated) Reset 

func (m *MessagesStateTransitionStreamCreated) Reset()

func (*MessagesStateTransitionStreamCreated) String 

func (m *MessagesStateTransitionStreamCreated) String() string

func (*MessagesStateTransitionStreamCreated) XXX_DiscardUnknown 

func (m *MessagesStateTransitionStreamCreated) XXX_DiscardUnknown()

func (*MessagesStateTransitionStreamCreated) XXX_Marshal 

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

func (*MessagesStateTransitionStreamCreated) XXX_Merge 

func (m *MessagesStateTransitionStreamCreated) XXX_Merge(src proto.Message)

func (*MessagesStateTransitionStreamCreated) XXX_Size 

func (m *MessagesStateTransitionStreamCreated) XXX_Size() int

func (*MessagesStateTransitionStreamCreated) XXX_Unmarshal 

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

type MessagesStateTransitionStreamDeleted 

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

func (*MessagesStateTransitionStreamDeleted) Descriptor 

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

func (*MessagesStateTransitionStreamDeleted) GetStreamID 

func (m *MessagesStateTransitionStreamDeleted) GetStreamID() string

func (*MessagesStateTransitionStreamDeleted) ProtoMessage 

func (*MessagesStateTransitionStreamDeleted) ProtoMessage()

func (*MessagesStateTransitionStreamDeleted) Reset 

func (m *MessagesStateTransitionStreamDeleted) Reset()

func (*MessagesStateTransitionStreamDeleted) String 

func (m *MessagesStateTransitionStreamDeleted) String() string

func (*MessagesStateTransitionStreamDeleted) XXX_DiscardUnknown 

func (m *MessagesStateTransitionStreamDeleted) XXX_DiscardUnknown()

func (*MessagesStateTransitionStreamDeleted) XXX_Marshal 

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

func (*MessagesStateTransitionStreamDeleted) XXX_Merge 

func (m *MessagesStateTransitionStreamDeleted) XXX_Merge(src proto.Message)

func (*MessagesStateTransitionStreamDeleted) XXX_Size 

func (m *MessagesStateTransitionStreamDeleted) XXX_Size() int

func (*MessagesStateTransitionStreamDeleted) XXX_Unmarshal 

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

type MessagesStateTransition_MessagePut 

type MessagesStateTransition_MessagePut struct {
	MessagePut *MessagesStateTransitionMessagePut `protobuf:"bytes,2,opt,name=MessagePut,proto3,oneof"`
}

type MessagesStateTransition_StreamCreated 

type MessagesStateTransition_StreamCreated struct {
	StreamCreated *MessagesStateTransitionStreamCreated `protobuf:"bytes,3,opt,name=StreamCreated,proto3,oneof"`
}

type MessagesStateTransition_StreamDeleted 

type MessagesStateTransition_StreamDeleted struct {
	StreamDeleted *MessagesStateTransitionStreamDeleted `protobuf:"bytes,4,opt,name=StreamDeleted,proto3,oneof"`
}

type ShardStatistics 

type ShardStatistics struct {
	StreamID             string   `protobuf:"bytes,1,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	ShardID              string   `protobuf:"bytes,2,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	StoredBytes          int64    `protobuf:"varint,3,opt,name=StoredBytes,proto3" json:"StoredBytes,omitempty"`
	StoredRecordCount    int64    `protobuf:"varint,4,opt,name=StoredRecordCount,proto3" json:"StoredRecordCount,omitempty"`
	CurrentOffset        uint64   `protobuf:"varint,5,opt,name=CurrentOffset,proto3" json:"CurrentOffset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShardStatistics) Descriptor 

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

func (*ShardStatistics) GetCurrentOffset 

func (m *ShardStatistics) GetCurrentOffset() uint64

func (*ShardStatistics) GetShardID 

func (m *ShardStatistics) GetShardID() string

func (*ShardStatistics) GetStoredBytes 

func (m *ShardStatistics) GetStoredBytes() int64

func (*ShardStatistics) GetStoredRecordCount 

func (m *ShardStatistics) GetStoredRecordCount() int64

func (*ShardStatistics) GetStreamID 

func (m *ShardStatistics) GetStreamID() string

func (*ShardStatistics) ProtoMessage 

func (*ShardStatistics) ProtoMessage()

func (*ShardStatistics) Reset 

func (m *ShardStatistics) Reset()

func (*ShardStatistics) String 

func (m *ShardStatistics) String() string

func (*ShardStatistics) XXX_DiscardUnknown 

func (m *ShardStatistics) XXX_DiscardUnknown()

func (*ShardStatistics) XXX_Marshal 

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

func (*ShardStatistics) XXX_Merge 

func (m *ShardStatistics) XXX_Merge(src proto.Message)

func (*ShardStatistics) XXX_Size 

func (m *ShardStatistics) XXX_Size() int

func (*ShardStatistics) XXX_Unmarshal 

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

type StoredMessage 

type StoredMessage struct {
	Offset               uint64   `protobuf:"varint,1,opt,name=Offset,proto3" json:"Offset,omitempty"`
	Payload              []byte   `protobuf:"bytes,2,opt,name=Payload,proto3" json:"Payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StoredMessage) Descriptor 

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

func (*StoredMessage) GetOffset 

func (m *StoredMessage) GetOffset() uint64

func (*StoredMessage) GetPayload 

func (m *StoredMessage) GetPayload() []byte

func (*StoredMessage) ProtoMessage 

func (*StoredMessage) ProtoMessage()

func (*StoredMessage) Reset 

func (m *StoredMessage) Reset()

func (*StoredMessage) String 

func (m *StoredMessage) String() string

func (*StoredMessage) XXX_DiscardUnknown 

func (m *StoredMessage) XXX_DiscardUnknown()

func (*StoredMessage) XXX_Marshal 

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

func (*StoredMessage) XXX_Merge 

func (m *StoredMessage) XXX_Merge(src proto.Message)

func (*StoredMessage) XXX_Size 

func (m *StoredMessage) XXX_Size() int

func (*StoredMessage) XXX_Unmarshal 

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

type StreamConfig 

type StreamConfig struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	ShardIDs             []string `protobuf:"bytes,2,rep,name=ShardIDs,proto3" json:"ShardIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamConfig) Descriptor 

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

func (*StreamConfig) GetID 

func (m *StreamConfig) GetID() string

func (*StreamConfig) GetShardIDs 

func (m *StreamConfig) GetShardIDs() []string

func (*StreamConfig) ProtoMessage 

func (*StreamConfig) ProtoMessage()

func (*StreamConfig) Reset 

func (m *StreamConfig) Reset()

func (*StreamConfig) String 

func (m *StreamConfig) String() string

func (*StreamConfig) XXX_DiscardUnknown 

func (m *StreamConfig) XXX_DiscardUnknown()

func (*StreamConfig) XXX_Marshal 

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

func (*StreamConfig) XXX_Merge 

func (m *StreamConfig) XXX_Merge(src proto.Message)

func (*StreamConfig) XXX_Size 

func (m *StreamConfig) XXX_Size() int

func (*StreamConfig) XXX_Unmarshal 

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

type StreamStatistics 

type StreamStatistics struct {
	ID                   string             `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	ShardStatistics      []*ShardStatistics `protobuf:"bytes,2,rep,name=ShardStatistics,proto3" json:"ShardStatistics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*StreamStatistics) Descriptor 

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

func (*StreamStatistics) GetID 

func (m *StreamStatistics) GetID() string

func (*StreamStatistics) GetShardStatistics 

func (m *StreamStatistics) GetShardStatistics() []*ShardStatistics

func (*StreamStatistics) ProtoMessage 

func (*StreamStatistics) ProtoMessage()

func (*StreamStatistics) Reset 

func (m *StreamStatistics) Reset()

func (*StreamStatistics) String 

func (m *StreamStatistics) String() string

func (*StreamStatistics) XXX_DiscardUnknown 

func (m *StreamStatistics) XXX_DiscardUnknown()

func (*StreamStatistics) XXX_Marshal 

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

func (*StreamStatistics) XXX_Merge 

func (m *StreamStatistics) XXX_Merge(src proto.Message)

func (*StreamStatistics) XXX_Size 

func (m *StreamStatistics) XXX_Size() int

func (*StreamStatistics) XXX_Unmarshal 

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

type UnimplementedMessagesServiceServer 

type UnimplementedMessagesServiceServer struct {
}

UnimplementedMessagesServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMessagesServiceServer) CreateStream 

func (*UnimplementedMessagesServiceServer) CreateStream(ctx context.Context, req *MessageCreateStreamInput) (*MessageCreateStreamOutput, error)

func (*UnimplementedMessagesServiceServer) DeleteStream 

func (*UnimplementedMessagesServiceServer) DeleteStream(ctx context.Context, req *MessageDeleteStreamInput) (*MessageDeleteStreamOutput, error)

func (*UnimplementedMessagesServiceServer) GetMessages 

func (*UnimplementedMessagesServiceServer) GetMessages(ctx context.Context, req *MessageGetMessagesInput) (*MessageGetMessagesOutput, error)

func (*UnimplementedMessagesServiceServer) GetStream 

func (*UnimplementedMessagesServiceServer) GetStream(ctx context.Context, req *MessageGetStreamInput) (*MessageGetStreamOutput, error)

func (*UnimplementedMessagesServiceServer) GetStreamStatistics 

func (*UnimplementedMessagesServiceServer) GetStreamStatistics(ctx context.Context, req *MessageGetStreamStatisticsInput) (*MessageGetStreamStatisticsOutput, error)

func (*UnimplementedMessagesServiceServer) ListStreams 

func (*UnimplementedMessagesServiceServer) ListStreams(ctx context.Context, req *MessageListStreamInput) (*MessageListStreamOutput, error)

func (*UnimplementedMessagesServiceServer) PutMessage 

func (*UnimplementedMessagesServiceServer) PutMessage(ctx context.Context, req *MessagePutMessageInput) (*MessagePutMessageOutput, error)

func (*UnimplementedMessagesServiceServer) PutMessageBatch 

func (*UnimplementedMessagesServiceServer) PutMessageBatch(ctx context.Context, req *MessagePutMessageBatchInput) (*MessagePutMessageBatchOutput, 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.