Documentation ¶
Index ¶
- Variables
- func RegisterAPIServer(s *grpc.Server, srv APIServer)
- type APIClient
- type APIServer
- type API_PublishAsyncClient
- type API_PublishAsyncServer
- type API_SubscribeClient
- type API_SubscribeServer
- type Ack
- func (*Ack) Descriptor() ([]byte, []int)
- func (m *Ack) GetAckInbox() string
- func (m *Ack) GetAckPolicy() AckPolicy
- func (m *Ack) GetCommitTimestamp() int64
- func (m *Ack) GetCorrelationId() string
- func (m *Ack) GetMsgSubject() string
- func (m *Ack) GetOffset() int64
- func (m *Ack) GetPartitionSubject() string
- func (m *Ack) GetReceptionTimestamp() int64
- func (m *Ack) GetStream() string
- func (m *Ack) Marshal() (dAtA []byte, err error)
- func (m *Ack) MarshalTo(dAtA []byte) (int, error)
- func (m *Ack) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Ack) ProtoMessage()
- func (m *Ack) Reset()
- func (m *Ack) Size() (n int)
- func (m *Ack) String() string
- func (m *Ack) Unmarshal(dAtA []byte) 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 AckPolicy
- type ActivityStreamEvent
- func (*ActivityStreamEvent) Descriptor() ([]byte, []int)
- 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) GetSetStreamReadonlyOp() *SetStreamReadonlyOp
- func (m *ActivityStreamEvent) Marshal() (dAtA []byte, err error)
- func (m *ActivityStreamEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *ActivityStreamEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActivityStreamEvent) ProtoMessage()
- func (m *ActivityStreamEvent) Reset()
- func (m *ActivityStreamEvent) Size() (n int)
- func (m *ActivityStreamEvent) String() string
- func (m *ActivityStreamEvent) Unmarshal(dAtA []byte) 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 ActivityStreamOp
- type Broker
- func (*Broker) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Broker) ProtoMessage()
- func (m *Broker) Reset()
- func (m *Broker) Size() (n int)
- func (m *Broker) String() string
- func (m *Broker) Unmarshal(dAtA []byte) 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
- func (*CreateStreamOp) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateStreamOp) ProtoMessage()
- func (m *CreateStreamOp) Reset()
- func (m *CreateStreamOp) Size() (n int)
- func (m *CreateStreamOp) String() string
- func (m *CreateStreamOp) Unmarshal(dAtA []byte) 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
- func (*CreateStreamRequest) Descriptor() ([]byte, []int)
- func (m *CreateStreamRequest) GetCleanerInterval() *NullableInt64
- func (m *CreateStreamRequest) GetCompactEnabled() *NullableBool
- func (m *CreateStreamRequest) GetCompactMaxGoroutines() *NullableInt32
- func (m *CreateStreamRequest) GetGroup() string
- func (m *CreateStreamRequest) GetName() string
- func (m *CreateStreamRequest) GetPartitions() int32
- func (m *CreateStreamRequest) GetReplicationFactor() int32
- 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) GetSubject() string
- func (m *CreateStreamRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateStreamRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateStreamRequest) ProtoMessage()
- func (m *CreateStreamRequest) Reset()
- func (m *CreateStreamRequest) Size() (n int)
- func (m *CreateStreamRequest) String() string
- func (m *CreateStreamRequest) Unmarshal(dAtA []byte) 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
- func (*CreateStreamResponse) Descriptor() ([]byte, []int)
- func (m *CreateStreamResponse) Marshal() (dAtA []byte, err error)
- func (m *CreateStreamResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateStreamResponse) ProtoMessage()
- func (m *CreateStreamResponse) Reset()
- func (m *CreateStreamResponse) Size() (n int)
- func (m *CreateStreamResponse) String() string
- func (m *CreateStreamResponse) Unmarshal(dAtA []byte) 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
- func (*DeleteStreamOp) Descriptor() ([]byte, []int)
- func (m *DeleteStreamOp) GetStream() string
- func (m *DeleteStreamOp) Marshal() (dAtA []byte, err error)
- func (m *DeleteStreamOp) MarshalTo(dAtA []byte) (int, error)
- func (m *DeleteStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeleteStreamOp) ProtoMessage()
- func (m *DeleteStreamOp) Reset()
- func (m *DeleteStreamOp) Size() (n int)
- func (m *DeleteStreamOp) String() string
- func (m *DeleteStreamOp) Unmarshal(dAtA []byte) 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
- func (*DeleteStreamRequest) Descriptor() ([]byte, []int)
- func (m *DeleteStreamRequest) GetName() string
- func (m *DeleteStreamRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteStreamRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *DeleteStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeleteStreamRequest) ProtoMessage()
- func (m *DeleteStreamRequest) Reset()
- func (m *DeleteStreamRequest) Size() (n int)
- func (m *DeleteStreamRequest) String() string
- func (m *DeleteStreamRequest) Unmarshal(dAtA []byte) 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
- func (*DeleteStreamResponse) Descriptor() ([]byte, []int)
- func (m *DeleteStreamResponse) Marshal() (dAtA []byte, err error)
- func (m *DeleteStreamResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *DeleteStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeleteStreamResponse) ProtoMessage()
- func (m *DeleteStreamResponse) Reset()
- func (m *DeleteStreamResponse) Size() (n int)
- func (m *DeleteStreamResponse) String() string
- func (m *DeleteStreamResponse) Unmarshal(dAtA []byte) 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
- func (*FetchMetadataRequest) Descriptor() ([]byte, []int)
- func (m *FetchMetadataRequest) GetStreams() []string
- func (m *FetchMetadataRequest) Marshal() (dAtA []byte, err error)
- func (m *FetchMetadataRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *FetchMetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FetchMetadataRequest) ProtoMessage()
- func (m *FetchMetadataRequest) Reset()
- func (m *FetchMetadataRequest) Size() (n int)
- func (m *FetchMetadataRequest) String() string
- func (m *FetchMetadataRequest) Unmarshal(dAtA []byte) 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
- func (*FetchMetadataResponse) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FetchMetadataResponse) ProtoMessage()
- func (m *FetchMetadataResponse) Reset()
- func (m *FetchMetadataResponse) Size() (n int)
- func (m *FetchMetadataResponse) String() string
- func (m *FetchMetadataResponse) Unmarshal(dAtA []byte) 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
- func (*Message) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) Size() (n int)
- func (m *Message) String() string
- func (m *Message) Unmarshal(dAtA []byte) 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
- func (*NullableBool) Descriptor() ([]byte, []int)
- 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 (*NullableBool) ProtoMessage()
- 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
- func (*NullableInt32) Descriptor() ([]byte, []int)
- 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 (*NullableInt32) ProtoMessage()
- 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
- func (*NullableInt64) Descriptor() ([]byte, []int)
- 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 (*NullableInt64) ProtoMessage()
- 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
- func (*PartitionMetadata) Descriptor() ([]byte, []int)
- func (m *PartitionMetadata) GetHighWatermark() int64
- func (m *PartitionMetadata) GetId() int32
- func (m *PartitionMetadata) GetIsr() []string
- func (m *PartitionMetadata) GetLeader() string
- func (m *PartitionMetadata) GetNewestOffset() int64
- func (m *PartitionMetadata) GetPaused() bool
- func (m *PartitionMetadata) GetReplicas() []string
- func (m *PartitionMetadata) Marshal() (dAtA []byte, err error)
- func (m *PartitionMetadata) MarshalTo(dAtA []byte) (int, error)
- func (m *PartitionMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PartitionMetadata) ProtoMessage()
- func (m *PartitionMetadata) Reset()
- func (m *PartitionMetadata) Size() (n int)
- func (m *PartitionMetadata) String() string
- func (m *PartitionMetadata) Unmarshal(dAtA []byte) 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
- func (*PauseStreamOp) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PauseStreamOp) ProtoMessage()
- func (m *PauseStreamOp) Reset()
- func (m *PauseStreamOp) Size() (n int)
- func (m *PauseStreamOp) String() string
- func (m *PauseStreamOp) Unmarshal(dAtA []byte) 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
- func (*PauseStreamRequest) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PauseStreamRequest) ProtoMessage()
- func (m *PauseStreamRequest) Reset()
- func (m *PauseStreamRequest) Size() (n int)
- func (m *PauseStreamRequest) String() string
- func (m *PauseStreamRequest) Unmarshal(dAtA []byte) 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
- func (*PauseStreamResponse) Descriptor() ([]byte, []int)
- func (m *PauseStreamResponse) Marshal() (dAtA []byte, err error)
- func (m *PauseStreamResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PauseStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PauseStreamResponse) ProtoMessage()
- func (m *PauseStreamResponse) Reset()
- func (m *PauseStreamResponse) Size() (n int)
- func (m *PauseStreamResponse) String() string
- func (m *PauseStreamResponse) Unmarshal(dAtA []byte) 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
- func (*PublishRequest) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PublishRequest) ProtoMessage()
- func (m *PublishRequest) Reset()
- func (m *PublishRequest) Size() (n int)
- func (m *PublishRequest) String() string
- func (m *PublishRequest) Unmarshal(dAtA []byte) 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
- func (*PublishResponse) Descriptor() ([]byte, []int)
- func (m *PublishResponse) GetAck() *Ack
- func (m *PublishResponse) Marshal() (dAtA []byte, err error)
- func (m *PublishResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PublishResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PublishResponse) ProtoMessage()
- func (m *PublishResponse) Reset()
- func (m *PublishResponse) Size() (n int)
- func (m *PublishResponse) String() string
- func (m *PublishResponse) Unmarshal(dAtA []byte) 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
- func (*PublishToSubjectRequest) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PublishToSubjectRequest) ProtoMessage()
- func (m *PublishToSubjectRequest) Reset()
- func (m *PublishToSubjectRequest) Size() (n int)
- func (m *PublishToSubjectRequest) String() string
- func (m *PublishToSubjectRequest) Unmarshal(dAtA []byte) 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
- func (*PublishToSubjectResponse) Descriptor() ([]byte, []int)
- func (m *PublishToSubjectResponse) GetAck() *Ack
- func (m *PublishToSubjectResponse) Marshal() (dAtA []byte, err error)
- func (m *PublishToSubjectResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PublishToSubjectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PublishToSubjectResponse) ProtoMessage()
- func (m *PublishToSubjectResponse) Reset()
- func (m *PublishToSubjectResponse) Size() (n int)
- func (m *PublishToSubjectResponse) String() string
- func (m *PublishToSubjectResponse) Unmarshal(dAtA []byte) 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
- func (*ResumeStreamOp) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResumeStreamOp) ProtoMessage()
- func (m *ResumeStreamOp) Reset()
- func (m *ResumeStreamOp) Size() (n int)
- func (m *ResumeStreamOp) String() string
- func (m *ResumeStreamOp) Unmarshal(dAtA []byte) 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 SetStreamReadonlyOp
- func (*SetStreamReadonlyOp) Descriptor() ([]byte, []int)
- 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 (*SetStreamReadonlyOp) ProtoMessage()
- 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
- func (*SetStreamReadonlyRequest) Descriptor() ([]byte, []int)
- 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 (*SetStreamReadonlyRequest) ProtoMessage()
- 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
- func (*SetStreamReadonlyResponse) Descriptor() ([]byte, []int)
- 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 (*SetStreamReadonlyResponse) ProtoMessage()
- 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 StartPosition
- type StreamMetadata
- func (*StreamMetadata) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StreamMetadata) ProtoMessage()
- func (m *StreamMetadata) Reset()
- func (m *StreamMetadata) Size() (n int)
- func (m *StreamMetadata) String() string
- func (m *StreamMetadata) Unmarshal(dAtA []byte) 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 StreamMetadata_Error
- type SubscribeRequest
- func (*SubscribeRequest) Descriptor() ([]byte, []int)
- func (m *SubscribeRequest) GetPartition() int32
- func (m *SubscribeRequest) GetReadISRReplica() bool
- func (m *SubscribeRequest) GetResume() 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SubscribeRequest) ProtoMessage()
- func (m *SubscribeRequest) Reset()
- func (m *SubscribeRequest) Size() (n int)
- func (m *SubscribeRequest) String() string
- func (m *SubscribeRequest) Unmarshal(dAtA []byte) 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
- 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) SetStreamReadonly(ctx context.Context, req *SetStreamReadonlyRequest) (*SetStreamReadonlyResponse, error)
- func (*UnimplementedAPIServer) Subscribe(req *SubscribeRequest, srv API_SubscribeServer) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowApi = fmt.Errorf("proto: integer overflow") )
var AckPolicy_name = map[int32]string{
0: "LEADER",
1: "ALL",
2: "NONE",
}
var AckPolicy_value = map[string]int32{
"LEADER": 0,
"ALL": 1,
"NONE": 2,
}
var ActivityStreamOp_name = map[int32]string{
0: "CREATE_STREAM",
1: "DELETE_STREAM",
2: "PAUSE_STREAM",
3: "RESUME_STREAM",
4: "SET_STREAM_READONLY",
}
var ActivityStreamOp_value = map[string]int32{
"CREATE_STREAM": 0,
"DELETE_STREAM": 1,
"PAUSE_STREAM": 2,
"RESUME_STREAM": 3,
"SET_STREAM_READONLY": 4,
}
var StartPosition_name = map[int32]string{
0: "NEW_ONLY",
1: "OFFSET",
2: "EARLIEST",
3: "LATEST",
4: "TIMESTAMP",
}
var StartPosition_value = map[string]int32{
"NEW_ONLY": 0,
"OFFSET": 1,
"EARLIEST": 2,
"LATEST": 3,
"TIMESTAMP": 4,
}
var StreamMetadata_Error_name = map[int32]string{
0: "OK",
1: "UNKNOWN_STREAM",
}
var StreamMetadata_Error_value = map[string]int32{
"OK": 0,
"UNKNOWN_STREAM": 1,
}
Functions ¶
func RegisterAPIServer ¶
Types ¶
type APIClient ¶
type APIClient interface { // CreateStream creates a new stream attached to a NATS subject. It returns // an AlreadyExists status code if a stream with the given subject and name // already exists. CreateStream(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*CreateStreamResponse, error) // DeleteStream deletes a stream. DeleteStream(ctx context.Context, in *DeleteStreamRequest, opts ...grpc.CallOption) (*DeleteStreamResponse, error) // PauseStream pauses a stream's partitions. If no partitions are // specified, all of the stream's partitions will be paused. Partitions are // resumed when they are published to via the Liftbridge Publish API. PauseStream(ctx context.Context, in *PauseStreamRequest, opts ...grpc.CallOption) (*PauseStreamResponse, error) // SetStreamReadonly sets a read-only flag to a partition. The latest // message's offset is returned. Returns a NoSuchStream error code if the // given stream or partition does not exist. SetStreamReadonly(ctx context.Context, in *SetStreamReadonlyRequest, opts ...grpc.CallOption) (*SetStreamReadonlyResponse, error) // Subscribe creates an ephemeral subscription for the given stream. It // begins to receive messages starting at the given offset and waits for // new messages when it reaches the end of the stream. Use the request // context to close the subscription. Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (API_SubscribeClient, error) // FetchMetadata retrieves the latest cluster metadata, including stream // broker information. FetchMetadata(ctx context.Context, in *FetchMetadataRequest, opts ...grpc.CallOption) (*FetchMetadataResponse, error) // Publish a new message to a stream. If the AckPolicy is not NONE and a // deadline is provided, this will synchronously block until the ack is // received. If the ack is not received in time, a DeadlineExceeded status // code is returned. Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error) // PublishAsync is used to asynchronously publish messages to a stream in a // pipelined fashion. This returns a stream which will yield // PublishResponses for messages whose AckPolicy is not NONE. PublishAsync(ctx context.Context, opts ...grpc.CallOption) (API_PublishAsyncClient, error) // Publish a Liftbridge message to a NATS subject. If the AckPolicy is not NONE and a // deadline is provided, this will synchronously block until the first ack // is received. If an ack is not received in time, a DeadlineExceeded // status code is returned. PublishToSubject(ctx context.Context, in *PublishToSubjectRequest, opts ...grpc.CallOption) (*PublishToSubjectResponse, error) }
APIClient is the client API for API service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAPIClient ¶
func NewAPIClient(cc *grpc.ClientConn) APIClient
type APIServer ¶
type APIServer interface { // CreateStream creates a new stream attached to a NATS subject. It returns // an AlreadyExists status code if a stream with the given subject and name // already exists. CreateStream(context.Context, *CreateStreamRequest) (*CreateStreamResponse, error) // DeleteStream deletes a stream. DeleteStream(context.Context, *DeleteStreamRequest) (*DeleteStreamResponse, error) // PauseStream pauses a stream's partitions. If no partitions are // specified, all of the stream's partitions will be paused. Partitions are // resumed when they are published to via the Liftbridge Publish API. PauseStream(context.Context, *PauseStreamRequest) (*PauseStreamResponse, error) // SetStreamReadonly sets a read-only flag to a partition. The latest // message's offset is returned. Returns a NoSuchStream error code if the // given stream or partition does not exist. SetStreamReadonly(context.Context, *SetStreamReadonlyRequest) (*SetStreamReadonlyResponse, error) // Subscribe creates an ephemeral subscription for the given stream. It // begins to receive messages starting at the given offset and waits for // new messages when it reaches the end of the stream. Use the request // context to close the subscription. Subscribe(*SubscribeRequest, API_SubscribeServer) error // FetchMetadata retrieves the latest cluster metadata, including stream // broker information. FetchMetadata(context.Context, *FetchMetadataRequest) (*FetchMetadataResponse, error) // Publish a new message to a stream. If the AckPolicy is not NONE and a // deadline is provided, this will synchronously block until the ack is // received. If the ack is not received in time, a DeadlineExceeded status // code is returned. Publish(context.Context, *PublishRequest) (*PublishResponse, error) // PublishAsync is used to asynchronously publish messages to a stream in a // pipelined fashion. This returns a stream which will yield // PublishResponses for messages whose AckPolicy is not NONE. PublishAsync(API_PublishAsyncServer) error // Publish a Liftbridge message to a NATS subject. If the AckPolicy is not NONE and a // deadline is provided, this will synchronously block until the first ack // is received. If an ack is not received in time, a DeadlineExceeded // status code is returned. PublishToSubject(context.Context, *PublishToSubjectRequest) (*PublishToSubjectResponse, error) }
APIServer is the server API for API service.
type API_PublishAsyncClient ¶ added in v1.1.0
type API_PublishAsyncClient interface { Send(*PublishRequest) error Recv() (*PublishResponse, error) grpc.ClientStream }
type API_PublishAsyncServer ¶ added in v1.1.0
type API_PublishAsyncServer interface { Send(*PublishResponse) error Recv() (*PublishRequest, error) grpc.ServerStream }
type API_SubscribeClient ¶
type API_SubscribeClient interface { Recv() (*Message, error) grpc.ClientStream }
type API_SubscribeServer ¶
type API_SubscribeServer interface { Send(*Message) error grpc.ServerStream }
type Ack ¶
type Ack struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` PartitionSubject string `protobuf:"bytes,2,opt,name=partitionSubject,proto3" json:"partitionSubject,omitempty"` MsgSubject string `protobuf:"bytes,3,opt,name=msgSubject,proto3" json:"msgSubject,omitempty"` Offset int64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"` AckInbox string `protobuf:"bytes,5,opt,name=ackInbox,proto3" json:"ackInbox,omitempty"` CorrelationId string `protobuf:"bytes,6,opt,name=correlationId,proto3" json:"correlationId,omitempty"` AckPolicy AckPolicy `protobuf:"varint,7,opt,name=ackPolicy,proto3,enum=proto.AckPolicy" json:"ackPolicy,omitempty"` ReceptionTimestamp int64 `protobuf:"varint,8,opt,name=receptionTimestamp,proto3" json:"receptionTimestamp,omitempty"` CommitTimestamp int64 `protobuf:"varint,9,opt,name=commitTimestamp,proto3" json:"commitTimestamp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Ack represents an acknowledgement that a message was committed to a stream partition.
func (*Ack) Descriptor ¶
func (*Ack) GetAckInbox ¶
func (*Ack) GetAckPolicy ¶
func (*Ack) GetCommitTimestamp ¶ added in v1.9.2
func (*Ack) GetCorrelationId ¶
func (*Ack) GetMsgSubject ¶
func (*Ack) GetPartitionSubject ¶
func (*Ack) GetReceptionTimestamp ¶ added in v1.9.2
func (*Ack) MarshalToSizedBuffer ¶ added in v1.1.0
func (*Ack) ProtoMessage ¶
func (*Ack) ProtoMessage()
func (*Ack) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *Ack) XXX_DiscardUnknown()
func (*Ack) XXX_Marshal ¶ added in v1.1.0
func (*Ack) XXX_Unmarshal ¶ added in v1.1.0
type AckPolicy ¶
type AckPolicy int32
AckPolicy controls the behavior of message acknowledgements.
func (AckPolicy) EnumDescriptor ¶
type ActivityStreamEvent ¶
type ActivityStreamEvent struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Op ActivityStreamOp `protobuf:"varint,2,opt,name=op,proto3,enum=proto.ActivityStreamOp" json:"op,omitempty"` CreateStreamOp *CreateStreamOp `protobuf:"bytes,3,opt,name=createStreamOp,proto3" json:"createStreamOp,omitempty"` DeleteStreamOp *DeleteStreamOp `protobuf:"bytes,4,opt,name=deleteStreamOp,proto3" json:"deleteStreamOp,omitempty"` PauseStreamOp *PauseStreamOp `protobuf:"bytes,5,opt,name=pauseStreamOp,proto3" json:"pauseStreamOp,omitempty"` ResumeStreamOp *ResumeStreamOp `protobuf:"bytes,6,opt,name=resumeStreamOp,proto3" json:"resumeStreamOp,omitempty"` SetStreamReadonlyOp *SetStreamReadonlyOp `protobuf:"bytes,7,opt,name=setStreamReadonlyOp,proto3" json:"setStreamReadonlyOp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ActivityStreamEvent represents an entry into the activity stream.
func (*ActivityStreamEvent) Descriptor ¶
func (*ActivityStreamEvent) Descriptor() ([]byte, []int)
func (*ActivityStreamEvent) GetCreateStreamOp ¶
func (m *ActivityStreamEvent) GetCreateStreamOp() *CreateStreamOp
func (*ActivityStreamEvent) GetDeleteStreamOp ¶
func (m *ActivityStreamEvent) GetDeleteStreamOp() *DeleteStreamOp
func (*ActivityStreamEvent) GetId ¶
func (m *ActivityStreamEvent) GetId() uint64
func (*ActivityStreamEvent) GetOp ¶
func (m *ActivityStreamEvent) GetOp() ActivityStreamOp
func (*ActivityStreamEvent) GetPauseStreamOp ¶
func (m *ActivityStreamEvent) GetPauseStreamOp() *PauseStreamOp
func (*ActivityStreamEvent) GetResumeStreamOp ¶
func (m *ActivityStreamEvent) GetResumeStreamOp() *ResumeStreamOp
func (*ActivityStreamEvent) GetSetStreamReadonlyOp ¶ added in v1.9.1
func (m *ActivityStreamEvent) GetSetStreamReadonlyOp() *SetStreamReadonlyOp
func (*ActivityStreamEvent) Marshal ¶
func (m *ActivityStreamEvent) Marshal() (dAtA []byte, err error)
func (*ActivityStreamEvent) MarshalTo ¶
func (m *ActivityStreamEvent) MarshalTo(dAtA []byte) (int, error)
func (*ActivityStreamEvent) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *ActivityStreamEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ActivityStreamEvent) ProtoMessage ¶
func (*ActivityStreamEvent) ProtoMessage()
func (*ActivityStreamEvent) Reset ¶
func (m *ActivityStreamEvent) Reset()
func (*ActivityStreamEvent) Size ¶
func (m *ActivityStreamEvent) Size() (n int)
func (*ActivityStreamEvent) String ¶
func (m *ActivityStreamEvent) String() string
func (*ActivityStreamEvent) Unmarshal ¶
func (m *ActivityStreamEvent) Unmarshal(dAtA []byte) error
func (*ActivityStreamEvent) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *ActivityStreamEvent) XXX_DiscardUnknown()
func (*ActivityStreamEvent) XXX_Marshal ¶ added in v1.1.0
func (m *ActivityStreamEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActivityStreamEvent) XXX_Merge ¶ added in v1.1.0
func (m *ActivityStreamEvent) XXX_Merge(src proto.Message)
func (*ActivityStreamEvent) XXX_Size ¶ added in v1.1.0
func (m *ActivityStreamEvent) XXX_Size() int
func (*ActivityStreamEvent) XXX_Unmarshal ¶ added in v1.1.0
func (m *ActivityStreamEvent) XXX_Unmarshal(b []byte) error
type ActivityStreamOp ¶
type ActivityStreamOp int32
ActivityStreamOp represents an activity stream operation.
const ( ActivityStreamOp_CREATE_STREAM ActivityStreamOp = 0 ActivityStreamOp_DELETE_STREAM ActivityStreamOp = 1 ActivityStreamOp_PAUSE_STREAM ActivityStreamOp = 2 ActivityStreamOp_RESUME_STREAM ActivityStreamOp = 3 ActivityStreamOp_SET_STREAM_READONLY ActivityStreamOp = 4 )
func (ActivityStreamOp) EnumDescriptor ¶
func (ActivityStreamOp) EnumDescriptor() ([]byte, []int)
func (ActivityStreamOp) String ¶
func (x ActivityStreamOp) String() string
type Broker ¶
type Broker struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Broker contains information for a Liftbridge broker.
func (*Broker) Descriptor ¶
func (*Broker) MarshalToSizedBuffer ¶ added in v1.1.0
func (*Broker) ProtoMessage ¶
func (*Broker) ProtoMessage()
func (*Broker) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *Broker) XXX_DiscardUnknown()
func (*Broker) XXX_Marshal ¶ added in v1.1.0
func (*Broker) XXX_Unmarshal ¶ added in v1.1.0
type CreateStreamOp ¶
type CreateStreamOp struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partitions []int32 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CreateStreamOp represents a stream creation operation.
func (*CreateStreamOp) Descriptor ¶
func (*CreateStreamOp) Descriptor() ([]byte, []int)
func (*CreateStreamOp) GetPartitions ¶
func (m *CreateStreamOp) GetPartitions() []int32
func (*CreateStreamOp) GetStream ¶
func (m *CreateStreamOp) GetStream() string
func (*CreateStreamOp) Marshal ¶
func (m *CreateStreamOp) Marshal() (dAtA []byte, err error)
func (*CreateStreamOp) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *CreateStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateStreamOp) ProtoMessage ¶
func (*CreateStreamOp) ProtoMessage()
func (*CreateStreamOp) Reset ¶
func (m *CreateStreamOp) Reset()
func (*CreateStreamOp) Size ¶
func (m *CreateStreamOp) Size() (n int)
func (*CreateStreamOp) String ¶
func (m *CreateStreamOp) String() string
func (*CreateStreamOp) Unmarshal ¶
func (m *CreateStreamOp) Unmarshal(dAtA []byte) error
func (*CreateStreamOp) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *CreateStreamOp) XXX_DiscardUnknown()
func (*CreateStreamOp) XXX_Marshal ¶ added in v1.1.0
func (m *CreateStreamOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateStreamOp) XXX_Merge ¶ added in v1.1.0
func (m *CreateStreamOp) XXX_Merge(src proto.Message)
func (*CreateStreamOp) XXX_Size ¶ added in v1.1.0
func (m *CreateStreamOp) XXX_Size() int
func (*CreateStreamOp) XXX_Unmarshal ¶ added in v1.1.0
func (m *CreateStreamOp) XXX_Unmarshal(b []byte) error
type CreateStreamRequest ¶
type CreateStreamRequest struct { Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Group string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"` ReplicationFactor int32 `protobuf:"varint,4,opt,name=replicationFactor,proto3" json:"replicationFactor,omitempty"` Partitions int32 `protobuf:"varint,5,opt,name=partitions,proto3" json:"partitions,omitempty"` RetentionMaxBytes *NullableInt64 `protobuf:"bytes,6,opt,name=RetentionMaxBytes,proto3" json:"RetentionMaxBytes,omitempty"` RetentionMaxMessages *NullableInt64 `protobuf:"bytes,7,opt,name=RetentionMaxMessages,proto3" json:"RetentionMaxMessages,omitempty"` RetentionMaxAge *NullableInt64 `protobuf:"bytes,8,opt,name=RetentionMaxAge,proto3" json:"RetentionMaxAge,omitempty"` CleanerInterval *NullableInt64 `protobuf:"bytes,9,opt,name=CleanerInterval,proto3" json:"CleanerInterval,omitempty"` SegmentMaxBytes *NullableInt64 `protobuf:"bytes,10,opt,name=SegmentMaxBytes,proto3" json:"SegmentMaxBytes,omitempty"` SegmentMaxAge *NullableInt64 `protobuf:"bytes,11,opt,name=SegmentMaxAge,proto3" json:"SegmentMaxAge,omitempty"` CompactMaxGoroutines *NullableInt32 `protobuf:"bytes,12,opt,name=CompactMaxGoroutines,proto3" json:"CompactMaxGoroutines,omitempty"` CompactEnabled *NullableBool `protobuf:"bytes,13,opt,name=CompactEnabled,proto3" json:"CompactEnabled,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CreateStreamRequest is sent to create a new stream.
func (*CreateStreamRequest) Descriptor ¶
func (*CreateStreamRequest) Descriptor() ([]byte, []int)
func (*CreateStreamRequest) GetCleanerInterval ¶ added in v1.1.0
func (m *CreateStreamRequest) GetCleanerInterval() *NullableInt64
func (*CreateStreamRequest) GetCompactEnabled ¶ added in v1.1.0
func (m *CreateStreamRequest) GetCompactEnabled() *NullableBool
func (*CreateStreamRequest) GetCompactMaxGoroutines ¶ added in v1.1.0
func (m *CreateStreamRequest) GetCompactMaxGoroutines() *NullableInt32
func (*CreateStreamRequest) GetGroup ¶
func (m *CreateStreamRequest) GetGroup() string
func (*CreateStreamRequest) GetName ¶
func (m *CreateStreamRequest) GetName() string
func (*CreateStreamRequest) GetPartitions ¶
func (m *CreateStreamRequest) GetPartitions() int32
func (*CreateStreamRequest) GetReplicationFactor ¶
func (m *CreateStreamRequest) GetReplicationFactor() int32
func (*CreateStreamRequest) GetRetentionMaxAge ¶ added in v1.1.0
func (m *CreateStreamRequest) GetRetentionMaxAge() *NullableInt64
func (*CreateStreamRequest) GetRetentionMaxBytes ¶ added in v1.1.0
func (m *CreateStreamRequest) GetRetentionMaxBytes() *NullableInt64
func (*CreateStreamRequest) GetRetentionMaxMessages ¶ added in v1.1.0
func (m *CreateStreamRequest) GetRetentionMaxMessages() *NullableInt64
func (*CreateStreamRequest) GetSegmentMaxAge ¶ added in v1.1.0
func (m *CreateStreamRequest) GetSegmentMaxAge() *NullableInt64
func (*CreateStreamRequest) GetSegmentMaxBytes ¶ added in v1.1.0
func (m *CreateStreamRequest) GetSegmentMaxBytes() *NullableInt64
func (*CreateStreamRequest) GetSubject ¶
func (m *CreateStreamRequest) GetSubject() string
func (*CreateStreamRequest) Marshal ¶
func (m *CreateStreamRequest) Marshal() (dAtA []byte, err error)
func (*CreateStreamRequest) MarshalTo ¶
func (m *CreateStreamRequest) MarshalTo(dAtA []byte) (int, error)
func (*CreateStreamRequest) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *CreateStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateStreamRequest) ProtoMessage ¶
func (*CreateStreamRequest) ProtoMessage()
func (*CreateStreamRequest) Reset ¶
func (m *CreateStreamRequest) Reset()
func (*CreateStreamRequest) Size ¶
func (m *CreateStreamRequest) Size() (n int)
func (*CreateStreamRequest) String ¶
func (m *CreateStreamRequest) String() string
func (*CreateStreamRequest) Unmarshal ¶
func (m *CreateStreamRequest) Unmarshal(dAtA []byte) error
func (*CreateStreamRequest) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *CreateStreamRequest) XXX_DiscardUnknown()
func (*CreateStreamRequest) XXX_Marshal ¶ added in v1.1.0
func (m *CreateStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateStreamRequest) XXX_Merge ¶ added in v1.1.0
func (m *CreateStreamRequest) XXX_Merge(src proto.Message)
func (*CreateStreamRequest) XXX_Size ¶ added in v1.1.0
func (m *CreateStreamRequest) XXX_Size() int
func (*CreateStreamRequest) XXX_Unmarshal ¶ added in v1.1.0
func (m *CreateStreamRequest) XXX_Unmarshal(b []byte) error
type CreateStreamResponse ¶
type CreateStreamResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CreateStreamResponse is sent by server after creating a stream.
func (*CreateStreamResponse) Descriptor ¶
func (*CreateStreamResponse) Descriptor() ([]byte, []int)
func (*CreateStreamResponse) Marshal ¶
func (m *CreateStreamResponse) Marshal() (dAtA []byte, err error)
func (*CreateStreamResponse) MarshalTo ¶
func (m *CreateStreamResponse) MarshalTo(dAtA []byte) (int, error)
func (*CreateStreamResponse) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *CreateStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateStreamResponse) ProtoMessage ¶
func (*CreateStreamResponse) ProtoMessage()
func (*CreateStreamResponse) Reset ¶
func (m *CreateStreamResponse) Reset()
func (*CreateStreamResponse) Size ¶
func (m *CreateStreamResponse) Size() (n int)
func (*CreateStreamResponse) String ¶
func (m *CreateStreamResponse) String() string
func (*CreateStreamResponse) Unmarshal ¶
func (m *CreateStreamResponse) Unmarshal(dAtA []byte) error
func (*CreateStreamResponse) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *CreateStreamResponse) XXX_DiscardUnknown()
func (*CreateStreamResponse) XXX_Marshal ¶ added in v1.1.0
func (m *CreateStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateStreamResponse) XXX_Merge ¶ added in v1.1.0
func (m *CreateStreamResponse) XXX_Merge(src proto.Message)
func (*CreateStreamResponse) XXX_Size ¶ added in v1.1.0
func (m *CreateStreamResponse) XXX_Size() int
func (*CreateStreamResponse) XXX_Unmarshal ¶ added in v1.1.0
func (m *CreateStreamResponse) XXX_Unmarshal(b []byte) error
type DeleteStreamOp ¶
type DeleteStreamOp struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
DeleteStreamOp represents a stream deletion operation.
func (*DeleteStreamOp) Descriptor ¶
func (*DeleteStreamOp) Descriptor() ([]byte, []int)
func (*DeleteStreamOp) GetStream ¶
func (m *DeleteStreamOp) GetStream() string
func (*DeleteStreamOp) Marshal ¶
func (m *DeleteStreamOp) Marshal() (dAtA []byte, err error)
func (*DeleteStreamOp) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *DeleteStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeleteStreamOp) ProtoMessage ¶
func (*DeleteStreamOp) ProtoMessage()
func (*DeleteStreamOp) Reset ¶
func (m *DeleteStreamOp) Reset()
func (*DeleteStreamOp) Size ¶
func (m *DeleteStreamOp) Size() (n int)
func (*DeleteStreamOp) String ¶
func (m *DeleteStreamOp) String() string
func (*DeleteStreamOp) Unmarshal ¶
func (m *DeleteStreamOp) Unmarshal(dAtA []byte) error
func (*DeleteStreamOp) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *DeleteStreamOp) XXX_DiscardUnknown()
func (*DeleteStreamOp) XXX_Marshal ¶ added in v1.1.0
func (m *DeleteStreamOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteStreamOp) XXX_Merge ¶ added in v1.1.0
func (m *DeleteStreamOp) XXX_Merge(src proto.Message)
func (*DeleteStreamOp) XXX_Size ¶ added in v1.1.0
func (m *DeleteStreamOp) XXX_Size() int
func (*DeleteStreamOp) XXX_Unmarshal ¶ added in v1.1.0
func (m *DeleteStreamOp) XXX_Unmarshal(b []byte) error
type DeleteStreamRequest ¶
type DeleteStreamRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
DeleteStreamRequest is sent to delete a stream.
func (*DeleteStreamRequest) Descriptor ¶
func (*DeleteStreamRequest) Descriptor() ([]byte, []int)
func (*DeleteStreamRequest) GetName ¶
func (m *DeleteStreamRequest) GetName() string
func (*DeleteStreamRequest) Marshal ¶
func (m *DeleteStreamRequest) Marshal() (dAtA []byte, err error)
func (*DeleteStreamRequest) MarshalTo ¶
func (m *DeleteStreamRequest) MarshalTo(dAtA []byte) (int, error)
func (*DeleteStreamRequest) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *DeleteStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeleteStreamRequest) ProtoMessage ¶
func (*DeleteStreamRequest) ProtoMessage()
func (*DeleteStreamRequest) Reset ¶
func (m *DeleteStreamRequest) Reset()
func (*DeleteStreamRequest) Size ¶
func (m *DeleteStreamRequest) Size() (n int)
func (*DeleteStreamRequest) String ¶
func (m *DeleteStreamRequest) String() string
func (*DeleteStreamRequest) Unmarshal ¶
func (m *DeleteStreamRequest) Unmarshal(dAtA []byte) error
func (*DeleteStreamRequest) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *DeleteStreamRequest) XXX_DiscardUnknown()
func (*DeleteStreamRequest) XXX_Marshal ¶ added in v1.1.0
func (m *DeleteStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteStreamRequest) XXX_Merge ¶ added in v1.1.0
func (m *DeleteStreamRequest) XXX_Merge(src proto.Message)
func (*DeleteStreamRequest) XXX_Size ¶ added in v1.1.0
func (m *DeleteStreamRequest) XXX_Size() int
func (*DeleteStreamRequest) XXX_Unmarshal ¶ added in v1.1.0
func (m *DeleteStreamRequest) XXX_Unmarshal(b []byte) error
type DeleteStreamResponse ¶
type DeleteStreamResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
DeleteStreamResponse is sent by server after deleting a stream.
func (*DeleteStreamResponse) Descriptor ¶
func (*DeleteStreamResponse) Descriptor() ([]byte, []int)
func (*DeleteStreamResponse) Marshal ¶
func (m *DeleteStreamResponse) Marshal() (dAtA []byte, err error)
func (*DeleteStreamResponse) MarshalTo ¶
func (m *DeleteStreamResponse) MarshalTo(dAtA []byte) (int, error)
func (*DeleteStreamResponse) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *DeleteStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeleteStreamResponse) ProtoMessage ¶
func (*DeleteStreamResponse) ProtoMessage()
func (*DeleteStreamResponse) Reset ¶
func (m *DeleteStreamResponse) Reset()
func (*DeleteStreamResponse) Size ¶
func (m *DeleteStreamResponse) Size() (n int)
func (*DeleteStreamResponse) String ¶
func (m *DeleteStreamResponse) String() string
func (*DeleteStreamResponse) Unmarshal ¶
func (m *DeleteStreamResponse) Unmarshal(dAtA []byte) error
func (*DeleteStreamResponse) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *DeleteStreamResponse) XXX_DiscardUnknown()
func (*DeleteStreamResponse) XXX_Marshal ¶ added in v1.1.0
func (m *DeleteStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteStreamResponse) XXX_Merge ¶ added in v1.1.0
func (m *DeleteStreamResponse) XXX_Merge(src proto.Message)
func (*DeleteStreamResponse) XXX_Size ¶ added in v1.1.0
func (m *DeleteStreamResponse) XXX_Size() int
func (*DeleteStreamResponse) XXX_Unmarshal ¶ added in v1.1.0
func (m *DeleteStreamResponse) XXX_Unmarshal(b []byte) error
type FetchMetadataRequest ¶
type FetchMetadataRequest struct { Streams []string `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
FetchMetadataRequest is sent to retrieve the latest cluster metadata.
func (*FetchMetadataRequest) Descriptor ¶
func (*FetchMetadataRequest) Descriptor() ([]byte, []int)
func (*FetchMetadataRequest) GetStreams ¶
func (m *FetchMetadataRequest) GetStreams() []string
func (*FetchMetadataRequest) Marshal ¶
func (m *FetchMetadataRequest) Marshal() (dAtA []byte, err error)
func (*FetchMetadataRequest) MarshalTo ¶
func (m *FetchMetadataRequest) MarshalTo(dAtA []byte) (int, error)
func (*FetchMetadataRequest) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *FetchMetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FetchMetadataRequest) ProtoMessage ¶
func (*FetchMetadataRequest) ProtoMessage()
func (*FetchMetadataRequest) Reset ¶
func (m *FetchMetadataRequest) Reset()
func (*FetchMetadataRequest) Size ¶
func (m *FetchMetadataRequest) Size() (n int)
func (*FetchMetadataRequest) String ¶
func (m *FetchMetadataRequest) String() string
func (*FetchMetadataRequest) Unmarshal ¶
func (m *FetchMetadataRequest) Unmarshal(dAtA []byte) error
func (*FetchMetadataRequest) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *FetchMetadataRequest) XXX_DiscardUnknown()
func (*FetchMetadataRequest) XXX_Marshal ¶ added in v1.1.0
func (m *FetchMetadataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FetchMetadataRequest) XXX_Merge ¶ added in v1.1.0
func (m *FetchMetadataRequest) XXX_Merge(src proto.Message)
func (*FetchMetadataRequest) XXX_Size ¶ added in v1.1.0
func (m *FetchMetadataRequest) XXX_Size() int
func (*FetchMetadataRequest) XXX_Unmarshal ¶ added in v1.1.0
func (m *FetchMetadataRequest) XXX_Unmarshal(b []byte) error
type FetchMetadataResponse ¶
type FetchMetadataResponse struct { Brokers []*Broker `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"` Metadata []*StreamMetadata `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
FetchMetadataResponse contains the cluster metadata requested.
func (*FetchMetadataResponse) Descriptor ¶
func (*FetchMetadataResponse) Descriptor() ([]byte, []int)
func (*FetchMetadataResponse) GetBrokers ¶
func (m *FetchMetadataResponse) GetBrokers() []*Broker
func (*FetchMetadataResponse) GetMetadata ¶
func (m *FetchMetadataResponse) GetMetadata() []*StreamMetadata
func (*FetchMetadataResponse) Marshal ¶
func (m *FetchMetadataResponse) Marshal() (dAtA []byte, err error)
func (*FetchMetadataResponse) MarshalTo ¶
func (m *FetchMetadataResponse) MarshalTo(dAtA []byte) (int, error)
func (*FetchMetadataResponse) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *FetchMetadataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FetchMetadataResponse) ProtoMessage ¶
func (*FetchMetadataResponse) ProtoMessage()
func (*FetchMetadataResponse) Reset ¶
func (m *FetchMetadataResponse) Reset()
func (*FetchMetadataResponse) Size ¶
func (m *FetchMetadataResponse) Size() (n int)
func (*FetchMetadataResponse) String ¶
func (m *FetchMetadataResponse) String() string
func (*FetchMetadataResponse) Unmarshal ¶
func (m *FetchMetadataResponse) Unmarshal(dAtA []byte) error
func (*FetchMetadataResponse) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *FetchMetadataResponse) XXX_DiscardUnknown()
func (*FetchMetadataResponse) XXX_Marshal ¶ added in v1.1.0
func (m *FetchMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FetchMetadataResponse) XXX_Merge ¶ added in v1.1.0
func (m *FetchMetadataResponse) XXX_Merge(src proto.Message)
func (*FetchMetadataResponse) XXX_Size ¶ added in v1.1.0
func (m *FetchMetadataResponse) XXX_Size() int
func (*FetchMetadataResponse) XXX_Unmarshal ¶ added in v1.1.0
func (m *FetchMetadataResponse) XXX_Unmarshal(b []byte) error
type Message ¶
type Message struct { Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Stream string `protobuf:"bytes,5,opt,name=stream,proto3" json:"stream,omitempty"` Partition int32 `protobuf:"varint,6,opt,name=partition,proto3" json:"partition,omitempty"` Subject string `protobuf:"bytes,7,opt,name=subject,proto3" json:"subject,omitempty"` ReplySubject string `protobuf:"bytes,8,opt,name=replySubject,proto3" json:"replySubject,omitempty"` Headers map[string][]byte `` /* 155-byte string literal not displayed */ AckInbox string `protobuf:"bytes,10,opt,name=ackInbox,proto3" json:"ackInbox,omitempty"` CorrelationId string `protobuf:"bytes,11,opt,name=correlationId,proto3" json:"correlationId,omitempty"` AckPolicy AckPolicy `protobuf:"varint,12,opt,name=ackPolicy,proto3,enum=proto.AckPolicy" json:"ackPolicy,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Message represents a message from a stream.
func (*Message) Descriptor ¶
func (*Message) GetAckInbox ¶
func (*Message) GetAckPolicy ¶
func (*Message) GetCorrelationId ¶
func (*Message) GetHeaders ¶
func (*Message) GetPartition ¶
func (*Message) GetReplySubject ¶
func (*Message) GetSubject ¶
func (*Message) GetTimestamp ¶
func (*Message) MarshalToSizedBuffer ¶ added in v1.1.0
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *Message) XXX_DiscardUnknown()
func (*Message) XXX_Marshal ¶ added in v1.1.0
func (*Message) XXX_Unmarshal ¶ added in v1.1.0
type NullableBool ¶ added in v1.1.0
type NullableBool struct { Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NullableBool) Descriptor ¶ added in v1.1.0
func (*NullableBool) Descriptor() ([]byte, []int)
func (*NullableBool) GetValue ¶ added in v1.1.0
func (m *NullableBool) GetValue() bool
func (*NullableBool) Marshal ¶ added in v1.1.0
func (m *NullableBool) Marshal() (dAtA []byte, err error)
func (*NullableBool) MarshalTo ¶ added in v1.1.0
func (m *NullableBool) MarshalTo(dAtA []byte) (int, error)
func (*NullableBool) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *NullableBool) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NullableBool) ProtoMessage ¶ added in v1.1.0
func (*NullableBool) ProtoMessage()
func (*NullableBool) Reset ¶ added in v1.1.0
func (m *NullableBool) Reset()
func (*NullableBool) Size ¶ added in v1.1.0
func (m *NullableBool) Size() (n int)
func (*NullableBool) String ¶ added in v1.1.0
func (m *NullableBool) String() string
func (*NullableBool) Unmarshal ¶ added in v1.1.0
func (m *NullableBool) Unmarshal(dAtA []byte) error
func (*NullableBool) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *NullableBool) XXX_DiscardUnknown()
func (*NullableBool) XXX_Marshal ¶ added in v1.1.0
func (m *NullableBool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NullableBool) XXX_Merge ¶ added in v1.1.0
func (m *NullableBool) XXX_Merge(src proto.Message)
func (*NullableBool) XXX_Size ¶ added in v1.1.0
func (m *NullableBool) XXX_Size() int
func (*NullableBool) XXX_Unmarshal ¶ added in v1.1.0
func (m *NullableBool) XXX_Unmarshal(b []byte) error
type NullableInt32 ¶ added in v1.1.0
type NullableInt32 struct { Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NullableInt32) Descriptor ¶ added in v1.1.0
func (*NullableInt32) Descriptor() ([]byte, []int)
func (*NullableInt32) GetValue ¶ added in v1.1.0
func (m *NullableInt32) GetValue() int32
func (*NullableInt32) Marshal ¶ added in v1.1.0
func (m *NullableInt32) Marshal() (dAtA []byte, err error)
func (*NullableInt32) MarshalTo ¶ added in v1.1.0
func (m *NullableInt32) MarshalTo(dAtA []byte) (int, error)
func (*NullableInt32) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *NullableInt32) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NullableInt32) ProtoMessage ¶ added in v1.1.0
func (*NullableInt32) ProtoMessage()
func (*NullableInt32) Reset ¶ added in v1.1.0
func (m *NullableInt32) Reset()
func (*NullableInt32) Size ¶ added in v1.1.0
func (m *NullableInt32) Size() (n int)
func (*NullableInt32) String ¶ added in v1.1.0
func (m *NullableInt32) String() string
func (*NullableInt32) Unmarshal ¶ added in v1.1.0
func (m *NullableInt32) Unmarshal(dAtA []byte) error
func (*NullableInt32) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *NullableInt32) XXX_DiscardUnknown()
func (*NullableInt32) XXX_Marshal ¶ added in v1.1.0
func (m *NullableInt32) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NullableInt32) XXX_Merge ¶ added in v1.1.0
func (m *NullableInt32) XXX_Merge(src proto.Message)
func (*NullableInt32) XXX_Size ¶ added in v1.1.0
func (m *NullableInt32) XXX_Size() int
func (*NullableInt32) XXX_Unmarshal ¶ added in v1.1.0
func (m *NullableInt32) XXX_Unmarshal(b []byte) error
type NullableInt64 ¶ added in v1.1.0
type NullableInt64 struct { Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NullableInt64) Descriptor ¶ added in v1.1.0
func (*NullableInt64) Descriptor() ([]byte, []int)
func (*NullableInt64) GetValue ¶ added in v1.1.0
func (m *NullableInt64) GetValue() int64
func (*NullableInt64) Marshal ¶ added in v1.1.0
func (m *NullableInt64) Marshal() (dAtA []byte, err error)
func (*NullableInt64) MarshalTo ¶ added in v1.1.0
func (m *NullableInt64) MarshalTo(dAtA []byte) (int, error)
func (*NullableInt64) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *NullableInt64) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NullableInt64) ProtoMessage ¶ added in v1.1.0
func (*NullableInt64) ProtoMessage()
func (*NullableInt64) Reset ¶ added in v1.1.0
func (m *NullableInt64) Reset()
func (*NullableInt64) Size ¶ added in v1.1.0
func (m *NullableInt64) Size() (n int)
func (*NullableInt64) String ¶ added in v1.1.0
func (m *NullableInt64) String() string
func (*NullableInt64) Unmarshal ¶ added in v1.1.0
func (m *NullableInt64) Unmarshal(dAtA []byte) error
func (*NullableInt64) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *NullableInt64) XXX_DiscardUnknown()
func (*NullableInt64) XXX_Marshal ¶ added in v1.1.0
func (m *NullableInt64) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NullableInt64) XXX_Merge ¶ added in v1.1.0
func (m *NullableInt64) XXX_Merge(src proto.Message)
func (*NullableInt64) XXX_Size ¶ added in v1.1.0
func (m *NullableInt64) XXX_Size() int
func (*NullableInt64) XXX_Unmarshal ¶ added in v1.1.0
func (m *NullableInt64) XXX_Unmarshal(b []byte) error
type PartitionMetadata ¶
type PartitionMetadata struct { Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Leader string `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"` Replicas []string `protobuf:"bytes,3,rep,name=replicas,proto3" json:"replicas,omitempty"` Isr []string `protobuf:"bytes,4,rep,name=isr,proto3" json:"isr,omitempty"` HighWatermark int64 `protobuf:"varint,5,opt,name=highWatermark,proto3" json:"highWatermark,omitempty"` NewestOffset int64 `protobuf:"varint,6,opt,name=newestOffset,proto3" json:"newestOffset,omitempty"` Paused bool `protobuf:"varint,7,opt,name=paused,proto3" json:"paused,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PartitionMetadata contains information for a stream partition.
func (*PartitionMetadata) Descriptor ¶
func (*PartitionMetadata) Descriptor() ([]byte, []int)
func (*PartitionMetadata) GetHighWatermark ¶ added in v1.9.1
func (m *PartitionMetadata) GetHighWatermark() int64
func (*PartitionMetadata) GetId ¶
func (m *PartitionMetadata) GetId() int32
func (*PartitionMetadata) GetIsr ¶
func (m *PartitionMetadata) GetIsr() []string
func (*PartitionMetadata) GetLeader ¶
func (m *PartitionMetadata) GetLeader() string
func (*PartitionMetadata) GetNewestOffset ¶ added in v1.9.1
func (m *PartitionMetadata) GetNewestOffset() int64
func (*PartitionMetadata) GetPaused ¶ added in v1.9.1
func (m *PartitionMetadata) GetPaused() bool
func (*PartitionMetadata) GetReplicas ¶
func (m *PartitionMetadata) GetReplicas() []string
func (*PartitionMetadata) Marshal ¶
func (m *PartitionMetadata) Marshal() (dAtA []byte, err error)
func (*PartitionMetadata) MarshalTo ¶
func (m *PartitionMetadata) MarshalTo(dAtA []byte) (int, error)
func (*PartitionMetadata) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *PartitionMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PartitionMetadata) ProtoMessage ¶
func (*PartitionMetadata) ProtoMessage()
func (*PartitionMetadata) Reset ¶
func (m *PartitionMetadata) Reset()
func (*PartitionMetadata) Size ¶
func (m *PartitionMetadata) Size() (n int)
func (*PartitionMetadata) String ¶
func (m *PartitionMetadata) String() string
func (*PartitionMetadata) Unmarshal ¶
func (m *PartitionMetadata) Unmarshal(dAtA []byte) error
func (*PartitionMetadata) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *PartitionMetadata) XXX_DiscardUnknown()
func (*PartitionMetadata) XXX_Marshal ¶ added in v1.1.0
func (m *PartitionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PartitionMetadata) XXX_Merge ¶ added in v1.1.0
func (m *PartitionMetadata) XXX_Merge(src proto.Message)
func (*PartitionMetadata) XXX_Size ¶ added in v1.1.0
func (m *PartitionMetadata) XXX_Size() int
func (*PartitionMetadata) XXX_Unmarshal ¶ added in v1.1.0
func (m *PartitionMetadata) XXX_Unmarshal(b []byte) error
type PauseStreamOp ¶
type PauseStreamOp struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partitions []int32 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"` ResumeAll bool `protobuf:"varint,3,opt,name=resumeAll,proto3" json:"resumeAll,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PauseStreamOp represents a stream pause operation.
func (*PauseStreamOp) Descriptor ¶
func (*PauseStreamOp) Descriptor() ([]byte, []int)
func (*PauseStreamOp) GetPartitions ¶
func (m *PauseStreamOp) GetPartitions() []int32
func (*PauseStreamOp) GetResumeAll ¶
func (m *PauseStreamOp) GetResumeAll() bool
func (*PauseStreamOp) GetStream ¶
func (m *PauseStreamOp) GetStream() string
func (*PauseStreamOp) Marshal ¶
func (m *PauseStreamOp) Marshal() (dAtA []byte, err error)
func (*PauseStreamOp) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *PauseStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PauseStreamOp) ProtoMessage ¶
func (*PauseStreamOp) ProtoMessage()
func (*PauseStreamOp) Reset ¶
func (m *PauseStreamOp) Reset()
func (*PauseStreamOp) Size ¶
func (m *PauseStreamOp) Size() (n int)
func (*PauseStreamOp) String ¶
func (m *PauseStreamOp) String() string
func (*PauseStreamOp) Unmarshal ¶
func (m *PauseStreamOp) Unmarshal(dAtA []byte) error
func (*PauseStreamOp) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *PauseStreamOp) XXX_DiscardUnknown()
func (*PauseStreamOp) XXX_Marshal ¶ added in v1.1.0
func (m *PauseStreamOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PauseStreamOp) XXX_Merge ¶ added in v1.1.0
func (m *PauseStreamOp) XXX_Merge(src proto.Message)
func (*PauseStreamOp) XXX_Size ¶ added in v1.1.0
func (m *PauseStreamOp) XXX_Size() int
func (*PauseStreamOp) XXX_Unmarshal ¶ added in v1.1.0
func (m *PauseStreamOp) XXX_Unmarshal(b []byte) error
type PauseStreamRequest ¶
type PauseStreamRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Partitions []int32 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"` ResumeAll bool `protobuf:"varint,3,opt,name=resumeAll,proto3" json:"resumeAll,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PauseStreamRequest is sent to pause the specified stream partitions. If no partitions are specified, this will pause all partitions in the stream. Partitions are resumed when they are published to via the Liftbridge Publish API.
func (*PauseStreamRequest) Descriptor ¶
func (*PauseStreamRequest) Descriptor() ([]byte, []int)
func (*PauseStreamRequest) GetName ¶
func (m *PauseStreamRequest) GetName() string
func (*PauseStreamRequest) GetPartitions ¶
func (m *PauseStreamRequest) GetPartitions() []int32
func (*PauseStreamRequest) GetResumeAll ¶
func (m *PauseStreamRequest) GetResumeAll() bool
func (*PauseStreamRequest) Marshal ¶
func (m *PauseStreamRequest) Marshal() (dAtA []byte, err error)
func (*PauseStreamRequest) MarshalTo ¶
func (m *PauseStreamRequest) MarshalTo(dAtA []byte) (int, error)
func (*PauseStreamRequest) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *PauseStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PauseStreamRequest) ProtoMessage ¶
func (*PauseStreamRequest) ProtoMessage()
func (*PauseStreamRequest) Reset ¶
func (m *PauseStreamRequest) Reset()
func (*PauseStreamRequest) Size ¶
func (m *PauseStreamRequest) Size() (n int)
func (*PauseStreamRequest) String ¶
func (m *PauseStreamRequest) String() string
func (*PauseStreamRequest) Unmarshal ¶
func (m *PauseStreamRequest) Unmarshal(dAtA []byte) error
func (*PauseStreamRequest) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *PauseStreamRequest) XXX_DiscardUnknown()
func (*PauseStreamRequest) XXX_Marshal ¶ added in v1.1.0
func (m *PauseStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PauseStreamRequest) XXX_Merge ¶ added in v1.1.0
func (m *PauseStreamRequest) XXX_Merge(src proto.Message)
func (*PauseStreamRequest) XXX_Size ¶ added in v1.1.0
func (m *PauseStreamRequest) XXX_Size() int
func (*PauseStreamRequest) XXX_Unmarshal ¶ added in v1.1.0
func (m *PauseStreamRequest) XXX_Unmarshal(b []byte) error
type PauseStreamResponse ¶
type PauseStreamResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PauseStreamResponse is sent by server after pausing a stream.
func (*PauseStreamResponse) Descriptor ¶
func (*PauseStreamResponse) Descriptor() ([]byte, []int)
func (*PauseStreamResponse) Marshal ¶
func (m *PauseStreamResponse) Marshal() (dAtA []byte, err error)
func (*PauseStreamResponse) MarshalTo ¶
func (m *PauseStreamResponse) MarshalTo(dAtA []byte) (int, error)
func (*PauseStreamResponse) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *PauseStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PauseStreamResponse) ProtoMessage ¶
func (*PauseStreamResponse) ProtoMessage()
func (*PauseStreamResponse) Reset ¶
func (m *PauseStreamResponse) Reset()
func (*PauseStreamResponse) Size ¶
func (m *PauseStreamResponse) Size() (n int)
func (*PauseStreamResponse) String ¶
func (m *PauseStreamResponse) String() string
func (*PauseStreamResponse) Unmarshal ¶
func (m *PauseStreamResponse) Unmarshal(dAtA []byte) error
func (*PauseStreamResponse) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *PauseStreamResponse) XXX_DiscardUnknown()
func (*PauseStreamResponse) XXX_Marshal ¶ added in v1.1.0
func (m *PauseStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PauseStreamResponse) XXX_Merge ¶ added in v1.1.0
func (m *PauseStreamResponse) XXX_Merge(src proto.Message)
func (*PauseStreamResponse) XXX_Size ¶ added in v1.1.0
func (m *PauseStreamResponse) XXX_Size() int
func (*PauseStreamResponse) XXX_Unmarshal ¶ added in v1.1.0
func (m *PauseStreamResponse) XXX_Unmarshal(b []byte) error
type PublishRequest ¶
type PublishRequest struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` Stream string `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"` Partition int32 `protobuf:"varint,4,opt,name=partition,proto3" json:"partition,omitempty"` Headers map[string][]byte `` /* 155-byte string literal not displayed */ AckInbox string `protobuf:"bytes,6,opt,name=ackInbox,proto3" json:"ackInbox,omitempty"` CorrelationId string `protobuf:"bytes,7,opt,name=correlationId,proto3" json:"correlationId,omitempty"` AckPolicy AckPolicy `protobuf:"varint,8,opt,name=ackPolicy,proto3,enum=proto.AckPolicy" json:"ackPolicy,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PublishRequest is sent to publish a new message to a stream.
func (*PublishRequest) Descriptor ¶
func (*PublishRequest) Descriptor() ([]byte, []int)
func (*PublishRequest) GetAckInbox ¶
func (m *PublishRequest) GetAckInbox() string
func (*PublishRequest) GetAckPolicy ¶
func (m *PublishRequest) GetAckPolicy() AckPolicy
func (*PublishRequest) GetCorrelationId ¶
func (m *PublishRequest) GetCorrelationId() string
func (*PublishRequest) GetHeaders ¶
func (m *PublishRequest) GetHeaders() map[string][]byte
func (*PublishRequest) GetKey ¶
func (m *PublishRequest) GetKey() []byte
func (*PublishRequest) GetPartition ¶
func (m *PublishRequest) GetPartition() int32
func (*PublishRequest) GetStream ¶
func (m *PublishRequest) GetStream() string
func (*PublishRequest) GetValue ¶
func (m *PublishRequest) GetValue() []byte
func (*PublishRequest) Marshal ¶
func (m *PublishRequest) Marshal() (dAtA []byte, err error)
func (*PublishRequest) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *PublishRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PublishRequest) ProtoMessage ¶
func (*PublishRequest) ProtoMessage()
func (*PublishRequest) Reset ¶
func (m *PublishRequest) Reset()
func (*PublishRequest) Size ¶
func (m *PublishRequest) Size() (n int)
func (*PublishRequest) String ¶
func (m *PublishRequest) String() string
func (*PublishRequest) Unmarshal ¶
func (m *PublishRequest) Unmarshal(dAtA []byte) error
func (*PublishRequest) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *PublishRequest) XXX_DiscardUnknown()
func (*PublishRequest) XXX_Marshal ¶ added in v1.1.0
func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PublishRequest) XXX_Merge ¶ added in v1.1.0
func (m *PublishRequest) XXX_Merge(src proto.Message)
func (*PublishRequest) XXX_Size ¶ added in v1.1.0
func (m *PublishRequest) XXX_Size() int
func (*PublishRequest) XXX_Unmarshal ¶ added in v1.1.0
func (m *PublishRequest) XXX_Unmarshal(b []byte) error
type PublishResponse ¶
type PublishResponse struct { Ack *Ack `protobuf:"bytes,1,opt,name=ack,proto3" json:"ack,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PublishResponse is sent by the server after publishing a message to a stream.
func (*PublishResponse) Descriptor ¶
func (*PublishResponse) Descriptor() ([]byte, []int)
func (*PublishResponse) GetAck ¶
func (m *PublishResponse) GetAck() *Ack
func (*PublishResponse) Marshal ¶
func (m *PublishResponse) Marshal() (dAtA []byte, err error)
func (*PublishResponse) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *PublishResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PublishResponse) ProtoMessage ¶
func (*PublishResponse) ProtoMessage()
func (*PublishResponse) Reset ¶
func (m *PublishResponse) Reset()
func (*PublishResponse) Size ¶
func (m *PublishResponse) Size() (n int)
func (*PublishResponse) String ¶
func (m *PublishResponse) String() string
func (*PublishResponse) Unmarshal ¶
func (m *PublishResponse) Unmarshal(dAtA []byte) error
func (*PublishResponse) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *PublishResponse) XXX_DiscardUnknown()
func (*PublishResponse) XXX_Marshal ¶ added in v1.1.0
func (m *PublishResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PublishResponse) XXX_Merge ¶ added in v1.1.0
func (m *PublishResponse) XXX_Merge(src proto.Message)
func (*PublishResponse) XXX_Size ¶ added in v1.1.0
func (m *PublishResponse) XXX_Size() int
func (*PublishResponse) XXX_Unmarshal ¶ added in v1.1.0
func (m *PublishResponse) XXX_Unmarshal(b []byte) error
type PublishToSubjectRequest ¶
type PublishToSubjectRequest struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` Subject string `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"` Headers map[string][]byte `` /* 155-byte string literal not displayed */ AckInbox string `protobuf:"bytes,5,opt,name=ackInbox,proto3" json:"ackInbox,omitempty"` CorrelationId string `protobuf:"bytes,6,opt,name=correlationId,proto3" json:"correlationId,omitempty"` AckPolicy AckPolicy `protobuf:"varint,7,opt,name=ackPolicy,proto3,enum=proto.AckPolicy" json:"ackPolicy,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PublishToSubjectRequest is sent to publish a Liftbridge message to a NATS subject.
func (*PublishToSubjectRequest) Descriptor ¶
func (*PublishToSubjectRequest) Descriptor() ([]byte, []int)
func (*PublishToSubjectRequest) GetAckInbox ¶
func (m *PublishToSubjectRequest) GetAckInbox() string
func (*PublishToSubjectRequest) GetAckPolicy ¶
func (m *PublishToSubjectRequest) GetAckPolicy() AckPolicy
func (*PublishToSubjectRequest) GetCorrelationId ¶
func (m *PublishToSubjectRequest) GetCorrelationId() string
func (*PublishToSubjectRequest) GetHeaders ¶
func (m *PublishToSubjectRequest) GetHeaders() map[string][]byte
func (*PublishToSubjectRequest) GetKey ¶
func (m *PublishToSubjectRequest) GetKey() []byte
func (*PublishToSubjectRequest) GetSubject ¶
func (m *PublishToSubjectRequest) GetSubject() string
func (*PublishToSubjectRequest) GetValue ¶
func (m *PublishToSubjectRequest) GetValue() []byte
func (*PublishToSubjectRequest) Marshal ¶
func (m *PublishToSubjectRequest) Marshal() (dAtA []byte, err error)
func (*PublishToSubjectRequest) MarshalTo ¶
func (m *PublishToSubjectRequest) MarshalTo(dAtA []byte) (int, error)
func (*PublishToSubjectRequest) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *PublishToSubjectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PublishToSubjectRequest) ProtoMessage ¶
func (*PublishToSubjectRequest) ProtoMessage()
func (*PublishToSubjectRequest) Reset ¶
func (m *PublishToSubjectRequest) Reset()
func (*PublishToSubjectRequest) Size ¶
func (m *PublishToSubjectRequest) Size() (n int)
func (*PublishToSubjectRequest) String ¶
func (m *PublishToSubjectRequest) String() string
func (*PublishToSubjectRequest) Unmarshal ¶
func (m *PublishToSubjectRequest) Unmarshal(dAtA []byte) error
func (*PublishToSubjectRequest) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *PublishToSubjectRequest) XXX_DiscardUnknown()
func (*PublishToSubjectRequest) XXX_Marshal ¶ added in v1.1.0
func (m *PublishToSubjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PublishToSubjectRequest) XXX_Merge ¶ added in v1.1.0
func (m *PublishToSubjectRequest) XXX_Merge(src proto.Message)
func (*PublishToSubjectRequest) XXX_Size ¶ added in v1.1.0
func (m *PublishToSubjectRequest) XXX_Size() int
func (*PublishToSubjectRequest) XXX_Unmarshal ¶ added in v1.1.0
func (m *PublishToSubjectRequest) XXX_Unmarshal(b []byte) error
type PublishToSubjectResponse ¶
type PublishToSubjectResponse struct { Ack *Ack `protobuf:"bytes,1,opt,name=ack,proto3" json:"ack,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PublishToSubjectResponse is sent by the server after publishing a message to a NATS subject.
func (*PublishToSubjectResponse) Descriptor ¶
func (*PublishToSubjectResponse) Descriptor() ([]byte, []int)
func (*PublishToSubjectResponse) GetAck ¶
func (m *PublishToSubjectResponse) GetAck() *Ack
func (*PublishToSubjectResponse) Marshal ¶
func (m *PublishToSubjectResponse) Marshal() (dAtA []byte, err error)
func (*PublishToSubjectResponse) MarshalTo ¶
func (m *PublishToSubjectResponse) MarshalTo(dAtA []byte) (int, error)
func (*PublishToSubjectResponse) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *PublishToSubjectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PublishToSubjectResponse) ProtoMessage ¶
func (*PublishToSubjectResponse) ProtoMessage()
func (*PublishToSubjectResponse) Reset ¶
func (m *PublishToSubjectResponse) Reset()
func (*PublishToSubjectResponse) Size ¶
func (m *PublishToSubjectResponse) Size() (n int)
func (*PublishToSubjectResponse) String ¶
func (m *PublishToSubjectResponse) String() string
func (*PublishToSubjectResponse) Unmarshal ¶
func (m *PublishToSubjectResponse) Unmarshal(dAtA []byte) error
func (*PublishToSubjectResponse) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *PublishToSubjectResponse) XXX_DiscardUnknown()
func (*PublishToSubjectResponse) XXX_Marshal ¶ added in v1.1.0
func (m *PublishToSubjectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PublishToSubjectResponse) XXX_Merge ¶ added in v1.1.0
func (m *PublishToSubjectResponse) XXX_Merge(src proto.Message)
func (*PublishToSubjectResponse) XXX_Size ¶ added in v1.1.0
func (m *PublishToSubjectResponse) XXX_Size() int
func (*PublishToSubjectResponse) XXX_Unmarshal ¶ added in v1.1.0
func (m *PublishToSubjectResponse) XXX_Unmarshal(b []byte) error
type ResumeStreamOp ¶
type ResumeStreamOp struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partitions []int32 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ResumeStreamOp represents a stream resume operation.
func (*ResumeStreamOp) Descriptor ¶
func (*ResumeStreamOp) Descriptor() ([]byte, []int)
func (*ResumeStreamOp) GetPartitions ¶
func (m *ResumeStreamOp) GetPartitions() []int32
func (*ResumeStreamOp) GetStream ¶
func (m *ResumeStreamOp) GetStream() string
func (*ResumeStreamOp) Marshal ¶
func (m *ResumeStreamOp) Marshal() (dAtA []byte, err error)
func (*ResumeStreamOp) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *ResumeStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResumeStreamOp) ProtoMessage ¶
func (*ResumeStreamOp) ProtoMessage()
func (*ResumeStreamOp) Reset ¶
func (m *ResumeStreamOp) Reset()
func (*ResumeStreamOp) Size ¶
func (m *ResumeStreamOp) Size() (n int)
func (*ResumeStreamOp) String ¶
func (m *ResumeStreamOp) String() string
func (*ResumeStreamOp) Unmarshal ¶
func (m *ResumeStreamOp) Unmarshal(dAtA []byte) error
func (*ResumeStreamOp) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *ResumeStreamOp) XXX_DiscardUnknown()
func (*ResumeStreamOp) XXX_Marshal ¶ added in v1.1.0
func (m *ResumeStreamOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResumeStreamOp) XXX_Merge ¶ added in v1.1.0
func (m *ResumeStreamOp) XXX_Merge(src proto.Message)
func (*ResumeStreamOp) XXX_Size ¶ added in v1.1.0
func (m *ResumeStreamOp) XXX_Size() int
func (*ResumeStreamOp) XXX_Unmarshal ¶ added in v1.1.0
func (m *ResumeStreamOp) XXX_Unmarshal(b []byte) error
type SetStreamReadonlyOp ¶ added in v1.9.1
type SetStreamReadonlyOp struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partitions []int32 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"` Readonly bool `protobuf:"varint,3,opt,name=readonly,proto3" json:"readonly,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ReadonlyStreamOp represents a stream readonly operation.
func (*SetStreamReadonlyOp) Descriptor ¶ added in v1.9.1
func (*SetStreamReadonlyOp) Descriptor() ([]byte, []int)
func (*SetStreamReadonlyOp) GetPartitions ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) GetPartitions() []int32
func (*SetStreamReadonlyOp) GetReadonly ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) GetReadonly() bool
func (*SetStreamReadonlyOp) GetStream ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) GetStream() string
func (*SetStreamReadonlyOp) Marshal ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) Marshal() (dAtA []byte, err error)
func (*SetStreamReadonlyOp) MarshalTo ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) MarshalTo(dAtA []byte) (int, error)
func (*SetStreamReadonlyOp) MarshalToSizedBuffer ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetStreamReadonlyOp) ProtoMessage ¶ added in v1.9.1
func (*SetStreamReadonlyOp) ProtoMessage()
func (*SetStreamReadonlyOp) Reset ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) Reset()
func (*SetStreamReadonlyOp) Size ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) Size() (n int)
func (*SetStreamReadonlyOp) String ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) String() string
func (*SetStreamReadonlyOp) Unmarshal ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) Unmarshal(dAtA []byte) error
func (*SetStreamReadonlyOp) XXX_DiscardUnknown ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) XXX_DiscardUnknown()
func (*SetStreamReadonlyOp) XXX_Marshal ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetStreamReadonlyOp) XXX_Merge ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) XXX_Merge(src proto.Message)
func (*SetStreamReadonlyOp) XXX_Size ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) XXX_Size() int
func (*SetStreamReadonlyOp) XXX_Unmarshal ¶ added in v1.9.1
func (m *SetStreamReadonlyOp) XXX_Unmarshal(b []byte) error
type SetStreamReadonlyRequest ¶ added in v1.9.1
type SetStreamReadonlyRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Partitions []int32 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"` Readonly bool `protobuf:"varint,3,opt,name=readonly,proto3" json:"readonly,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SetStreamReadonlyRequest is send to set a stream as read-only.
func (*SetStreamReadonlyRequest) Descriptor ¶ added in v1.9.1
func (*SetStreamReadonlyRequest) Descriptor() ([]byte, []int)
func (*SetStreamReadonlyRequest) GetName ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) GetName() string
func (*SetStreamReadonlyRequest) GetPartitions ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) GetPartitions() []int32
func (*SetStreamReadonlyRequest) GetReadonly ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) GetReadonly() bool
func (*SetStreamReadonlyRequest) Marshal ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) Marshal() (dAtA []byte, err error)
func (*SetStreamReadonlyRequest) MarshalTo ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) MarshalTo(dAtA []byte) (int, error)
func (*SetStreamReadonlyRequest) MarshalToSizedBuffer ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetStreamReadonlyRequest) ProtoMessage ¶ added in v1.9.1
func (*SetStreamReadonlyRequest) ProtoMessage()
func (*SetStreamReadonlyRequest) Reset ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) Reset()
func (*SetStreamReadonlyRequest) Size ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) Size() (n int)
func (*SetStreamReadonlyRequest) String ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) String() string
func (*SetStreamReadonlyRequest) Unmarshal ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) Unmarshal(dAtA []byte) error
func (*SetStreamReadonlyRequest) XXX_DiscardUnknown ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) XXX_DiscardUnknown()
func (*SetStreamReadonlyRequest) XXX_Marshal ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetStreamReadonlyRequest) XXX_Merge ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) XXX_Merge(src proto.Message)
func (*SetStreamReadonlyRequest) XXX_Size ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) XXX_Size() int
func (*SetStreamReadonlyRequest) XXX_Unmarshal ¶ added in v1.9.1
func (m *SetStreamReadonlyRequest) XXX_Unmarshal(b []byte) error
type SetStreamReadonlyResponse ¶ added in v1.9.1
type SetStreamReadonlyResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SetStreamReadonlyResponse is sent by server after setting a stream's readonly flag.
func (*SetStreamReadonlyResponse) Descriptor ¶ added in v1.9.1
func (*SetStreamReadonlyResponse) Descriptor() ([]byte, []int)
func (*SetStreamReadonlyResponse) Marshal ¶ added in v1.9.1
func (m *SetStreamReadonlyResponse) Marshal() (dAtA []byte, err error)
func (*SetStreamReadonlyResponse) MarshalTo ¶ added in v1.9.1
func (m *SetStreamReadonlyResponse) MarshalTo(dAtA []byte) (int, error)
func (*SetStreamReadonlyResponse) MarshalToSizedBuffer ¶ added in v1.9.1
func (m *SetStreamReadonlyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetStreamReadonlyResponse) ProtoMessage ¶ added in v1.9.1
func (*SetStreamReadonlyResponse) ProtoMessage()
func (*SetStreamReadonlyResponse) Reset ¶ added in v1.9.1
func (m *SetStreamReadonlyResponse) Reset()
func (*SetStreamReadonlyResponse) Size ¶ added in v1.9.1
func (m *SetStreamReadonlyResponse) Size() (n int)
func (*SetStreamReadonlyResponse) String ¶ added in v1.9.1
func (m *SetStreamReadonlyResponse) String() string
func (*SetStreamReadonlyResponse) Unmarshal ¶ added in v1.9.1
func (m *SetStreamReadonlyResponse) Unmarshal(dAtA []byte) error
func (*SetStreamReadonlyResponse) XXX_DiscardUnknown ¶ added in v1.9.1
func (m *SetStreamReadonlyResponse) XXX_DiscardUnknown()
func (*SetStreamReadonlyResponse) XXX_Marshal ¶ added in v1.9.1
func (m *SetStreamReadonlyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetStreamReadonlyResponse) XXX_Merge ¶ added in v1.9.1
func (m *SetStreamReadonlyResponse) XXX_Merge(src proto.Message)
func (*SetStreamReadonlyResponse) XXX_Size ¶ added in v1.9.1
func (m *SetStreamReadonlyResponse) XXX_Size() int
func (*SetStreamReadonlyResponse) XXX_Unmarshal ¶ added in v1.9.1
func (m *SetStreamReadonlyResponse) XXX_Unmarshal(b []byte) error
type StartPosition ¶
type StartPosition int32
StartPosition determines the start-position type on a subscription.
const ( StartPosition_NEW_ONLY StartPosition = 0 StartPosition_OFFSET StartPosition = 1 StartPosition_EARLIEST StartPosition = 2 StartPosition_LATEST StartPosition = 3 StartPosition_TIMESTAMP StartPosition = 4 )
func (StartPosition) EnumDescriptor ¶
func (StartPosition) EnumDescriptor() ([]byte, []int)
func (StartPosition) String ¶
func (x StartPosition) String() string
type StreamMetadata ¶
type StreamMetadata struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Subject string `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"` Error StreamMetadata_Error `protobuf:"varint,3,opt,name=error,proto3,enum=proto.StreamMetadata_Error" json:"error,omitempty"` Partitions map[int32]*PartitionMetadata `` /* 162-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
StreamMetadata contains information for a stream.
func (*StreamMetadata) Descriptor ¶
func (*StreamMetadata) Descriptor() ([]byte, []int)
func (*StreamMetadata) GetError ¶
func (m *StreamMetadata) GetError() StreamMetadata_Error
func (*StreamMetadata) GetName ¶
func (m *StreamMetadata) GetName() string
func (*StreamMetadata) GetPartitions ¶
func (m *StreamMetadata) GetPartitions() map[int32]*PartitionMetadata
func (*StreamMetadata) GetSubject ¶
func (m *StreamMetadata) GetSubject() string
func (*StreamMetadata) Marshal ¶
func (m *StreamMetadata) Marshal() (dAtA []byte, err error)
func (*StreamMetadata) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *StreamMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamMetadata) ProtoMessage ¶
func (*StreamMetadata) ProtoMessage()
func (*StreamMetadata) Reset ¶
func (m *StreamMetadata) Reset()
func (*StreamMetadata) Size ¶
func (m *StreamMetadata) Size() (n int)
func (*StreamMetadata) String ¶
func (m *StreamMetadata) String() string
func (*StreamMetadata) Unmarshal ¶
func (m *StreamMetadata) Unmarshal(dAtA []byte) error
func (*StreamMetadata) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *StreamMetadata) XXX_DiscardUnknown()
func (*StreamMetadata) XXX_Marshal ¶ added in v1.1.0
func (m *StreamMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamMetadata) XXX_Merge ¶ added in v1.1.0
func (m *StreamMetadata) XXX_Merge(src proto.Message)
func (*StreamMetadata) XXX_Size ¶ added in v1.1.0
func (m *StreamMetadata) XXX_Size() int
func (*StreamMetadata) XXX_Unmarshal ¶ added in v1.1.0
func (m *StreamMetadata) XXX_Unmarshal(b []byte) error
type StreamMetadata_Error ¶
type StreamMetadata_Error int32
const ( StreamMetadata_OK StreamMetadata_Error = 0 StreamMetadata_UNKNOWN_STREAM StreamMetadata_Error = 1 )
func (StreamMetadata_Error) EnumDescriptor ¶
func (StreamMetadata_Error) EnumDescriptor() ([]byte, []int)
func (StreamMetadata_Error) String ¶
func (x StreamMetadata_Error) String() string
type SubscribeRequest ¶
type SubscribeRequest struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partition int32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` StartPosition StartPosition `protobuf:"varint,3,opt,name=startPosition,proto3,enum=proto.StartPosition" json:"startPosition,omitempty"` StartOffset int64 `protobuf:"varint,4,opt,name=startOffset,proto3" json:"startOffset,omitempty"` StartTimestamp int64 `protobuf:"varint,5,opt,name=startTimestamp,proto3" json:"startTimestamp,omitempty"` ReadISRReplica bool `protobuf:"varint,6,opt,name=readISRReplica,proto3" json:"readISRReplica,omitempty"` Resume bool `protobuf:"varint,7,opt,name=resume,proto3" json:"resume,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SubscribeRequest is sent to subscribe to a stream partition.
func (*SubscribeRequest) Descriptor ¶
func (*SubscribeRequest) Descriptor() ([]byte, []int)
func (*SubscribeRequest) GetPartition ¶
func (m *SubscribeRequest) GetPartition() int32
func (*SubscribeRequest) GetReadISRReplica ¶
func (m *SubscribeRequest) GetReadISRReplica() bool
func (*SubscribeRequest) GetResume ¶ added in v1.9.2
func (m *SubscribeRequest) GetResume() bool
func (*SubscribeRequest) GetStartOffset ¶
func (m *SubscribeRequest) GetStartOffset() int64
func (*SubscribeRequest) GetStartPosition ¶
func (m *SubscribeRequest) GetStartPosition() StartPosition
func (*SubscribeRequest) GetStartTimestamp ¶
func (m *SubscribeRequest) GetStartTimestamp() int64
func (*SubscribeRequest) GetStream ¶
func (m *SubscribeRequest) GetStream() string
func (*SubscribeRequest) Marshal ¶
func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)
func (*SubscribeRequest) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *SubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) Reset ¶
func (m *SubscribeRequest) Reset()
func (*SubscribeRequest) Size ¶
func (m *SubscribeRequest) Size() (n int)
func (*SubscribeRequest) String ¶
func (m *SubscribeRequest) String() string
func (*SubscribeRequest) Unmarshal ¶
func (m *SubscribeRequest) Unmarshal(dAtA []byte) error
func (*SubscribeRequest) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *SubscribeRequest) XXX_DiscardUnknown()
func (*SubscribeRequest) XXX_Marshal ¶ added in v1.1.0
func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubscribeRequest) XXX_Merge ¶ added in v1.1.0
func (m *SubscribeRequest) XXX_Merge(src proto.Message)
func (*SubscribeRequest) XXX_Size ¶ added in v1.1.0
func (m *SubscribeRequest) XXX_Size() int
func (*SubscribeRequest) XXX_Unmarshal ¶ added in v1.1.0
func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error
type UnimplementedAPIServer ¶ added in v1.1.0
type UnimplementedAPIServer struct { }
UnimplementedAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedAPIServer) CreateStream ¶ added in v1.1.0
func (*UnimplementedAPIServer) CreateStream(ctx context.Context, req *CreateStreamRequest) (*CreateStreamResponse, error)
func (*UnimplementedAPIServer) DeleteStream ¶ added in v1.1.0
func (*UnimplementedAPIServer) DeleteStream(ctx context.Context, req *DeleteStreamRequest) (*DeleteStreamResponse, error)
func (*UnimplementedAPIServer) FetchMetadata ¶ added in v1.1.0
func (*UnimplementedAPIServer) FetchMetadata(ctx context.Context, req *FetchMetadataRequest) (*FetchMetadataResponse, error)
func (*UnimplementedAPIServer) PauseStream ¶ added in v1.1.0
func (*UnimplementedAPIServer) PauseStream(ctx context.Context, req *PauseStreamRequest) (*PauseStreamResponse, error)
func (*UnimplementedAPIServer) Publish ¶ added in v1.1.0
func (*UnimplementedAPIServer) Publish(ctx context.Context, req *PublishRequest) (*PublishResponse, error)
func (*UnimplementedAPIServer) PublishAsync ¶ added in v1.1.0
func (*UnimplementedAPIServer) PublishAsync(srv API_PublishAsyncServer) error
func (*UnimplementedAPIServer) PublishToSubject ¶ added in v1.1.0
func (*UnimplementedAPIServer) PublishToSubject(ctx context.Context, req *PublishToSubjectRequest) (*PublishToSubjectResponse, error)
func (*UnimplementedAPIServer) SetStreamReadonly ¶ added in v1.9.1
func (*UnimplementedAPIServer) SetStreamReadonly(ctx context.Context, req *SetStreamReadonlyRequest) (*SetStreamReadonlyResponse, error)
func (*UnimplementedAPIServer) Subscribe ¶ added in v1.1.0
func (*UnimplementedAPIServer) Subscribe(req *SubscribeRequest, srv API_SubscribeServer) error