proto

package

Go to main page

Versions in this module

v1

v1.9.3

Sep 7, 2020

v1.9.2

Sep 2, 2020

Changes in this version

type Ack

+ CommitTimestamp int64

+ ReceptionTimestamp int64

+ func (m *Ack) GetCommitTimestamp() int64

+ func (m *Ack) GetReceptionTimestamp() int64

type SubscribeRequest

+ Resume bool

+ func (m *SubscribeRequest) GetResume() bool

v1.9.1

Aug 25, 2020

Changes in this version

type APIClient

+ SetStreamReadonly func(ctx context.Context, in *SetStreamReadonlyRequest, opts ...grpc.CallOption) (*SetStreamReadonlyResponse, error)

type APIServer

+ SetStreamReadonly func(context.Context, *SetStreamReadonlyRequest) (*SetStreamReadonlyResponse, error)

type ActivityStreamEvent

+ SetStreamReadonlyOp *SetStreamReadonlyOp

+ func (m *ActivityStreamEvent) GetSetStreamReadonlyOp() *SetStreamReadonlyOp

type ActivityStreamOp

+ const ActivityStreamOp_SET_STREAM_READONLY

type PartitionMetadata

+ HighWatermark int64

+ NewestOffset int64

+ Paused bool

+ func (m *PartitionMetadata) GetHighWatermark() int64

+ func (m *PartitionMetadata) GetNewestOffset() int64

+ func (m *PartitionMetadata) GetPaused() bool

+ type SetStreamReadonlyOp struct

+ Partitions []int32

+ Readonly bool

+ Stream string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetStreamReadonlyOp) Descriptor() ([]byte, []int)

+ func (*SetStreamReadonlyOp) ProtoMessage()

+ func (m *SetStreamReadonlyOp) GetPartitions() []int32

+ func (m *SetStreamReadonlyOp) GetReadonly() bool

+ func (m *SetStreamReadonlyOp) GetStream() string

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

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

+ func (m *SetStreamReadonlyOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SetStreamReadonlyOp) Reset()

+ func (m *SetStreamReadonlyOp) Size() (n int)

+ func (m *SetStreamReadonlyOp) String() string

+ func (m *SetStreamReadonlyOp) Unmarshal(dAtA []byte) error

+ func (m *SetStreamReadonlyOp) XXX_DiscardUnknown()

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

+ func (m *SetStreamReadonlyOp) XXX_Merge(src proto.Message)

+ func (m *SetStreamReadonlyOp) XXX_Size() int

+ func (m *SetStreamReadonlyOp) XXX_Unmarshal(b []byte) error

+ type SetStreamReadonlyRequest struct

+ Name string

+ Partitions []int32

+ Readonly bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetStreamReadonlyRequest) Descriptor() ([]byte, []int)

+ func (*SetStreamReadonlyRequest) ProtoMessage()

+ func (m *SetStreamReadonlyRequest) GetName() string

+ func (m *SetStreamReadonlyRequest) GetPartitions() []int32

+ func (m *SetStreamReadonlyRequest) GetReadonly() bool

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

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

+ func (m *SetStreamReadonlyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SetStreamReadonlyRequest) Reset()

+ func (m *SetStreamReadonlyRequest) Size() (n int)

+ func (m *SetStreamReadonlyRequest) String() string

+ func (m *SetStreamReadonlyRequest) Unmarshal(dAtA []byte) error

+ func (m *SetStreamReadonlyRequest) XXX_DiscardUnknown()

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

+ func (m *SetStreamReadonlyRequest) XXX_Merge(src proto.Message)

+ func (m *SetStreamReadonlyRequest) XXX_Size() int

+ func (m *SetStreamReadonlyRequest) XXX_Unmarshal(b []byte) error

+ type SetStreamReadonlyResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetStreamReadonlyResponse) Descriptor() ([]byte, []int)

+ func (*SetStreamReadonlyResponse) ProtoMessage()

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

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

+ func (m *SetStreamReadonlyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SetStreamReadonlyResponse) Reset()

+ func (m *SetStreamReadonlyResponse) Size() (n int)

+ func (m *SetStreamReadonlyResponse) String() string

+ func (m *SetStreamReadonlyResponse) Unmarshal(dAtA []byte) error

+ func (m *SetStreamReadonlyResponse) XXX_DiscardUnknown()

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

+ func (m *SetStreamReadonlyResponse) XXX_Merge(src proto.Message)

+ func (m *SetStreamReadonlyResponse) XXX_Size() int

+ func (m *SetStreamReadonlyResponse) XXX_Unmarshal(b []byte) error

type UnimplementedAPIServer

+ func (*UnimplementedAPIServer) SetStreamReadonly(ctx context.Context, req *SetStreamReadonlyRequest) (*SetStreamReadonlyResponse, error)

v1.1.0

Jul 16, 2020

Changes in this version

+ var ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group")

type APIClient

+ PublishAsync func(ctx context.Context, opts ...grpc.CallOption) (API_PublishAsyncClient, error)

type APIServer

+ PublishAsync func(API_PublishAsyncServer) error

+ type API_PublishAsyncClient interface

+ Recv func() (*PublishResponse, error)

+ Send func(*PublishRequest) error

+ type API_PublishAsyncServer interface

+ Recv func() (*PublishRequest, error)

+ Send func(*PublishResponse) error

type Ack

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Ack) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ack) XXX_DiscardUnknown()

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

+ func (m *Ack) XXX_Merge(src proto.Message)

+ func (m *Ack) XXX_Size() int

+ func (m *Ack) XXX_Unmarshal(b []byte) error

type ActivityStreamEvent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ActivityStreamEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ActivityStreamEvent) XXX_DiscardUnknown()

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

+ func (m *ActivityStreamEvent) XXX_Merge(src proto.Message)

+ func (m *ActivityStreamEvent) XXX_Size() int

+ func (m *ActivityStreamEvent) XXX_Unmarshal(b []byte) error

type Broker

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Broker) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Broker) XXX_DiscardUnknown()

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

+ func (m *Broker) XXX_Merge(src proto.Message)

+ func (m *Broker) XXX_Size() int

+ func (m *Broker) XXX_Unmarshal(b []byte) error

type CreateStreamOp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *CreateStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CreateStreamOp) XXX_DiscardUnknown()

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

+ func (m *CreateStreamOp) XXX_Merge(src proto.Message)

+ func (m *CreateStreamOp) XXX_Size() int

+ func (m *CreateStreamOp) XXX_Unmarshal(b []byte) error

type CreateStreamRequest

+ CleanerInterval *NullableInt64

+ CompactEnabled *NullableBool

+ CompactMaxGoroutines *NullableInt32

+ RetentionMaxAge *NullableInt64

+ RetentionMaxBytes *NullableInt64

+ RetentionMaxMessages *NullableInt64

+ SegmentMaxAge *NullableInt64

+ SegmentMaxBytes *NullableInt64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *CreateStreamRequest) GetCleanerInterval() *NullableInt64

+ func (m *CreateStreamRequest) GetCompactEnabled() *NullableBool

+ func (m *CreateStreamRequest) GetCompactMaxGoroutines() *NullableInt32

+ func (m *CreateStreamRequest) GetRetentionMaxAge() *NullableInt64

+ func (m *CreateStreamRequest) GetRetentionMaxBytes() *NullableInt64

+ func (m *CreateStreamRequest) GetRetentionMaxMessages() *NullableInt64

+ func (m *CreateStreamRequest) GetSegmentMaxAge() *NullableInt64

+ func (m *CreateStreamRequest) GetSegmentMaxBytes() *NullableInt64

+ func (m *CreateStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CreateStreamRequest) XXX_DiscardUnknown()

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

+ func (m *CreateStreamRequest) XXX_Merge(src proto.Message)

+ func (m *CreateStreamRequest) XXX_Size() int

+ func (m *CreateStreamRequest) XXX_Unmarshal(b []byte) error

type CreateStreamResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *CreateStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CreateStreamResponse) XXX_DiscardUnknown()

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

+ func (m *CreateStreamResponse) XXX_Merge(src proto.Message)

+ func (m *CreateStreamResponse) XXX_Size() int

+ func (m *CreateStreamResponse) XXX_Unmarshal(b []byte) error

type DeleteStreamOp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DeleteStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeleteStreamOp) XXX_DiscardUnknown()

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

+ func (m *DeleteStreamOp) XXX_Merge(src proto.Message)

+ func (m *DeleteStreamOp) XXX_Size() int

+ func (m *DeleteStreamOp) XXX_Unmarshal(b []byte) error

type DeleteStreamRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DeleteStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeleteStreamRequest) XXX_DiscardUnknown()

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

+ func (m *DeleteStreamRequest) XXX_Merge(src proto.Message)

+ func (m *DeleteStreamRequest) XXX_Size() int

+ func (m *DeleteStreamRequest) XXX_Unmarshal(b []byte) error

type DeleteStreamResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DeleteStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeleteStreamResponse) XXX_DiscardUnknown()

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

+ func (m *DeleteStreamResponse) XXX_Merge(src proto.Message)

+ func (m *DeleteStreamResponse) XXX_Size() int

+ func (m *DeleteStreamResponse) XXX_Unmarshal(b []byte) error

type FetchMetadataRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *FetchMetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FetchMetadataRequest) XXX_DiscardUnknown()

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

+ func (m *FetchMetadataRequest) XXX_Merge(src proto.Message)

+ func (m *FetchMetadataRequest) XXX_Size() int

+ func (m *FetchMetadataRequest) XXX_Unmarshal(b []byte) error

type FetchMetadataResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *FetchMetadataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FetchMetadataResponse) XXX_DiscardUnknown()

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

+ func (m *FetchMetadataResponse) XXX_Merge(src proto.Message)

+ func (m *FetchMetadataResponse) XXX_Size() int

+ func (m *FetchMetadataResponse) XXX_Unmarshal(b []byte) error

type Message

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Message) XXX_DiscardUnknown()

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

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

+ func (m *Message) XXX_Size() int

+ func (m *Message) XXX_Unmarshal(b []byte) error

+ type NullableBool struct

+ Value bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NullableBool) Descriptor() ([]byte, []int)

+ func (*NullableBool) ProtoMessage()

+ func (m *NullableBool) GetValue() bool

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

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

+ func (m *NullableBool) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NullableBool) Reset()

+ func (m *NullableBool) Size() (n int)

+ func (m *NullableBool) String() string

+ func (m *NullableBool) Unmarshal(dAtA []byte) error

+ func (m *NullableBool) XXX_DiscardUnknown()

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

+ func (m *NullableBool) XXX_Merge(src proto.Message)

+ func (m *NullableBool) XXX_Size() int

+ func (m *NullableBool) XXX_Unmarshal(b []byte) error

+ type NullableInt32 struct

+ Value int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NullableInt32) Descriptor() ([]byte, []int)

+ func (*NullableInt32) ProtoMessage()

+ func (m *NullableInt32) GetValue() int32

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

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

+ func (m *NullableInt32) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NullableInt32) Reset()

+ func (m *NullableInt32) Size() (n int)

+ func (m *NullableInt32) String() string

+ func (m *NullableInt32) Unmarshal(dAtA []byte) error

+ func (m *NullableInt32) XXX_DiscardUnknown()

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

+ func (m *NullableInt32) XXX_Merge(src proto.Message)

+ func (m *NullableInt32) XXX_Size() int

+ func (m *NullableInt32) XXX_Unmarshal(b []byte) error

+ type NullableInt64 struct

+ Value int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NullableInt64) Descriptor() ([]byte, []int)

+ func (*NullableInt64) ProtoMessage()

+ func (m *NullableInt64) GetValue() int64

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

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

+ func (m *NullableInt64) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NullableInt64) Reset()

+ func (m *NullableInt64) Size() (n int)

+ func (m *NullableInt64) String() string

+ func (m *NullableInt64) Unmarshal(dAtA []byte) error

+ func (m *NullableInt64) XXX_DiscardUnknown()

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

+ func (m *NullableInt64) XXX_Merge(src proto.Message)

+ func (m *NullableInt64) XXX_Size() int

+ func (m *NullableInt64) XXX_Unmarshal(b []byte) error

type PartitionMetadata

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PartitionMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PartitionMetadata) XXX_DiscardUnknown()

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

+ func (m *PartitionMetadata) XXX_Merge(src proto.Message)

+ func (m *PartitionMetadata) XXX_Size() int

+ func (m *PartitionMetadata) XXX_Unmarshal(b []byte) error

type PauseStreamOp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PauseStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PauseStreamOp) XXX_DiscardUnknown()

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

+ func (m *PauseStreamOp) XXX_Merge(src proto.Message)

+ func (m *PauseStreamOp) XXX_Size() int

+ func (m *PauseStreamOp) XXX_Unmarshal(b []byte) error

type PauseStreamRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PauseStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PauseStreamRequest) XXX_DiscardUnknown()

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

+ func (m *PauseStreamRequest) XXX_Merge(src proto.Message)

+ func (m *PauseStreamRequest) XXX_Size() int

+ func (m *PauseStreamRequest) XXX_Unmarshal(b []byte) error

type PauseStreamResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PauseStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PauseStreamResponse) XXX_DiscardUnknown()

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

+ func (m *PauseStreamResponse) XXX_Merge(src proto.Message)

+ func (m *PauseStreamResponse) XXX_Size() int

+ func (m *PauseStreamResponse) XXX_Unmarshal(b []byte) error

type PublishRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PublishRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PublishRequest) XXX_DiscardUnknown()

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

+ func (m *PublishRequest) XXX_Merge(src proto.Message)

+ func (m *PublishRequest) XXX_Size() int

+ func (m *PublishRequest) XXX_Unmarshal(b []byte) error

type PublishResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PublishResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PublishResponse) XXX_DiscardUnknown()

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

+ func (m *PublishResponse) XXX_Merge(src proto.Message)

+ func (m *PublishResponse) XXX_Size() int

+ func (m *PublishResponse) XXX_Unmarshal(b []byte) error

type PublishToSubjectRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PublishToSubjectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PublishToSubjectRequest) XXX_DiscardUnknown()

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

+ func (m *PublishToSubjectRequest) XXX_Merge(src proto.Message)

+ func (m *PublishToSubjectRequest) XXX_Size() int

+ func (m *PublishToSubjectRequest) XXX_Unmarshal(b []byte) error

type PublishToSubjectResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PublishToSubjectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PublishToSubjectResponse) XXX_DiscardUnknown()

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

+ func (m *PublishToSubjectResponse) XXX_Merge(src proto.Message)

+ func (m *PublishToSubjectResponse) XXX_Size() int

+ func (m *PublishToSubjectResponse) XXX_Unmarshal(b []byte) error

type ResumeStreamOp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ResumeStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResumeStreamOp) XXX_DiscardUnknown()

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

+ func (m *ResumeStreamOp) XXX_Merge(src proto.Message)

+ func (m *ResumeStreamOp) XXX_Size() int

+ func (m *ResumeStreamOp) XXX_Unmarshal(b []byte) error

type StreamMetadata

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *StreamMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamMetadata) XXX_DiscardUnknown()

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

+ func (m *StreamMetadata) XXX_Merge(src proto.Message)

+ func (m *StreamMetadata) XXX_Size() int

+ func (m *StreamMetadata) XXX_Unmarshal(b []byte) error

type SubscribeRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SubscribeRequest) XXX_DiscardUnknown()

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

+ func (m *SubscribeRequest) XXX_Merge(src proto.Message)

+ func (m *SubscribeRequest) XXX_Size() int

+ func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error

+ type UnimplementedAPIServer struct

+ func (*UnimplementedAPIServer) CreateStream(ctx context.Context, req *CreateStreamRequest) (*CreateStreamResponse, error)

+ func (*UnimplementedAPIServer) DeleteStream(ctx context.Context, req *DeleteStreamRequest) (*DeleteStreamResponse, error)

+ func (*UnimplementedAPIServer) FetchMetadata(ctx context.Context, req *FetchMetadataRequest) (*FetchMetadataResponse, error)

+ func (*UnimplementedAPIServer) PauseStream(ctx context.Context, req *PauseStreamRequest) (*PauseStreamResponse, error)

+ func (*UnimplementedAPIServer) Publish(ctx context.Context, req *PublishRequest) (*PublishResponse, error)

+ func (*UnimplementedAPIServer) PublishAsync(srv API_PublishAsyncServer) error

+ func (*UnimplementedAPIServer) PublishToSubject(ctx context.Context, req *PublishToSubjectRequest) (*PublishToSubjectResponse, error)

+ func (*UnimplementedAPIServer) Subscribe(req *SubscribeRequest, srv API_SubscribeServer) error

v1.0.0

Apr 23, 2020

Changes in this version

+ var AckPolicy_name = map[int32]string

+ var AckPolicy_value = map[string]int32

+ var ActivityStreamOp_name = map[int32]string

+ var ActivityStreamOp_value = map[string]int32

+ var ErrIntOverflowApi = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")

+ var StartPosition_name = map[int32]string

+ var StartPosition_value = map[string]int32

+ var StreamMetadata_Error_name = map[int32]string

+ var StreamMetadata_Error_value = map[string]int32

+ func RegisterAPIServer(s *grpc.Server, srv APIServer)

+ type APIClient interface

+ CreateStream func(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*CreateStreamResponse, error)

+ DeleteStream func(ctx context.Context, in *DeleteStreamRequest, opts ...grpc.CallOption) (*DeleteStreamResponse, error)

+ FetchMetadata func(ctx context.Context, in *FetchMetadataRequest, opts ...grpc.CallOption) (*FetchMetadataResponse, error)

+ PauseStream func(ctx context.Context, in *PauseStreamRequest, opts ...grpc.CallOption) (*PauseStreamResponse, error)

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)

+ PublishToSubject func(ctx context.Context, in *PublishToSubjectRequest, opts ...grpc.CallOption) (*PublishToSubjectResponse, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (API_SubscribeClient, error)

+ func NewAPIClient(cc *grpc.ClientConn) APIClient

+ type APIServer interface

+ CreateStream func(context.Context, *CreateStreamRequest) (*CreateStreamResponse, error)

+ DeleteStream func(context.Context, *DeleteStreamRequest) (*DeleteStreamResponse, error)

+ FetchMetadata func(context.Context, *FetchMetadataRequest) (*FetchMetadataResponse, error)

+ PauseStream func(context.Context, *PauseStreamRequest) (*PauseStreamResponse, error)

+ Publish func(context.Context, *PublishRequest) (*PublishResponse, error)

+ PublishToSubject func(context.Context, *PublishToSubjectRequest) (*PublishToSubjectResponse, error)

+ Subscribe func(*SubscribeRequest, API_SubscribeServer) error

+ type API_SubscribeClient interface

+ Recv func() (*Message, error)

+ type API_SubscribeServer interface

+ Send func(*Message) error

+ type Ack struct

+ AckInbox string

+ AckPolicy AckPolicy

+ CorrelationId string

+ MsgSubject string

+ Offset int64

+ PartitionSubject string

+ Stream string

+ func (*Ack) Descriptor() ([]byte, []int)

+ func (*Ack) ProtoMessage()

+ func (m *Ack) GetAckInbox() string

+ func (m *Ack) GetAckPolicy() AckPolicy

+ func (m *Ack) GetCorrelationId() string

+ func (m *Ack) GetMsgSubject() string

+ func (m *Ack) GetOffset() int64

+ func (m *Ack) GetPartitionSubject() string

+ func (m *Ack) GetStream() string

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

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

+ func (m *Ack) Reset()

+ func (m *Ack) Size() (n int)

+ func (m *Ack) String() string

+ func (m *Ack) Unmarshal(dAtA []byte) error

+ type AckPolicy int32

+ const AckPolicy_ALL

+ const AckPolicy_LEADER

+ const AckPolicy_NONE

+ func (AckPolicy) EnumDescriptor() ([]byte, []int)

+ func (x AckPolicy) String() string

+ type ActivityStreamEvent struct

+ CreateStreamOp *CreateStreamOp

+ DeleteStreamOp *DeleteStreamOp

+ Id uint64

+ Op ActivityStreamOp

+ PauseStreamOp *PauseStreamOp

+ ResumeStreamOp *ResumeStreamOp

+ func (*ActivityStreamEvent) Descriptor() ([]byte, []int)

+ func (*ActivityStreamEvent) ProtoMessage()

+ func (m *ActivityStreamEvent) GetCreateStreamOp() *CreateStreamOp

+ func (m *ActivityStreamEvent) GetDeleteStreamOp() *DeleteStreamOp

+ func (m *ActivityStreamEvent) GetId() uint64

+ func (m *ActivityStreamEvent) GetOp() ActivityStreamOp

+ func (m *ActivityStreamEvent) GetPauseStreamOp() *PauseStreamOp

+ func (m *ActivityStreamEvent) GetResumeStreamOp() *ResumeStreamOp

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

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

+ func (m *ActivityStreamEvent) Reset()

+ func (m *ActivityStreamEvent) Size() (n int)

+ func (m *ActivityStreamEvent) String() string

+ func (m *ActivityStreamEvent) Unmarshal(dAtA []byte) error

+ type ActivityStreamOp int32

+ const ActivityStreamOp_CREATE_STREAM

+ const ActivityStreamOp_DELETE_STREAM

+ const ActivityStreamOp_PAUSE_STREAM

+ const ActivityStreamOp_RESUME_STREAM

+ func (ActivityStreamOp) EnumDescriptor() ([]byte, []int)

+ func (x ActivityStreamOp) String() string

+ type Broker struct

+ Host string

+ Id string

+ Port int32

+ func (*Broker) Descriptor() ([]byte, []int)

+ func (*Broker) ProtoMessage()

+ func (m *Broker) GetHost() string

+ func (m *Broker) GetId() string

+ func (m *Broker) GetPort() int32

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

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

+ func (m *Broker) Reset()

+ func (m *Broker) Size() (n int)

+ func (m *Broker) String() string

+ func (m *Broker) Unmarshal(dAtA []byte) error

+ type CreateStreamOp struct

+ Partitions []int32

+ Stream string

+ func (*CreateStreamOp) Descriptor() ([]byte, []int)

+ func (*CreateStreamOp) ProtoMessage()

+ func (m *CreateStreamOp) GetPartitions() []int32

+ func (m *CreateStreamOp) GetStream() string

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

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

+ func (m *CreateStreamOp) Reset()

+ func (m *CreateStreamOp) Size() (n int)

+ func (m *CreateStreamOp) String() string

+ func (m *CreateStreamOp) Unmarshal(dAtA []byte) error

+ type CreateStreamRequest struct

+ Group string

+ Name string

+ Partitions int32

+ ReplicationFactor int32

+ Subject string

+ func (*CreateStreamRequest) Descriptor() ([]byte, []int)

+ func (*CreateStreamRequest) ProtoMessage()

+ func (m *CreateStreamRequest) GetGroup() string

+ func (m *CreateStreamRequest) GetName() string

+ func (m *CreateStreamRequest) GetPartitions() int32

+ func (m *CreateStreamRequest) GetReplicationFactor() int32

+ func (m *CreateStreamRequest) GetSubject() string

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

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

+ func (m *CreateStreamRequest) Reset()

+ func (m *CreateStreamRequest) Size() (n int)

+ func (m *CreateStreamRequest) String() string

+ func (m *CreateStreamRequest) Unmarshal(dAtA []byte) error

+ type CreateStreamResponse struct

+ func (*CreateStreamResponse) Descriptor() ([]byte, []int)

+ func (*CreateStreamResponse) ProtoMessage()

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

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

+ func (m *CreateStreamResponse) Reset()

+ func (m *CreateStreamResponse) Size() (n int)

+ func (m *CreateStreamResponse) String() string

+ func (m *CreateStreamResponse) Unmarshal(dAtA []byte) error

+ type DeleteStreamOp struct

+ Stream string

+ func (*DeleteStreamOp) Descriptor() ([]byte, []int)

+ func (*DeleteStreamOp) ProtoMessage()

+ func (m *DeleteStreamOp) GetStream() string

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

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

+ func (m *DeleteStreamOp) Reset()

+ func (m *DeleteStreamOp) Size() (n int)

+ func (m *DeleteStreamOp) String() string

+ func (m *DeleteStreamOp) Unmarshal(dAtA []byte) error

+ type DeleteStreamRequest struct

+ Name string

+ func (*DeleteStreamRequest) Descriptor() ([]byte, []int)

+ func (*DeleteStreamRequest) ProtoMessage()

+ func (m *DeleteStreamRequest) GetName() string

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

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

+ func (m *DeleteStreamRequest) Reset()

+ func (m *DeleteStreamRequest) Size() (n int)

+ func (m *DeleteStreamRequest) String() string

+ func (m *DeleteStreamRequest) Unmarshal(dAtA []byte) error

+ type DeleteStreamResponse struct

+ func (*DeleteStreamResponse) Descriptor() ([]byte, []int)

+ func (*DeleteStreamResponse) ProtoMessage()

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

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

+ func (m *DeleteStreamResponse) Reset()

+ func (m *DeleteStreamResponse) Size() (n int)

+ func (m *DeleteStreamResponse) String() string

+ func (m *DeleteStreamResponse) Unmarshal(dAtA []byte) error

+ type FetchMetadataRequest struct

+ Streams []string

+ func (*FetchMetadataRequest) Descriptor() ([]byte, []int)

+ func (*FetchMetadataRequest) ProtoMessage()

+ func (m *FetchMetadataRequest) GetStreams() []string

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

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

+ func (m *FetchMetadataRequest) Reset()

+ func (m *FetchMetadataRequest) Size() (n int)

+ func (m *FetchMetadataRequest) String() string

+ func (m *FetchMetadataRequest) Unmarshal(dAtA []byte) error

+ type FetchMetadataResponse struct

+ Brokers []*Broker

+ Metadata []*StreamMetadata

+ func (*FetchMetadataResponse) Descriptor() ([]byte, []int)

+ func (*FetchMetadataResponse) ProtoMessage()

+ func (m *FetchMetadataResponse) GetBrokers() []*Broker

+ func (m *FetchMetadataResponse) GetMetadata() []*StreamMetadata

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

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

+ func (m *FetchMetadataResponse) Reset()

+ func (m *FetchMetadataResponse) Size() (n int)

+ func (m *FetchMetadataResponse) String() string

+ func (m *FetchMetadataResponse) Unmarshal(dAtA []byte) error

+ type Message struct

+ AckInbox string

+ AckPolicy AckPolicy

+ CorrelationId string

+ Headers map[string][]byte

+ Key []byte

+ Offset int64

+ Partition int32

+ ReplySubject string

+ Stream string

+ Subject string

+ Timestamp int64

+ Value []byte

+ func (*Message) Descriptor() ([]byte, []int)

+ func (*Message) ProtoMessage()

+ func (m *Message) GetAckInbox() string

+ func (m *Message) GetAckPolicy() AckPolicy

+ func (m *Message) GetCorrelationId() string

+ func (m *Message) GetHeaders() map[string][]byte

+ func (m *Message) GetKey() []byte

+ func (m *Message) GetOffset() int64

+ func (m *Message) GetPartition() int32

+ func (m *Message) GetReplySubject() string

+ func (m *Message) GetStream() string

+ func (m *Message) GetSubject() string

+ func (m *Message) GetTimestamp() int64

+ func (m *Message) GetValue() []byte

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

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

+ func (m *Message) Reset()

+ func (m *Message) Size() (n int)

+ func (m *Message) String() string

+ func (m *Message) Unmarshal(dAtA []byte) error

+ type PartitionMetadata struct

+ Id int32

+ Isr []string

+ Leader string

+ Replicas []string

+ func (*PartitionMetadata) Descriptor() ([]byte, []int)

+ func (*PartitionMetadata) ProtoMessage()

+ func (m *PartitionMetadata) GetId() int32

+ func (m *PartitionMetadata) GetIsr() []string

+ func (m *PartitionMetadata) GetLeader() string

+ func (m *PartitionMetadata) GetReplicas() []string

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

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

+ func (m *PartitionMetadata) Reset()

+ func (m *PartitionMetadata) Size() (n int)

+ func (m *PartitionMetadata) String() string

+ func (m *PartitionMetadata) Unmarshal(dAtA []byte) error

+ type PauseStreamOp struct

+ Partitions []int32

+ ResumeAll bool

+ Stream string

+ func (*PauseStreamOp) Descriptor() ([]byte, []int)

+ func (*PauseStreamOp) ProtoMessage()

+ func (m *PauseStreamOp) GetPartitions() []int32

+ func (m *PauseStreamOp) GetResumeAll() bool

+ func (m *PauseStreamOp) GetStream() string

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

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

+ func (m *PauseStreamOp) Reset()

+ func (m *PauseStreamOp) Size() (n int)

+ func (m *PauseStreamOp) String() string

+ func (m *PauseStreamOp) Unmarshal(dAtA []byte) error

+ type PauseStreamRequest struct

+ Name string

+ Partitions []int32

+ ResumeAll bool

+ func (*PauseStreamRequest) Descriptor() ([]byte, []int)

+ func (*PauseStreamRequest) ProtoMessage()

+ func (m *PauseStreamRequest) GetName() string

+ func (m *PauseStreamRequest) GetPartitions() []int32

+ func (m *PauseStreamRequest) GetResumeAll() bool

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

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

+ func (m *PauseStreamRequest) Reset()

+ func (m *PauseStreamRequest) Size() (n int)

+ func (m *PauseStreamRequest) String() string

+ func (m *PauseStreamRequest) Unmarshal(dAtA []byte) error

+ type PauseStreamResponse struct

+ func (*PauseStreamResponse) Descriptor() ([]byte, []int)

+ func (*PauseStreamResponse) ProtoMessage()

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

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

+ func (m *PauseStreamResponse) Reset()

+ func (m *PauseStreamResponse) Size() (n int)

+ func (m *PauseStreamResponse) String() string

+ func (m *PauseStreamResponse) Unmarshal(dAtA []byte) error

+ type PublishRequest struct

+ AckInbox string

+ AckPolicy AckPolicy

+ CorrelationId string

+ Headers map[string][]byte

+ Key []byte

+ Partition int32

+ Stream string

+ Value []byte

+ func (*PublishRequest) Descriptor() ([]byte, []int)

+ func (*PublishRequest) ProtoMessage()

+ func (m *PublishRequest) GetAckInbox() string

+ func (m *PublishRequest) GetAckPolicy() AckPolicy

+ func (m *PublishRequest) GetCorrelationId() string

+ func (m *PublishRequest) GetHeaders() map[string][]byte

+ func (m *PublishRequest) GetKey() []byte

+ func (m *PublishRequest) GetPartition() int32

+ func (m *PublishRequest) GetStream() string

+ func (m *PublishRequest) GetValue() []byte

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

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

+ func (m *PublishRequest) Reset()

+ func (m *PublishRequest) Size() (n int)

+ func (m *PublishRequest) String() string

+ func (m *PublishRequest) Unmarshal(dAtA []byte) error

+ type PublishResponse struct

+ Ack *Ack

+ func (*PublishResponse) Descriptor() ([]byte, []int)

+ func (*PublishResponse) ProtoMessage()

+ func (m *PublishResponse) GetAck() *Ack

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

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

+ func (m *PublishResponse) Reset()

+ func (m *PublishResponse) Size() (n int)

+ func (m *PublishResponse) String() string

+ func (m *PublishResponse) Unmarshal(dAtA []byte) error

+ type PublishToSubjectRequest struct

+ AckInbox string

+ AckPolicy AckPolicy

+ CorrelationId string

+ Headers map[string][]byte

+ Key []byte

+ Subject string

+ Value []byte

+ func (*PublishToSubjectRequest) Descriptor() ([]byte, []int)

+ func (*PublishToSubjectRequest) ProtoMessage()

+ func (m *PublishToSubjectRequest) GetAckInbox() string

+ func (m *PublishToSubjectRequest) GetAckPolicy() AckPolicy

+ func (m *PublishToSubjectRequest) GetCorrelationId() string

+ func (m *PublishToSubjectRequest) GetHeaders() map[string][]byte

+ func (m *PublishToSubjectRequest) GetKey() []byte

+ func (m *PublishToSubjectRequest) GetSubject() string

+ func (m *PublishToSubjectRequest) GetValue() []byte

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

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

+ func (m *PublishToSubjectRequest) Reset()

+ func (m *PublishToSubjectRequest) Size() (n int)

+ func (m *PublishToSubjectRequest) String() string

+ func (m *PublishToSubjectRequest) Unmarshal(dAtA []byte) error

+ type PublishToSubjectResponse struct

+ Ack *Ack

+ func (*PublishToSubjectResponse) Descriptor() ([]byte, []int)

+ func (*PublishToSubjectResponse) ProtoMessage()

+ func (m *PublishToSubjectResponse) GetAck() *Ack

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

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

+ func (m *PublishToSubjectResponse) Reset()

+ func (m *PublishToSubjectResponse) Size() (n int)

+ func (m *PublishToSubjectResponse) String() string

+ func (m *PublishToSubjectResponse) Unmarshal(dAtA []byte) error

+ type ResumeStreamOp struct

+ Partitions []int32

+ Stream string

+ func (*ResumeStreamOp) Descriptor() ([]byte, []int)

+ func (*ResumeStreamOp) ProtoMessage()

+ func (m *ResumeStreamOp) GetPartitions() []int32

+ func (m *ResumeStreamOp) GetStream() string

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

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

+ func (m *ResumeStreamOp) Reset()

+ func (m *ResumeStreamOp) Size() (n int)

+ func (m *ResumeStreamOp) String() string

+ func (m *ResumeStreamOp) Unmarshal(dAtA []byte) error

+ type StartPosition int32

+ const StartPosition_EARLIEST

+ const StartPosition_LATEST

+ const StartPosition_NEW_ONLY

+ const StartPosition_OFFSET

+ const StartPosition_TIMESTAMP

+ func (StartPosition) EnumDescriptor() ([]byte, []int)

+ func (x StartPosition) String() string

+ type StreamMetadata struct

+ Error StreamMetadata_Error

+ Name string

+ Partitions map[int32]*PartitionMetadata

+ Subject string

+ func (*StreamMetadata) Descriptor() ([]byte, []int)

+ func (*StreamMetadata) ProtoMessage()

+ func (m *StreamMetadata) GetError() StreamMetadata_Error

+ func (m *StreamMetadata) GetName() string

+ func (m *StreamMetadata) GetPartitions() map[int32]*PartitionMetadata

+ func (m *StreamMetadata) GetSubject() string

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

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

+ func (m *StreamMetadata) Reset()

+ func (m *StreamMetadata) Size() (n int)

+ func (m *StreamMetadata) String() string

+ func (m *StreamMetadata) Unmarshal(dAtA []byte) error

+ type StreamMetadata_Error int32

+ const StreamMetadata_OK

+ const StreamMetadata_UNKNOWN_STREAM

+ func (StreamMetadata_Error) EnumDescriptor() ([]byte, []int)

+ func (x StreamMetadata_Error) String() string

+ type SubscribeRequest struct

+ Partition int32

+ ReadISRReplica bool

+ StartOffset int64

+ StartPosition StartPosition

+ StartTimestamp int64

+ Stream string

+ func (*SubscribeRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeRequest) ProtoMessage()

+ func (m *SubscribeRequest) GetPartition() int32

+ func (m *SubscribeRequest) GetReadISRReplica() bool

+ func (m *SubscribeRequest) GetStartOffset() int64

+ func (m *SubscribeRequest) GetStartPosition() StartPosition

+ func (m *SubscribeRequest) GetStartTimestamp() int64

+ func (m *SubscribeRequest) GetStream() string

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

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

+ func (m *SubscribeRequest) Reset()

+ func (m *SubscribeRequest) Size() (n int)

+ func (m *SubscribeRequest) String() string

+ func (m *SubscribeRequest) Unmarshal(dAtA []byte) error

v1.0.0-beta

Feb 27, 2020

v1.0.0-alpha

Feb 14, 2020

v0

v0.0.1-alpha

Dec 23, 2019

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