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) GetAckError() Ack_Error
- 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 Ack_Error
- 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) GetJoinConsumerGroupOp() *JoinConsumerGroupOp
- func (m *ActivityStreamEvent) GetLeaveConsumerGroupOp() *LeaveConsumerGroupOp
- 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) GetLeaderCount() int32
- func (m *Broker) GetPartitionCount() int32
- 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 Consumer
- func (*Consumer) Descriptor() ([]byte, []int)
- func (m *Consumer) GetConsumerId() string
- func (m *Consumer) GetGroupEpoch() uint64
- func (m *Consumer) GetGroupId() string
- func (m *Consumer) Marshal() (dAtA []byte, err error)
- func (m *Consumer) MarshalTo(dAtA []byte) (int, error)
- func (m *Consumer) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Consumer) ProtoMessage()
- func (m *Consumer) Reset()
- func (m *Consumer) Size() (n int)
- func (m *Consumer) String() string
- func (m *Consumer) Unmarshal(dAtA []byte) error
- func (m *Consumer) XXX_DiscardUnknown()
- func (m *Consumer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Consumer) XXX_Merge(src proto.Message)
- func (m *Consumer) XXX_Size() int
- func (m *Consumer) XXX_Unmarshal(b []byte) error
- type ConsumerGroupMetadata
- func (*ConsumerGroupMetadata) Descriptor() ([]byte, []int)
- func (m *ConsumerGroupMetadata) GetCoordinator() string
- func (m *ConsumerGroupMetadata) GetEpoch() uint64
- func (m *ConsumerGroupMetadata) GetError() ConsumerGroupMetadata_Error
- func (m *ConsumerGroupMetadata) GetGroupId() string
- func (m *ConsumerGroupMetadata) Marshal() (dAtA []byte, err error)
- func (m *ConsumerGroupMetadata) MarshalTo(dAtA []byte) (int, error)
- func (m *ConsumerGroupMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConsumerGroupMetadata) ProtoMessage()
- func (m *ConsumerGroupMetadata) Reset()
- func (m *ConsumerGroupMetadata) Size() (n int)
- func (m *ConsumerGroupMetadata) String() string
- func (m *ConsumerGroupMetadata) Unmarshal(dAtA []byte) error
- func (m *ConsumerGroupMetadata) XXX_DiscardUnknown()
- func (m *ConsumerGroupMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConsumerGroupMetadata) XXX_Merge(src proto.Message)
- func (m *ConsumerGroupMetadata) XXX_Size() int
- func (m *ConsumerGroupMetadata) XXX_Unmarshal(b []byte) error
- type ConsumerGroupMetadata_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) GetAutoPauseDisableIfSubscribers() *NullableBool
- func (m *CreateStreamRequest) GetAutoPauseTime() *NullableInt64
- func (m *CreateStreamRequest) GetCleanerInterval() *NullableInt64
- func (m *CreateStreamRequest) GetCompactEnabled() *NullableBool
- func (m *CreateStreamRequest) GetCompactMaxGoroutines() *NullableInt32
- func (m *CreateStreamRequest) GetEncryption() *NullableBool
- func (m *CreateStreamRequest) GetGroup() string
- func (m *CreateStreamRequest) GetMinIsr() *NullableInt32
- func (m *CreateStreamRequest) GetName() string
- func (m *CreateStreamRequest) GetOptimisticConcurrencyControl() *NullableBool
- 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 FetchConsumerGroupAssignmentsRequest
- func (*FetchConsumerGroupAssignmentsRequest) Descriptor() ([]byte, []int)
- func (m *FetchConsumerGroupAssignmentsRequest) GetConsumerId() string
- func (m *FetchConsumerGroupAssignmentsRequest) GetEpoch() uint64
- func (m *FetchConsumerGroupAssignmentsRequest) GetGroupId() string
- func (m *FetchConsumerGroupAssignmentsRequest) Marshal() (dAtA []byte, err error)
- func (m *FetchConsumerGroupAssignmentsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *FetchConsumerGroupAssignmentsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FetchConsumerGroupAssignmentsRequest) ProtoMessage()
- func (m *FetchConsumerGroupAssignmentsRequest) Reset()
- func (m *FetchConsumerGroupAssignmentsRequest) Size() (n int)
- func (m *FetchConsumerGroupAssignmentsRequest) String() string
- func (m *FetchConsumerGroupAssignmentsRequest) Unmarshal(dAtA []byte) error
- func (m *FetchConsumerGroupAssignmentsRequest) XXX_DiscardUnknown()
- func (m *FetchConsumerGroupAssignmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FetchConsumerGroupAssignmentsRequest) XXX_Merge(src proto.Message)
- func (m *FetchConsumerGroupAssignmentsRequest) XXX_Size() int
- func (m *FetchConsumerGroupAssignmentsRequest) XXX_Unmarshal(b []byte) error
- type FetchConsumerGroupAssignmentsResponse
- func (*FetchConsumerGroupAssignmentsResponse) Descriptor() ([]byte, []int)
- func (m *FetchConsumerGroupAssignmentsResponse) GetAssignments() []*PartitionAssignment
- func (m *FetchConsumerGroupAssignmentsResponse) GetEpoch() uint64
- func (m *FetchConsumerGroupAssignmentsResponse) Marshal() (dAtA []byte, err error)
- func (m *FetchConsumerGroupAssignmentsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *FetchConsumerGroupAssignmentsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FetchConsumerGroupAssignmentsResponse) ProtoMessage()
- func (m *FetchConsumerGroupAssignmentsResponse) Reset()
- func (m *FetchConsumerGroupAssignmentsResponse) Size() (n int)
- func (m *FetchConsumerGroupAssignmentsResponse) String() string
- func (m *FetchConsumerGroupAssignmentsResponse) Unmarshal(dAtA []byte) error
- func (m *FetchConsumerGroupAssignmentsResponse) XXX_DiscardUnknown()
- func (m *FetchConsumerGroupAssignmentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FetchConsumerGroupAssignmentsResponse) XXX_Merge(src proto.Message)
- func (m *FetchConsumerGroupAssignmentsResponse) XXX_Size() int
- func (m *FetchConsumerGroupAssignmentsResponse) XXX_Unmarshal(b []byte) error
- type FetchCursorRequest
- func (*FetchCursorRequest) Descriptor() ([]byte, []int)
- func (m *FetchCursorRequest) GetCursorId() string
- func (m *FetchCursorRequest) GetPartition() int32
- func (m *FetchCursorRequest) GetStream() string
- func (m *FetchCursorRequest) Marshal() (dAtA []byte, err error)
- func (m *FetchCursorRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *FetchCursorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FetchCursorRequest) ProtoMessage()
- func (m *FetchCursorRequest) Reset()
- func (m *FetchCursorRequest) Size() (n int)
- func (m *FetchCursorRequest) String() string
- func (m *FetchCursorRequest) Unmarshal(dAtA []byte) error
- func (m *FetchCursorRequest) XXX_DiscardUnknown()
- func (m *FetchCursorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FetchCursorRequest) XXX_Merge(src proto.Message)
- func (m *FetchCursorRequest) XXX_Size() int
- func (m *FetchCursorRequest) XXX_Unmarshal(b []byte) error
- type FetchCursorResponse
- func (*FetchCursorResponse) Descriptor() ([]byte, []int)
- func (m *FetchCursorResponse) GetOffset() int64
- func (m *FetchCursorResponse) Marshal() (dAtA []byte, err error)
- func (m *FetchCursorResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *FetchCursorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FetchCursorResponse) ProtoMessage()
- func (m *FetchCursorResponse) Reset()
- func (m *FetchCursorResponse) Size() (n int)
- func (m *FetchCursorResponse) String() string
- func (m *FetchCursorResponse) Unmarshal(dAtA []byte) error
- func (m *FetchCursorResponse) XXX_DiscardUnknown()
- func (m *FetchCursorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FetchCursorResponse) XXX_Merge(src proto.Message)
- func (m *FetchCursorResponse) XXX_Size() int
- func (m *FetchCursorResponse) XXX_Unmarshal(b []byte) error
- type FetchMetadataRequest
- func (*FetchMetadataRequest) Descriptor() ([]byte, []int)
- func (m *FetchMetadataRequest) GetGroups() []string
- 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) GetGroupMetadata() []*ConsumerGroupMetadata
- func (m *FetchMetadataResponse) GetStreamMetadata() []*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 FetchPartitionMetadataRequest
- func (*FetchPartitionMetadataRequest) Descriptor() ([]byte, []int)
- func (m *FetchPartitionMetadataRequest) GetPartition() int32
- func (m *FetchPartitionMetadataRequest) GetStream() string
- func (m *FetchPartitionMetadataRequest) Marshal() (dAtA []byte, err error)
- func (m *FetchPartitionMetadataRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *FetchPartitionMetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FetchPartitionMetadataRequest) ProtoMessage()
- func (m *FetchPartitionMetadataRequest) Reset()
- func (m *FetchPartitionMetadataRequest) Size() (n int)
- func (m *FetchPartitionMetadataRequest) String() string
- func (m *FetchPartitionMetadataRequest) Unmarshal(dAtA []byte) error
- func (m *FetchPartitionMetadataRequest) XXX_DiscardUnknown()
- func (m *FetchPartitionMetadataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FetchPartitionMetadataRequest) XXX_Merge(src proto.Message)
- func (m *FetchPartitionMetadataRequest) XXX_Size() int
- func (m *FetchPartitionMetadataRequest) XXX_Unmarshal(b []byte) error
- type FetchPartitionMetadataResponse
- func (*FetchPartitionMetadataResponse) Descriptor() ([]byte, []int)
- func (m *FetchPartitionMetadataResponse) GetMetadata() *PartitionMetadata
- func (m *FetchPartitionMetadataResponse) Marshal() (dAtA []byte, err error)
- func (m *FetchPartitionMetadataResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *FetchPartitionMetadataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FetchPartitionMetadataResponse) ProtoMessage()
- func (m *FetchPartitionMetadataResponse) Reset()
- func (m *FetchPartitionMetadataResponse) Size() (n int)
- func (m *FetchPartitionMetadataResponse) String() string
- func (m *FetchPartitionMetadataResponse) Unmarshal(dAtA []byte) error
- func (m *FetchPartitionMetadataResponse) XXX_DiscardUnknown()
- func (m *FetchPartitionMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FetchPartitionMetadataResponse) XXX_Merge(src proto.Message)
- func (m *FetchPartitionMetadataResponse) XXX_Size() int
- func (m *FetchPartitionMetadataResponse) XXX_Unmarshal(b []byte) error
- type JoinConsumerGroupOp
- func (*JoinConsumerGroupOp) Descriptor() ([]byte, []int)
- func (m *JoinConsumerGroupOp) GetConsumerId() string
- func (m *JoinConsumerGroupOp) GetGroupId() string
- func (m *JoinConsumerGroupOp) GetStreams() []string
- func (m *JoinConsumerGroupOp) Marshal() (dAtA []byte, err error)
- func (m *JoinConsumerGroupOp) MarshalTo(dAtA []byte) (int, error)
- func (m *JoinConsumerGroupOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JoinConsumerGroupOp) ProtoMessage()
- func (m *JoinConsumerGroupOp) Reset()
- func (m *JoinConsumerGroupOp) Size() (n int)
- func (m *JoinConsumerGroupOp) String() string
- func (m *JoinConsumerGroupOp) Unmarshal(dAtA []byte) error
- func (m *JoinConsumerGroupOp) XXX_DiscardUnknown()
- func (m *JoinConsumerGroupOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JoinConsumerGroupOp) XXX_Merge(src proto.Message)
- func (m *JoinConsumerGroupOp) XXX_Size() int
- func (m *JoinConsumerGroupOp) XXX_Unmarshal(b []byte) error
- type JoinConsumerGroupRequest
- func (*JoinConsumerGroupRequest) Descriptor() ([]byte, []int)
- func (m *JoinConsumerGroupRequest) GetConsumerId() string
- func (m *JoinConsumerGroupRequest) GetGroupId() string
- func (m *JoinConsumerGroupRequest) GetStreams() []string
- func (m *JoinConsumerGroupRequest) Marshal() (dAtA []byte, err error)
- func (m *JoinConsumerGroupRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JoinConsumerGroupRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JoinConsumerGroupRequest) ProtoMessage()
- func (m *JoinConsumerGroupRequest) Reset()
- func (m *JoinConsumerGroupRequest) Size() (n int)
- func (m *JoinConsumerGroupRequest) String() string
- func (m *JoinConsumerGroupRequest) Unmarshal(dAtA []byte) error
- func (m *JoinConsumerGroupRequest) XXX_DiscardUnknown()
- func (m *JoinConsumerGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JoinConsumerGroupRequest) XXX_Merge(src proto.Message)
- func (m *JoinConsumerGroupRequest) XXX_Size() int
- func (m *JoinConsumerGroupRequest) XXX_Unmarshal(b []byte) error
- type JoinConsumerGroupResponse
- func (*JoinConsumerGroupResponse) Descriptor() ([]byte, []int)
- func (m *JoinConsumerGroupResponse) GetConsumerTimeout() int64
- func (m *JoinConsumerGroupResponse) GetCoordinator() string
- func (m *JoinConsumerGroupResponse) GetCoordinatorTimeout() int64
- func (m *JoinConsumerGroupResponse) GetEpoch() uint64
- func (m *JoinConsumerGroupResponse) Marshal() (dAtA []byte, err error)
- func (m *JoinConsumerGroupResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *JoinConsumerGroupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JoinConsumerGroupResponse) ProtoMessage()
- func (m *JoinConsumerGroupResponse) Reset()
- func (m *JoinConsumerGroupResponse) Size() (n int)
- func (m *JoinConsumerGroupResponse) String() string
- func (m *JoinConsumerGroupResponse) Unmarshal(dAtA []byte) error
- func (m *JoinConsumerGroupResponse) XXX_DiscardUnknown()
- func (m *JoinConsumerGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JoinConsumerGroupResponse) XXX_Merge(src proto.Message)
- func (m *JoinConsumerGroupResponse) XXX_Size() int
- func (m *JoinConsumerGroupResponse) XXX_Unmarshal(b []byte) error
- type LeaveConsumerGroupOp
- func (*LeaveConsumerGroupOp) Descriptor() ([]byte, []int)
- func (m *LeaveConsumerGroupOp) GetConsumerId() string
- func (m *LeaveConsumerGroupOp) GetExpired() bool
- func (m *LeaveConsumerGroupOp) GetGroupId() string
- func (m *LeaveConsumerGroupOp) Marshal() (dAtA []byte, err error)
- func (m *LeaveConsumerGroupOp) MarshalTo(dAtA []byte) (int, error)
- func (m *LeaveConsumerGroupOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LeaveConsumerGroupOp) ProtoMessage()
- func (m *LeaveConsumerGroupOp) Reset()
- func (m *LeaveConsumerGroupOp) Size() (n int)
- func (m *LeaveConsumerGroupOp) String() string
- func (m *LeaveConsumerGroupOp) Unmarshal(dAtA []byte) error
- func (m *LeaveConsumerGroupOp) XXX_DiscardUnknown()
- func (m *LeaveConsumerGroupOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LeaveConsumerGroupOp) XXX_Merge(src proto.Message)
- func (m *LeaveConsumerGroupOp) XXX_Size() int
- func (m *LeaveConsumerGroupOp) XXX_Unmarshal(b []byte) error
- type LeaveConsumerGroupRequest
- func (*LeaveConsumerGroupRequest) Descriptor() ([]byte, []int)
- func (m *LeaveConsumerGroupRequest) GetConsumerId() string
- func (m *LeaveConsumerGroupRequest) GetGroupId() string
- func (m *LeaveConsumerGroupRequest) Marshal() (dAtA []byte, err error)
- func (m *LeaveConsumerGroupRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *LeaveConsumerGroupRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LeaveConsumerGroupRequest) ProtoMessage()
- func (m *LeaveConsumerGroupRequest) Reset()
- func (m *LeaveConsumerGroupRequest) Size() (n int)
- func (m *LeaveConsumerGroupRequest) String() string
- func (m *LeaveConsumerGroupRequest) Unmarshal(dAtA []byte) error
- func (m *LeaveConsumerGroupRequest) XXX_DiscardUnknown()
- func (m *LeaveConsumerGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LeaveConsumerGroupRequest) XXX_Merge(src proto.Message)
- func (m *LeaveConsumerGroupRequest) XXX_Size() int
- func (m *LeaveConsumerGroupRequest) XXX_Unmarshal(b []byte) error
- type LeaveConsumerGroupResponse
- func (*LeaveConsumerGroupResponse) Descriptor() ([]byte, []int)
- func (m *LeaveConsumerGroupResponse) Marshal() (dAtA []byte, err error)
- func (m *LeaveConsumerGroupResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *LeaveConsumerGroupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LeaveConsumerGroupResponse) ProtoMessage()
- func (m *LeaveConsumerGroupResponse) Reset()
- func (m *LeaveConsumerGroupResponse) Size() (n int)
- func (m *LeaveConsumerGroupResponse) String() string
- func (m *LeaveConsumerGroupResponse) Unmarshal(dAtA []byte) error
- func (m *LeaveConsumerGroupResponse) XXX_DiscardUnknown()
- func (m *LeaveConsumerGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LeaveConsumerGroupResponse) XXX_Merge(src proto.Message)
- func (m *LeaveConsumerGroupResponse) XXX_Size() int
- func (m *LeaveConsumerGroupResponse) 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 PartitionAssignment
- func (*PartitionAssignment) Descriptor() ([]byte, []int)
- func (m *PartitionAssignment) GetPartitions() []int32
- func (m *PartitionAssignment) GetStream() string
- func (m *PartitionAssignment) Marshal() (dAtA []byte, err error)
- func (m *PartitionAssignment) MarshalTo(dAtA []byte) (int, error)
- func (m *PartitionAssignment) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PartitionAssignment) ProtoMessage()
- func (m *PartitionAssignment) Reset()
- func (m *PartitionAssignment) Size() (n int)
- func (m *PartitionAssignment) String() string
- func (m *PartitionAssignment) Unmarshal(dAtA []byte) error
- func (m *PartitionAssignment) XXX_DiscardUnknown()
- func (m *PartitionAssignment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PartitionAssignment) XXX_Merge(src proto.Message)
- func (m *PartitionAssignment) XXX_Size() int
- func (m *PartitionAssignment) XXX_Unmarshal(b []byte) error
- type PartitionEventTimestamps
- func (*PartitionEventTimestamps) Descriptor() ([]byte, []int)
- func (m *PartitionEventTimestamps) GetFirstTimestamp() int64
- func (m *PartitionEventTimestamps) GetLatestTimestamp() int64
- func (m *PartitionEventTimestamps) Marshal() (dAtA []byte, err error)
- func (m *PartitionEventTimestamps) MarshalTo(dAtA []byte) (int, error)
- func (m *PartitionEventTimestamps) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PartitionEventTimestamps) ProtoMessage()
- func (m *PartitionEventTimestamps) Reset()
- func (m *PartitionEventTimestamps) Size() (n int)
- func (m *PartitionEventTimestamps) String() string
- func (m *PartitionEventTimestamps) Unmarshal(dAtA []byte) error
- func (m *PartitionEventTimestamps) XXX_DiscardUnknown()
- func (m *PartitionEventTimestamps) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PartitionEventTimestamps) XXX_Merge(src proto.Message)
- func (m *PartitionEventTimestamps) XXX_Size() int
- func (m *PartitionEventTimestamps) 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) GetMessagesReceivedTimestamps() *PartitionEventTimestamps
- func (m *PartitionMetadata) GetNewestOffset() int64
- func (m *PartitionMetadata) GetPauseTimestamps() *PartitionEventTimestamps
- func (m *PartitionMetadata) GetPaused() bool
- func (m *PartitionMetadata) GetReadonly() bool
- func (m *PartitionMetadata) GetReadonlyTimestamps() *PartitionEventTimestamps
- 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 PublishAsyncError
- func (*PublishAsyncError) Descriptor() ([]byte, []int)
- func (m *PublishAsyncError) GetCode() PublishAsyncError_Code
- func (m *PublishAsyncError) GetMessage() string
- func (m *PublishAsyncError) Marshal() (dAtA []byte, err error)
- func (m *PublishAsyncError) MarshalTo(dAtA []byte) (int, error)
- func (m *PublishAsyncError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PublishAsyncError) ProtoMessage()
- func (m *PublishAsyncError) Reset()
- func (m *PublishAsyncError) Size() (n int)
- func (m *PublishAsyncError) String() string
- func (m *PublishAsyncError) Unmarshal(dAtA []byte) error
- func (m *PublishAsyncError) XXX_DiscardUnknown()
- func (m *PublishAsyncError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PublishAsyncError) XXX_Merge(src proto.Message)
- func (m *PublishAsyncError) XXX_Size() int
- func (m *PublishAsyncError) XXX_Unmarshal(b []byte) error
- type PublishAsyncError_Code
- 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) GetExpectedOffset() int64
- 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) GetAsyncError() *PublishAsyncError
- func (m *PublishResponse) GetCorrelationId() string
- 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 ReportConsumerGroupCoordinatorRequest
- func (*ReportConsumerGroupCoordinatorRequest) Descriptor() ([]byte, []int)
- func (m *ReportConsumerGroupCoordinatorRequest) GetConsumerId() string
- func (m *ReportConsumerGroupCoordinatorRequest) GetCoordinator() string
- func (m *ReportConsumerGroupCoordinatorRequest) GetEpoch() uint64
- func (m *ReportConsumerGroupCoordinatorRequest) GetGroupId() string
- func (m *ReportConsumerGroupCoordinatorRequest) Marshal() (dAtA []byte, err error)
- func (m *ReportConsumerGroupCoordinatorRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReportConsumerGroupCoordinatorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReportConsumerGroupCoordinatorRequest) ProtoMessage()
- func (m *ReportConsumerGroupCoordinatorRequest) Reset()
- func (m *ReportConsumerGroupCoordinatorRequest) Size() (n int)
- func (m *ReportConsumerGroupCoordinatorRequest) String() string
- func (m *ReportConsumerGroupCoordinatorRequest) Unmarshal(dAtA []byte) error
- func (m *ReportConsumerGroupCoordinatorRequest) XXX_DiscardUnknown()
- func (m *ReportConsumerGroupCoordinatorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReportConsumerGroupCoordinatorRequest) XXX_Merge(src proto.Message)
- func (m *ReportConsumerGroupCoordinatorRequest) XXX_Size() int
- func (m *ReportConsumerGroupCoordinatorRequest) XXX_Unmarshal(b []byte) error
- type ReportConsumerGroupCoordinatorResponse
- func (*ReportConsumerGroupCoordinatorResponse) Descriptor() ([]byte, []int)
- func (m *ReportConsumerGroupCoordinatorResponse) Marshal() (dAtA []byte, err error)
- func (m *ReportConsumerGroupCoordinatorResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReportConsumerGroupCoordinatorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReportConsumerGroupCoordinatorResponse) ProtoMessage()
- func (m *ReportConsumerGroupCoordinatorResponse) Reset()
- func (m *ReportConsumerGroupCoordinatorResponse) Size() (n int)
- func (m *ReportConsumerGroupCoordinatorResponse) String() string
- func (m *ReportConsumerGroupCoordinatorResponse) Unmarshal(dAtA []byte) error
- func (m *ReportConsumerGroupCoordinatorResponse) XXX_DiscardUnknown()
- func (m *ReportConsumerGroupCoordinatorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReportConsumerGroupCoordinatorResponse) XXX_Merge(src proto.Message)
- func (m *ReportConsumerGroupCoordinatorResponse) XXX_Size() int
- func (m *ReportConsumerGroupCoordinatorResponse) 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 SetCursorRequest
- func (*SetCursorRequest) Descriptor() ([]byte, []int)
- func (m *SetCursorRequest) GetCursorId() string
- func (m *SetCursorRequest) GetOffset() int64
- func (m *SetCursorRequest) GetPartition() int32
- func (m *SetCursorRequest) GetStream() string
- func (m *SetCursorRequest) Marshal() (dAtA []byte, err error)
- func (m *SetCursorRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SetCursorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetCursorRequest) ProtoMessage()
- func (m *SetCursorRequest) Reset()
- func (m *SetCursorRequest) Size() (n int)
- func (m *SetCursorRequest) String() string
- func (m *SetCursorRequest) Unmarshal(dAtA []byte) error
- func (m *SetCursorRequest) XXX_DiscardUnknown()
- func (m *SetCursorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetCursorRequest) XXX_Merge(src proto.Message)
- func (m *SetCursorRequest) XXX_Size() int
- func (m *SetCursorRequest) XXX_Unmarshal(b []byte) error
- type SetCursorResponse
- func (*SetCursorResponse) Descriptor() ([]byte, []int)
- func (m *SetCursorResponse) Marshal() (dAtA []byte, err error)
- func (m *SetCursorResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SetCursorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetCursorResponse) ProtoMessage()
- func (m *SetCursorResponse) Reset()
- func (m *SetCursorResponse) Size() (n int)
- func (m *SetCursorResponse) String() string
- func (m *SetCursorResponse) Unmarshal(dAtA []byte) error
- func (m *SetCursorResponse) XXX_DiscardUnknown()
- func (m *SetCursorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetCursorResponse) XXX_Merge(src proto.Message)
- func (m *SetCursorResponse) XXX_Size() int
- func (m *SetCursorResponse) 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 StopPosition
- type StreamMetadata
- func (*StreamMetadata) Descriptor() ([]byte, []int)
- func (m *StreamMetadata) GetCreationTimestamp() int64
- 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) GetConsumer() *Consumer
- 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) GetStopOffset() int64
- func (m *SubscribeRequest) GetStopPosition() StopPosition
- func (m *SubscribeRequest) GetStopTimestamp() 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) FetchConsumerGroupAssignments(ctx context.Context, req *FetchConsumerGroupAssignmentsRequest) (*FetchConsumerGroupAssignmentsResponse, error)
- func (*UnimplementedAPIServer) FetchCursor(ctx context.Context, req *FetchCursorRequest) (*FetchCursorResponse, error)
- func (*UnimplementedAPIServer) FetchMetadata(ctx context.Context, req *FetchMetadataRequest) (*FetchMetadataResponse, error)
- func (*UnimplementedAPIServer) FetchPartitionMetadata(ctx context.Context, req *FetchPartitionMetadataRequest) (*FetchPartitionMetadataResponse, error)
- func (*UnimplementedAPIServer) JoinConsumerGroup(ctx context.Context, req *JoinConsumerGroupRequest) (*JoinConsumerGroupResponse, error)
- func (*UnimplementedAPIServer) LeaveConsumerGroup(ctx context.Context, req *LeaveConsumerGroupRequest) (*LeaveConsumerGroupResponse, 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) ReportConsumerGroupCoordinator(ctx context.Context, req *ReportConsumerGroupCoordinatorRequest) (*ReportConsumerGroupCoordinatorResponse, error)
- func (*UnimplementedAPIServer) SetCursor(ctx context.Context, req *SetCursorRequest) (*SetCursorResponse, 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") ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group") )
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 Ack_Error_name = map[int32]string{
0: "OK",
1: "UNKNOWN",
2: "INCORRECT_OFFSET",
3: "TOO_LARGE",
4: "ENCRYPTION",
}
var Ack_Error_value = map[string]int32{
"OK": 0,
"UNKNOWN": 1,
"INCORRECT_OFFSET": 2,
"TOO_LARGE": 3,
"ENCRYPTION": 4,
}
var ActivityStreamOp_name = map[int32]string{
0: "CREATE_STREAM",
1: "DELETE_STREAM",
2: "PAUSE_STREAM",
3: "RESUME_STREAM",
4: "SET_STREAM_READONLY",
5: "JOIN_CONSUMER_GROUP",
6: "LEAVE_CONSUMER_GROUP",
}
var ActivityStreamOp_value = map[string]int32{
"CREATE_STREAM": 0,
"DELETE_STREAM": 1,
"PAUSE_STREAM": 2,
"RESUME_STREAM": 3,
"SET_STREAM_READONLY": 4,
"JOIN_CONSUMER_GROUP": 5,
"LEAVE_CONSUMER_GROUP": 6,
}
var ConsumerGroupMetadata_Error_name = map[int32]string{
0: "OK",
1: "UNKNOWN_GROUP",
}
var ConsumerGroupMetadata_Error_value = map[string]int32{
"OK": 0,
"UNKNOWN_GROUP": 1,
}
var PublishAsyncError_Code_name = map[int32]string{
0: "UNKNOWN",
1: "BAD_REQUEST",
2: "NOT_FOUND",
3: "INTERNAL",
4: "READONLY",
5: "INCORRECT_OFFSET",
6: "ENCRYPTION_FAILED",
7: "PERMISSION_DENIED",
}
var PublishAsyncError_Code_value = map[string]int32{
"UNKNOWN": 0,
"BAD_REQUEST": 1,
"NOT_FOUND": 2,
"INTERNAL": 3,
"READONLY": 4,
"INCORRECT_OFFSET": 5,
"ENCRYPTION_FAILED": 6,
"PERMISSION_DENIED": 7,
}
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 StopPosition_name = map[int32]string{
0: "STOP_ON_CANCEL",
1: "STOP_OFFSET",
2: "STOP_LATEST",
3: "STOP_TIMESTAMP",
}
var StopPosition_value = map[string]int32{
"STOP_ON_CANCEL": 0,
"STOP_OFFSET": 1,
"STOP_LATEST": 2,
"STOP_TIMESTAMP": 3,
}
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. 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) // FetchPartitionMetadata retrieves the latest partition metadata from partition leader // The main interest is to retrieve Highest Watermark and Newest Offset FetchPartitionMetadata(ctx context.Context, in *FetchPartitionMetadataRequest, opts ...grpc.CallOption) (*FetchPartitionMetadataResponse, 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) // SetCursor stores a cursor position for a particular stream partition // which is uniquely identified by an opaque string. // // NOTE: This is a beta endpoint and is subject to change. It is not // included as part of Liftbridge's semantic versioning scheme. SetCursor(ctx context.Context, in *SetCursorRequest, opts ...grpc.CallOption) (*SetCursorResponse, error) // FetchCursor retrieves a partition cursor position. // // NOTE: This is a beta endpoint and is subject to change. It is not // included as part of Liftbridge's semantic versioning scheme. FetchCursor(ctx context.Context, in *FetchCursorRequest, opts ...grpc.CallOption) (*FetchCursorResponse, error) // JoinConsumerGroup adds a consumer to a consumer group. If the group does // not exist, it will create it first. // // NOTE: This is a beta endpoint and is subject to change. It is not // included as part of Liftbridge's semantic versioning scheme. JoinConsumerGroup(ctx context.Context, in *JoinConsumerGroupRequest, opts ...grpc.CallOption) (*JoinConsumerGroupResponse, error) // LeaveConsumerGroup removes a consumer from a consumer group. // // NOTE: This is a beta endpoint and is subject to change. It is not // included as part of Liftbridge's semantic versioning scheme. LeaveConsumerGroup(ctx context.Context, in *LeaveConsumerGroupRequest, opts ...grpc.CallOption) (*LeaveConsumerGroupResponse, error) // FetchConsumerGroupAssignments retrieves the partition assignments for a // consumer. This also acts as a heartbeat for the consumer so that the // coordinator keeps the consumer active in the group. // // NOTE: This is a beta endpoint and is subject to change. It is not // included as part of Liftbridge's semantic versioning scheme. FetchConsumerGroupAssignments(ctx context.Context, in *FetchConsumerGroupAssignmentsRequest, opts ...grpc.CallOption) (*FetchConsumerGroupAssignmentsResponse, error) // ReportConsumerGroupCoordinator reports a consumer group coordinator as // failed. If a majority of the group's members report the coordinator // within a bounded period, the cluster will select a new coordinator. // // NOTE: This is a beta endpoint and is subject to change. It is not // included as part of Liftbridge's semantic versioning scheme. ReportConsumerGroupCoordinator(ctx context.Context, in *ReportConsumerGroupCoordinatorRequest, opts ...grpc.CallOption) (*ReportConsumerGroupCoordinatorResponse, 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. 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) // FetchPartitionMetadata retrieves the latest partition metadata from partition leader // The main interest is to retrieve Highest Watermark and Newest Offset FetchPartitionMetadata(context.Context, *FetchPartitionMetadataRequest) (*FetchPartitionMetadataResponse, 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) // SetCursor stores a cursor position for a particular stream partition // which is uniquely identified by an opaque string. // // NOTE: This is a beta endpoint and is subject to change. It is not // included as part of Liftbridge's semantic versioning scheme. SetCursor(context.Context, *SetCursorRequest) (*SetCursorResponse, error) // FetchCursor retrieves a partition cursor position. // // NOTE: This is a beta endpoint and is subject to change. It is not // included as part of Liftbridge's semantic versioning scheme. FetchCursor(context.Context, *FetchCursorRequest) (*FetchCursorResponse, error) // JoinConsumerGroup adds a consumer to a consumer group. If the group does // not exist, it will create it first. // // NOTE: This is a beta endpoint and is subject to change. It is not // included as part of Liftbridge's semantic versioning scheme. JoinConsumerGroup(context.Context, *JoinConsumerGroupRequest) (*JoinConsumerGroupResponse, error) // LeaveConsumerGroup removes a consumer from a consumer group. // // NOTE: This is a beta endpoint and is subject to change. It is not // included as part of Liftbridge's semantic versioning scheme. LeaveConsumerGroup(context.Context, *LeaveConsumerGroupRequest) (*LeaveConsumerGroupResponse, error) // FetchConsumerGroupAssignments retrieves the partition assignments for a // consumer. This also acts as a heartbeat for the consumer so that the // coordinator keeps the consumer active in the group. // // NOTE: This is a beta endpoint and is subject to change. It is not // included as part of Liftbridge's semantic versioning scheme. FetchConsumerGroupAssignments(context.Context, *FetchConsumerGroupAssignmentsRequest) (*FetchConsumerGroupAssignmentsResponse, error) // ReportConsumerGroupCoordinator reports a consumer group coordinator as // failed. If a majority of the group's members report the coordinator // within a bounded period, the cluster will select a new coordinator. // // NOTE: This is a beta endpoint and is subject to change. It is not // included as part of Liftbridge's semantic versioning scheme. ReportConsumerGroupCoordinator(context.Context, *ReportConsumerGroupCoordinatorRequest) (*ReportConsumerGroupCoordinatorResponse, 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"` AckError Ack_Error `protobuf:"varint,10,opt,name=ackError,proto3,enum=proto.Ack_Error" json:"ackError,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) GetAckError ¶ added in v1.4.0
func (*Ack) GetAckInbox ¶
func (*Ack) GetAckPolicy ¶
func (*Ack) GetCommitTimestamp ¶ added in v1.3.0
func (*Ack) GetCorrelationId ¶
func (*Ack) GetMsgSubject ¶
func (*Ack) GetPartitionSubject ¶
func (*Ack) GetReceptionTimestamp ¶ added in v1.3.0
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 Ack_Error ¶ added in v1.4.0
type Ack_Error int32
Error represents an error that is piggybacked to AckInbox due to any error that is encountered upon publishing, e.g. a PublishRequest may include the expected offset which is outdated on the partition. This publish would be refused.
func (Ack_Error) EnumDescriptor ¶ added in v1.4.0
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"` JoinConsumerGroupOp *JoinConsumerGroupOp `protobuf:"bytes,8,opt,name=joinConsumerGroupOp,proto3" json:"joinConsumerGroupOp,omitempty"` LeaveConsumerGroupOp *LeaveConsumerGroupOp `protobuf:"bytes,9,opt,name=leaveConsumerGroupOp,proto3" json:"leaveConsumerGroupOp,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) GetJoinConsumerGroupOp ¶ added in v1.9.0
func (m *ActivityStreamEvent) GetJoinConsumerGroupOp() *JoinConsumerGroupOp
func (*ActivityStreamEvent) GetLeaveConsumerGroupOp ¶ added in v1.9.0
func (m *ActivityStreamEvent) GetLeaveConsumerGroupOp() *LeaveConsumerGroupOp
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.3.0
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 ActivityStreamOp_JOIN_CONSUMER_GROUP ActivityStreamOp = 5 ActivityStreamOp_LEAVE_CONSUMER_GROUP ActivityStreamOp = 6 )
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"` PartitionCount int32 `protobuf:"varint,4,opt,name=partitionCount,proto3" json:"partitionCount,omitempty"` LeaderCount int32 `protobuf:"varint,5,opt,name=leaderCount,proto3" json:"leaderCount,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) GetLeaderCount ¶ added in v1.7.0
func (*Broker) GetPartitionCount ¶ added in v1.7.0
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 Consumer ¶ added in v1.8.0
type Consumer struct { GroupId string `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"` GroupEpoch uint64 `protobuf:"varint,2,opt,name=groupEpoch,proto3" json:"groupEpoch,omitempty"` ConsumerId string `protobuf:"bytes,3,opt,name=consumerId,proto3" json:"consumerId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Consumer contains information pertaining to a subscriber that is a member of a consumer group.
func (*Consumer) Descriptor ¶ added in v1.8.0
func (*Consumer) GetConsumerId ¶ added in v1.8.0
func (*Consumer) GetGroupEpoch ¶ added in v1.8.0
func (*Consumer) GetGroupId ¶ added in v1.8.0
func (*Consumer) MarshalToSizedBuffer ¶ added in v1.8.0
func (*Consumer) ProtoMessage ¶ added in v1.8.0
func (*Consumer) ProtoMessage()
func (*Consumer) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *Consumer) XXX_DiscardUnknown()
func (*Consumer) XXX_Marshal ¶ added in v1.8.0
func (*Consumer) XXX_Unmarshal ¶ added in v1.8.0
type ConsumerGroupMetadata ¶ added in v1.8.0
type ConsumerGroupMetadata struct { GroupId string `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"` Error ConsumerGroupMetadata_Error `protobuf:"varint,2,opt,name=error,proto3,enum=proto.ConsumerGroupMetadata_Error" json:"error,omitempty"` Coordinator string `protobuf:"bytes,3,opt,name=coordinator,proto3" json:"coordinator,omitempty"` Epoch uint64 `protobuf:"varint,4,opt,name=epoch,proto3" json:"epoch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ConsumerGroupMetadata contains information for a consumer group.
func (*ConsumerGroupMetadata) Descriptor ¶ added in v1.8.0
func (*ConsumerGroupMetadata) Descriptor() ([]byte, []int)
func (*ConsumerGroupMetadata) GetCoordinator ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) GetCoordinator() string
func (*ConsumerGroupMetadata) GetEpoch ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) GetEpoch() uint64
func (*ConsumerGroupMetadata) GetError ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) GetError() ConsumerGroupMetadata_Error
func (*ConsumerGroupMetadata) GetGroupId ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) GetGroupId() string
func (*ConsumerGroupMetadata) Marshal ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) Marshal() (dAtA []byte, err error)
func (*ConsumerGroupMetadata) MarshalTo ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) MarshalTo(dAtA []byte) (int, error)
func (*ConsumerGroupMetadata) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConsumerGroupMetadata) ProtoMessage ¶ added in v1.8.0
func (*ConsumerGroupMetadata) ProtoMessage()
func (*ConsumerGroupMetadata) Reset ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) Reset()
func (*ConsumerGroupMetadata) Size ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) Size() (n int)
func (*ConsumerGroupMetadata) String ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) String() string
func (*ConsumerGroupMetadata) Unmarshal ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) Unmarshal(dAtA []byte) error
func (*ConsumerGroupMetadata) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) XXX_DiscardUnknown()
func (*ConsumerGroupMetadata) XXX_Marshal ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConsumerGroupMetadata) XXX_Merge ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) XXX_Merge(src proto.Message)
func (*ConsumerGroupMetadata) XXX_Size ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) XXX_Size() int
func (*ConsumerGroupMetadata) XXX_Unmarshal ¶ added in v1.8.0
func (m *ConsumerGroupMetadata) XXX_Unmarshal(b []byte) error
type ConsumerGroupMetadata_Error ¶ added in v1.8.0
type ConsumerGroupMetadata_Error int32
const ( ConsumerGroupMetadata_OK ConsumerGroupMetadata_Error = 0 ConsumerGroupMetadata_UNKNOWN_GROUP ConsumerGroupMetadata_Error = 1 )
func (ConsumerGroupMetadata_Error) EnumDescriptor ¶ added in v1.8.0
func (ConsumerGroupMetadata_Error) EnumDescriptor() ([]byte, []int)
func (ConsumerGroupMetadata_Error) String ¶ added in v1.8.0
func (x ConsumerGroupMetadata_Error) String() string
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"` AutoPauseTime *NullableInt64 `protobuf:"bytes,14,opt,name=autoPauseTime,proto3" json:"autoPauseTime,omitempty"` AutoPauseDisableIfSubscribers *NullableBool `protobuf:"bytes,15,opt,name=autoPauseDisableIfSubscribers,proto3" json:"autoPauseDisableIfSubscribers,omitempty"` MinIsr *NullableInt32 `protobuf:"bytes,16,opt,name=minIsr,proto3" json:"minIsr,omitempty"` OptimisticConcurrencyControl *NullableBool `protobuf:"bytes,17,opt,name=optimisticConcurrencyControl,proto3" json:"optimisticConcurrencyControl,omitempty"` Encryption *NullableBool `protobuf:"bytes,18,opt,name=encryption,proto3" json:"encryption,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) GetAutoPauseDisableIfSubscribers ¶ added in v1.3.0
func (m *CreateStreamRequest) GetAutoPauseDisableIfSubscribers() *NullableBool
func (*CreateStreamRequest) GetAutoPauseTime ¶ added in v1.3.0
func (m *CreateStreamRequest) GetAutoPauseTime() *NullableInt64
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) GetEncryption ¶ added in v1.6.0
func (m *CreateStreamRequest) GetEncryption() *NullableBool
func (*CreateStreamRequest) GetGroup ¶
func (m *CreateStreamRequest) GetGroup() string
func (*CreateStreamRequest) GetMinIsr ¶ added in v1.3.0
func (m *CreateStreamRequest) GetMinIsr() *NullableInt32
func (*CreateStreamRequest) GetName ¶
func (m *CreateStreamRequest) GetName() string
func (*CreateStreamRequest) GetOptimisticConcurrencyControl ¶ added in v1.4.0
func (m *CreateStreamRequest) GetOptimisticConcurrencyControl() *NullableBool
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 FetchConsumerGroupAssignmentsRequest ¶ added in v1.8.0
type FetchConsumerGroupAssignmentsRequest struct { GroupId string `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"` ConsumerId string `protobuf:"bytes,2,opt,name=consumerId,proto3" json:"consumerId,omitempty"` Epoch uint64 `protobuf:"varint,3,opt,name=epoch,proto3" json:"epoch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
FetchConsumerGroupAssignmentsRequest is sent to a consumer group coordinator to retrieve the consumer's partition assignments.
func (*FetchConsumerGroupAssignmentsRequest) Descriptor ¶ added in v1.8.0
func (*FetchConsumerGroupAssignmentsRequest) Descriptor() ([]byte, []int)
func (*FetchConsumerGroupAssignmentsRequest) GetConsumerId ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) GetConsumerId() string
func (*FetchConsumerGroupAssignmentsRequest) GetEpoch ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) GetEpoch() uint64
func (*FetchConsumerGroupAssignmentsRequest) GetGroupId ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) GetGroupId() string
func (*FetchConsumerGroupAssignmentsRequest) Marshal ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) Marshal() (dAtA []byte, err error)
func (*FetchConsumerGroupAssignmentsRequest) MarshalTo ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) MarshalTo(dAtA []byte) (int, error)
func (*FetchConsumerGroupAssignmentsRequest) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FetchConsumerGroupAssignmentsRequest) ProtoMessage ¶ added in v1.8.0
func (*FetchConsumerGroupAssignmentsRequest) ProtoMessage()
func (*FetchConsumerGroupAssignmentsRequest) Reset ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) Reset()
func (*FetchConsumerGroupAssignmentsRequest) Size ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) Size() (n int)
func (*FetchConsumerGroupAssignmentsRequest) String ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) String() string
func (*FetchConsumerGroupAssignmentsRequest) Unmarshal ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) Unmarshal(dAtA []byte) error
func (*FetchConsumerGroupAssignmentsRequest) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) XXX_DiscardUnknown()
func (*FetchConsumerGroupAssignmentsRequest) XXX_Marshal ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FetchConsumerGroupAssignmentsRequest) XXX_Merge ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) XXX_Merge(src proto.Message)
func (*FetchConsumerGroupAssignmentsRequest) XXX_Size ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) XXX_Size() int
func (*FetchConsumerGroupAssignmentsRequest) XXX_Unmarshal ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsRequest) XXX_Unmarshal(b []byte) error
type FetchConsumerGroupAssignmentsResponse ¶ added in v1.8.0
type FetchConsumerGroupAssignmentsResponse struct { Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"` Assignments []*PartitionAssignment `protobuf:"bytes,2,rep,name=assignments,proto3" json:"assignments,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
FetchConsumerGroupAssignmentsResponse is sent by the group coordinator to notify the consumer of its partition assignments.
func (*FetchConsumerGroupAssignmentsResponse) Descriptor ¶ added in v1.8.0
func (*FetchConsumerGroupAssignmentsResponse) Descriptor() ([]byte, []int)
func (*FetchConsumerGroupAssignmentsResponse) GetAssignments ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) GetAssignments() []*PartitionAssignment
func (*FetchConsumerGroupAssignmentsResponse) GetEpoch ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) GetEpoch() uint64
func (*FetchConsumerGroupAssignmentsResponse) Marshal ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) Marshal() (dAtA []byte, err error)
func (*FetchConsumerGroupAssignmentsResponse) MarshalTo ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) MarshalTo(dAtA []byte) (int, error)
func (*FetchConsumerGroupAssignmentsResponse) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FetchConsumerGroupAssignmentsResponse) ProtoMessage ¶ added in v1.8.0
func (*FetchConsumerGroupAssignmentsResponse) ProtoMessage()
func (*FetchConsumerGroupAssignmentsResponse) Reset ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) Reset()
func (*FetchConsumerGroupAssignmentsResponse) Size ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) Size() (n int)
func (*FetchConsumerGroupAssignmentsResponse) String ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) String() string
func (*FetchConsumerGroupAssignmentsResponse) Unmarshal ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) Unmarshal(dAtA []byte) error
func (*FetchConsumerGroupAssignmentsResponse) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) XXX_DiscardUnknown()
func (*FetchConsumerGroupAssignmentsResponse) XXX_Marshal ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FetchConsumerGroupAssignmentsResponse) XXX_Merge ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) XXX_Merge(src proto.Message)
func (*FetchConsumerGroupAssignmentsResponse) XXX_Size ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) XXX_Size() int
func (*FetchConsumerGroupAssignmentsResponse) XXX_Unmarshal ¶ added in v1.8.0
func (m *FetchConsumerGroupAssignmentsResponse) XXX_Unmarshal(b []byte) error
type FetchCursorRequest ¶ added in v1.3.0
type FetchCursorRequest 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"` CursorId string `protobuf:"bytes,3,opt,name=cursorId,proto3" json:"cursorId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
FetchCursorRequest is sent to retrieve a consumer's cursor position for a particular stream partition.
func (*FetchCursorRequest) Descriptor ¶ added in v1.3.0
func (*FetchCursorRequest) Descriptor() ([]byte, []int)
func (*FetchCursorRequest) GetCursorId ¶ added in v1.3.0
func (m *FetchCursorRequest) GetCursorId() string
func (*FetchCursorRequest) GetPartition ¶ added in v1.3.0
func (m *FetchCursorRequest) GetPartition() int32
func (*FetchCursorRequest) GetStream ¶ added in v1.3.0
func (m *FetchCursorRequest) GetStream() string
func (*FetchCursorRequest) Marshal ¶ added in v1.3.0
func (m *FetchCursorRequest) Marshal() (dAtA []byte, err error)
func (*FetchCursorRequest) MarshalTo ¶ added in v1.3.0
func (m *FetchCursorRequest) MarshalTo(dAtA []byte) (int, error)
func (*FetchCursorRequest) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *FetchCursorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FetchCursorRequest) ProtoMessage ¶ added in v1.3.0
func (*FetchCursorRequest) ProtoMessage()
func (*FetchCursorRequest) Reset ¶ added in v1.3.0
func (m *FetchCursorRequest) Reset()
func (*FetchCursorRequest) Size ¶ added in v1.3.0
func (m *FetchCursorRequest) Size() (n int)
func (*FetchCursorRequest) String ¶ added in v1.3.0
func (m *FetchCursorRequest) String() string
func (*FetchCursorRequest) Unmarshal ¶ added in v1.3.0
func (m *FetchCursorRequest) Unmarshal(dAtA []byte) error
func (*FetchCursorRequest) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *FetchCursorRequest) XXX_DiscardUnknown()
func (*FetchCursorRequest) XXX_Marshal ¶ added in v1.3.0
func (m *FetchCursorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FetchCursorRequest) XXX_Merge ¶ added in v1.3.0
func (m *FetchCursorRequest) XXX_Merge(src proto.Message)
func (*FetchCursorRequest) XXX_Size ¶ added in v1.3.0
func (m *FetchCursorRequest) XXX_Size() int
func (*FetchCursorRequest) XXX_Unmarshal ¶ added in v1.3.0
func (m *FetchCursorRequest) XXX_Unmarshal(b []byte) error
type FetchCursorResponse ¶ added in v1.3.0
type FetchCursorResponse struct { Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
FetchCursorResponse contains the requested consumer cursor position.
func (*FetchCursorResponse) Descriptor ¶ added in v1.3.0
func (*FetchCursorResponse) Descriptor() ([]byte, []int)
func (*FetchCursorResponse) GetOffset ¶ added in v1.3.0
func (m *FetchCursorResponse) GetOffset() int64
func (*FetchCursorResponse) Marshal ¶ added in v1.3.0
func (m *FetchCursorResponse) Marshal() (dAtA []byte, err error)
func (*FetchCursorResponse) MarshalTo ¶ added in v1.3.0
func (m *FetchCursorResponse) MarshalTo(dAtA []byte) (int, error)
func (*FetchCursorResponse) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *FetchCursorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FetchCursorResponse) ProtoMessage ¶ added in v1.3.0
func (*FetchCursorResponse) ProtoMessage()
func (*FetchCursorResponse) Reset ¶ added in v1.3.0
func (m *FetchCursorResponse) Reset()
func (*FetchCursorResponse) Size ¶ added in v1.3.0
func (m *FetchCursorResponse) Size() (n int)
func (*FetchCursorResponse) String ¶ added in v1.3.0
func (m *FetchCursorResponse) String() string
func (*FetchCursorResponse) Unmarshal ¶ added in v1.3.0
func (m *FetchCursorResponse) Unmarshal(dAtA []byte) error
func (*FetchCursorResponse) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *FetchCursorResponse) XXX_DiscardUnknown()
func (*FetchCursorResponse) XXX_Marshal ¶ added in v1.3.0
func (m *FetchCursorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FetchCursorResponse) XXX_Merge ¶ added in v1.3.0
func (m *FetchCursorResponse) XXX_Merge(src proto.Message)
func (*FetchCursorResponse) XXX_Size ¶ added in v1.3.0
func (m *FetchCursorResponse) XXX_Size() int
func (*FetchCursorResponse) XXX_Unmarshal ¶ added in v1.3.0
func (m *FetchCursorResponse) XXX_Unmarshal(b []byte) error
type FetchMetadataRequest ¶
type FetchMetadataRequest struct { Streams []string `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"` Groups []string `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,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) GetGroups ¶ added in v1.8.0
func (m *FetchMetadataRequest) GetGroups() []string
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"` StreamMetadata []*StreamMetadata `protobuf:"bytes,2,rep,name=streamMetadata,proto3" json:"streamMetadata,omitempty"` GroupMetadata []*ConsumerGroupMetadata `protobuf:"bytes,3,rep,name=groupMetadata,proto3" json:"groupMetadata,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) GetGroupMetadata ¶ added in v1.8.0
func (m *FetchMetadataResponse) GetGroupMetadata() []*ConsumerGroupMetadata
func (*FetchMetadataResponse) GetStreamMetadata ¶ added in v1.8.0
func (m *FetchMetadataResponse) GetStreamMetadata() []*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 FetchPartitionMetadataRequest ¶ added in v1.3.0
type FetchPartitionMetadataRequest 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
FetchPartitionMetadataRequest is sent to retrieve latest partition metadata. Mainly it is useful to retrieve Highest Watermark and Highest Offset of the partition leader
func (*FetchPartitionMetadataRequest) Descriptor ¶ added in v1.3.0
func (*FetchPartitionMetadataRequest) Descriptor() ([]byte, []int)
func (*FetchPartitionMetadataRequest) GetPartition ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) GetPartition() int32
func (*FetchPartitionMetadataRequest) GetStream ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) GetStream() string
func (*FetchPartitionMetadataRequest) Marshal ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) Marshal() (dAtA []byte, err error)
func (*FetchPartitionMetadataRequest) MarshalTo ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) MarshalTo(dAtA []byte) (int, error)
func (*FetchPartitionMetadataRequest) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FetchPartitionMetadataRequest) ProtoMessage ¶ added in v1.3.0
func (*FetchPartitionMetadataRequest) ProtoMessage()
func (*FetchPartitionMetadataRequest) Reset ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) Reset()
func (*FetchPartitionMetadataRequest) Size ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) Size() (n int)
func (*FetchPartitionMetadataRequest) String ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) String() string
func (*FetchPartitionMetadataRequest) Unmarshal ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) Unmarshal(dAtA []byte) error
func (*FetchPartitionMetadataRequest) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) XXX_DiscardUnknown()
func (*FetchPartitionMetadataRequest) XXX_Marshal ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FetchPartitionMetadataRequest) XXX_Merge ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) XXX_Merge(src proto.Message)
func (*FetchPartitionMetadataRequest) XXX_Size ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) XXX_Size() int
func (*FetchPartitionMetadataRequest) XXX_Unmarshal ¶ added in v1.3.0
func (m *FetchPartitionMetadataRequest) XXX_Unmarshal(b []byte) error
type FetchPartitionMetadataResponse ¶ added in v1.3.0
type FetchPartitionMetadataResponse struct { Metadata *PartitionMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
FetchPartitionMetadataResponse contains the partition metadata requested
func (*FetchPartitionMetadataResponse) Descriptor ¶ added in v1.3.0
func (*FetchPartitionMetadataResponse) Descriptor() ([]byte, []int)
func (*FetchPartitionMetadataResponse) GetMetadata ¶ added in v1.3.0
func (m *FetchPartitionMetadataResponse) GetMetadata() *PartitionMetadata
func (*FetchPartitionMetadataResponse) Marshal ¶ added in v1.3.0
func (m *FetchPartitionMetadataResponse) Marshal() (dAtA []byte, err error)
func (*FetchPartitionMetadataResponse) MarshalTo ¶ added in v1.3.0
func (m *FetchPartitionMetadataResponse) MarshalTo(dAtA []byte) (int, error)
func (*FetchPartitionMetadataResponse) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *FetchPartitionMetadataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FetchPartitionMetadataResponse) ProtoMessage ¶ added in v1.3.0
func (*FetchPartitionMetadataResponse) ProtoMessage()
func (*FetchPartitionMetadataResponse) Reset ¶ added in v1.3.0
func (m *FetchPartitionMetadataResponse) Reset()
func (*FetchPartitionMetadataResponse) Size ¶ added in v1.3.0
func (m *FetchPartitionMetadataResponse) Size() (n int)
func (*FetchPartitionMetadataResponse) String ¶ added in v1.3.0
func (m *FetchPartitionMetadataResponse) String() string
func (*FetchPartitionMetadataResponse) Unmarshal ¶ added in v1.3.0
func (m *FetchPartitionMetadataResponse) Unmarshal(dAtA []byte) error
func (*FetchPartitionMetadataResponse) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *FetchPartitionMetadataResponse) XXX_DiscardUnknown()
func (*FetchPartitionMetadataResponse) XXX_Marshal ¶ added in v1.3.0
func (m *FetchPartitionMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FetchPartitionMetadataResponse) XXX_Merge ¶ added in v1.3.0
func (m *FetchPartitionMetadataResponse) XXX_Merge(src proto.Message)
func (*FetchPartitionMetadataResponse) XXX_Size ¶ added in v1.3.0
func (m *FetchPartitionMetadataResponse) XXX_Size() int
func (*FetchPartitionMetadataResponse) XXX_Unmarshal ¶ added in v1.3.0
func (m *FetchPartitionMetadataResponse) XXX_Unmarshal(b []byte) error
type JoinConsumerGroupOp ¶ added in v1.9.0
type JoinConsumerGroupOp struct { GroupId string `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"` ConsumerId string `protobuf:"bytes,2,opt,name=consumerId,proto3" json:"consumerId,omitempty"` Streams []string `protobuf:"bytes,3,rep,name=streams,proto3" json:"streams,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
JoinConsumerGroupOp represents a consumer group join operation.
func (*JoinConsumerGroupOp) Descriptor ¶ added in v1.9.0
func (*JoinConsumerGroupOp) Descriptor() ([]byte, []int)
func (*JoinConsumerGroupOp) GetConsumerId ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) GetConsumerId() string
func (*JoinConsumerGroupOp) GetGroupId ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) GetGroupId() string
func (*JoinConsumerGroupOp) GetStreams ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) GetStreams() []string
func (*JoinConsumerGroupOp) Marshal ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) Marshal() (dAtA []byte, err error)
func (*JoinConsumerGroupOp) MarshalTo ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) MarshalTo(dAtA []byte) (int, error)
func (*JoinConsumerGroupOp) MarshalToSizedBuffer ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JoinConsumerGroupOp) ProtoMessage ¶ added in v1.9.0
func (*JoinConsumerGroupOp) ProtoMessage()
func (*JoinConsumerGroupOp) Reset ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) Reset()
func (*JoinConsumerGroupOp) Size ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) Size() (n int)
func (*JoinConsumerGroupOp) String ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) String() string
func (*JoinConsumerGroupOp) Unmarshal ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) Unmarshal(dAtA []byte) error
func (*JoinConsumerGroupOp) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) XXX_DiscardUnknown()
func (*JoinConsumerGroupOp) XXX_Marshal ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JoinConsumerGroupOp) XXX_Merge ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) XXX_Merge(src proto.Message)
func (*JoinConsumerGroupOp) XXX_Size ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) XXX_Size() int
func (*JoinConsumerGroupOp) XXX_Unmarshal ¶ added in v1.9.0
func (m *JoinConsumerGroupOp) XXX_Unmarshal(b []byte) error
type JoinConsumerGroupRequest ¶ added in v1.8.0
type JoinConsumerGroupRequest struct { GroupId string `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"` ConsumerId string `protobuf:"bytes,2,opt,name=consumerId,proto3" json:"consumerId,omitempty"` Streams []string `protobuf:"bytes,3,rep,name=streams,proto3" json:"streams,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
JoinConsumerGroupRequest is sent to add a consumer to a consumer group.
func (*JoinConsumerGroupRequest) Descriptor ¶ added in v1.8.0
func (*JoinConsumerGroupRequest) Descriptor() ([]byte, []int)
func (*JoinConsumerGroupRequest) GetConsumerId ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) GetConsumerId() string
func (*JoinConsumerGroupRequest) GetGroupId ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) GetGroupId() string
func (*JoinConsumerGroupRequest) GetStreams ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) GetStreams() []string
func (*JoinConsumerGroupRequest) Marshal ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) Marshal() (dAtA []byte, err error)
func (*JoinConsumerGroupRequest) MarshalTo ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) MarshalTo(dAtA []byte) (int, error)
func (*JoinConsumerGroupRequest) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JoinConsumerGroupRequest) ProtoMessage ¶ added in v1.8.0
func (*JoinConsumerGroupRequest) ProtoMessage()
func (*JoinConsumerGroupRequest) Reset ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) Reset()
func (*JoinConsumerGroupRequest) Size ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) Size() (n int)
func (*JoinConsumerGroupRequest) String ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) String() string
func (*JoinConsumerGroupRequest) Unmarshal ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) Unmarshal(dAtA []byte) error
func (*JoinConsumerGroupRequest) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) XXX_DiscardUnknown()
func (*JoinConsumerGroupRequest) XXX_Marshal ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JoinConsumerGroupRequest) XXX_Merge ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) XXX_Merge(src proto.Message)
func (*JoinConsumerGroupRequest) XXX_Size ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) XXX_Size() int
func (*JoinConsumerGroupRequest) XXX_Unmarshal ¶ added in v1.8.0
func (m *JoinConsumerGroupRequest) XXX_Unmarshal(b []byte) error
type JoinConsumerGroupResponse ¶ added in v1.8.0
type JoinConsumerGroupResponse struct { Coordinator string `protobuf:"bytes,1,opt,name=coordinator,proto3" json:"coordinator,omitempty"` Epoch uint64 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"` ConsumerTimeout int64 `protobuf:"varint,3,opt,name=consumerTimeout,proto3" json:"consumerTimeout,omitempty"` CoordinatorTimeout int64 `protobuf:"varint,4,opt,name=coordinatorTimeout,proto3" json:"coordinatorTimeout,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
JoinConsumerGroupResponse is sent by the server after adding a consumer to a consumer group.
func (*JoinConsumerGroupResponse) Descriptor ¶ added in v1.8.0
func (*JoinConsumerGroupResponse) Descriptor() ([]byte, []int)
func (*JoinConsumerGroupResponse) GetConsumerTimeout ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) GetConsumerTimeout() int64
func (*JoinConsumerGroupResponse) GetCoordinator ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) GetCoordinator() string
func (*JoinConsumerGroupResponse) GetCoordinatorTimeout ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) GetCoordinatorTimeout() int64
func (*JoinConsumerGroupResponse) GetEpoch ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) GetEpoch() uint64
func (*JoinConsumerGroupResponse) Marshal ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) Marshal() (dAtA []byte, err error)
func (*JoinConsumerGroupResponse) MarshalTo ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) MarshalTo(dAtA []byte) (int, error)
func (*JoinConsumerGroupResponse) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JoinConsumerGroupResponse) ProtoMessage ¶ added in v1.8.0
func (*JoinConsumerGroupResponse) ProtoMessage()
func (*JoinConsumerGroupResponse) Reset ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) Reset()
func (*JoinConsumerGroupResponse) Size ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) Size() (n int)
func (*JoinConsumerGroupResponse) String ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) String() string
func (*JoinConsumerGroupResponse) Unmarshal ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) Unmarshal(dAtA []byte) error
func (*JoinConsumerGroupResponse) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) XXX_DiscardUnknown()
func (*JoinConsumerGroupResponse) XXX_Marshal ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JoinConsumerGroupResponse) XXX_Merge ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) XXX_Merge(src proto.Message)
func (*JoinConsumerGroupResponse) XXX_Size ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) XXX_Size() int
func (*JoinConsumerGroupResponse) XXX_Unmarshal ¶ added in v1.8.0
func (m *JoinConsumerGroupResponse) XXX_Unmarshal(b []byte) error
type LeaveConsumerGroupOp ¶ added in v1.9.0
type LeaveConsumerGroupOp struct { GroupId string `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"` ConsumerId string `protobuf:"bytes,2,opt,name=consumerId,proto3" json:"consumerId,omitempty"` Expired bool `protobuf:"varint,3,opt,name=expired,proto3" json:"expired,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
LeaveConsumerGroupOp represents a consumer group leave operation.
func (*LeaveConsumerGroupOp) Descriptor ¶ added in v1.9.0
func (*LeaveConsumerGroupOp) Descriptor() ([]byte, []int)
func (*LeaveConsumerGroupOp) GetConsumerId ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) GetConsumerId() string
func (*LeaveConsumerGroupOp) GetExpired ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) GetExpired() bool
func (*LeaveConsumerGroupOp) GetGroupId ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) GetGroupId() string
func (*LeaveConsumerGroupOp) Marshal ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) Marshal() (dAtA []byte, err error)
func (*LeaveConsumerGroupOp) MarshalTo ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) MarshalTo(dAtA []byte) (int, error)
func (*LeaveConsumerGroupOp) MarshalToSizedBuffer ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LeaveConsumerGroupOp) ProtoMessage ¶ added in v1.9.0
func (*LeaveConsumerGroupOp) ProtoMessage()
func (*LeaveConsumerGroupOp) Reset ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) Reset()
func (*LeaveConsumerGroupOp) Size ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) Size() (n int)
func (*LeaveConsumerGroupOp) String ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) String() string
func (*LeaveConsumerGroupOp) Unmarshal ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) Unmarshal(dAtA []byte) error
func (*LeaveConsumerGroupOp) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) XXX_DiscardUnknown()
func (*LeaveConsumerGroupOp) XXX_Marshal ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LeaveConsumerGroupOp) XXX_Merge ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) XXX_Merge(src proto.Message)
func (*LeaveConsumerGroupOp) XXX_Size ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) XXX_Size() int
func (*LeaveConsumerGroupOp) XXX_Unmarshal ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) XXX_Unmarshal(b []byte) error
type LeaveConsumerGroupRequest ¶ added in v1.8.0
type LeaveConsumerGroupRequest struct { GroupId string `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"` ConsumerId string `protobuf:"bytes,2,opt,name=consumerId,proto3" json:"consumerId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
LeaveConsumerGroupRequest is sent to remove a consumer from a consumer group.
func (*LeaveConsumerGroupRequest) Descriptor ¶ added in v1.8.0
func (*LeaveConsumerGroupRequest) Descriptor() ([]byte, []int)
func (*LeaveConsumerGroupRequest) GetConsumerId ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) GetConsumerId() string
func (*LeaveConsumerGroupRequest) GetGroupId ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) GetGroupId() string
func (*LeaveConsumerGroupRequest) Marshal ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) Marshal() (dAtA []byte, err error)
func (*LeaveConsumerGroupRequest) MarshalTo ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) MarshalTo(dAtA []byte) (int, error)
func (*LeaveConsumerGroupRequest) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LeaveConsumerGroupRequest) ProtoMessage ¶ added in v1.8.0
func (*LeaveConsumerGroupRequest) ProtoMessage()
func (*LeaveConsumerGroupRequest) Reset ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) Reset()
func (*LeaveConsumerGroupRequest) Size ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) Size() (n int)
func (*LeaveConsumerGroupRequest) String ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) String() string
func (*LeaveConsumerGroupRequest) Unmarshal ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) Unmarshal(dAtA []byte) error
func (*LeaveConsumerGroupRequest) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) XXX_DiscardUnknown()
func (*LeaveConsumerGroupRequest) XXX_Marshal ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LeaveConsumerGroupRequest) XXX_Merge ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) XXX_Merge(src proto.Message)
func (*LeaveConsumerGroupRequest) XXX_Size ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) XXX_Size() int
func (*LeaveConsumerGroupRequest) XXX_Unmarshal ¶ added in v1.8.0
func (m *LeaveConsumerGroupRequest) XXX_Unmarshal(b []byte) error
type LeaveConsumerGroupResponse ¶ added in v1.8.0
type LeaveConsumerGroupResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
LeaveConsumerGroupResponse is sent by the server after removing a consumer from a consumer group.
func (*LeaveConsumerGroupResponse) Descriptor ¶ added in v1.8.0
func (*LeaveConsumerGroupResponse) Descriptor() ([]byte, []int)
func (*LeaveConsumerGroupResponse) Marshal ¶ added in v1.8.0
func (m *LeaveConsumerGroupResponse) Marshal() (dAtA []byte, err error)
func (*LeaveConsumerGroupResponse) MarshalTo ¶ added in v1.8.0
func (m *LeaveConsumerGroupResponse) MarshalTo(dAtA []byte) (int, error)
func (*LeaveConsumerGroupResponse) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *LeaveConsumerGroupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LeaveConsumerGroupResponse) ProtoMessage ¶ added in v1.8.0
func (*LeaveConsumerGroupResponse) ProtoMessage()
func (*LeaveConsumerGroupResponse) Reset ¶ added in v1.8.0
func (m *LeaveConsumerGroupResponse) Reset()
func (*LeaveConsumerGroupResponse) Size ¶ added in v1.8.0
func (m *LeaveConsumerGroupResponse) Size() (n int)
func (*LeaveConsumerGroupResponse) String ¶ added in v1.8.0
func (m *LeaveConsumerGroupResponse) String() string
func (*LeaveConsumerGroupResponse) Unmarshal ¶ added in v1.8.0
func (m *LeaveConsumerGroupResponse) Unmarshal(dAtA []byte) error
func (*LeaveConsumerGroupResponse) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *LeaveConsumerGroupResponse) XXX_DiscardUnknown()
func (*LeaveConsumerGroupResponse) XXX_Marshal ¶ added in v1.8.0
func (m *LeaveConsumerGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LeaveConsumerGroupResponse) XXX_Merge ¶ added in v1.8.0
func (m *LeaveConsumerGroupResponse) XXX_Merge(src proto.Message)
func (*LeaveConsumerGroupResponse) XXX_Size ¶ added in v1.8.0
func (m *LeaveConsumerGroupResponse) XXX_Size() int
func (*LeaveConsumerGroupResponse) XXX_Unmarshal ¶ added in v1.8.0
func (m *LeaveConsumerGroupResponse) 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 PartitionAssignment ¶ added in v1.8.0
type PartitionAssignment 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:"-"` }
PartitionAssignment contains a set of stream partitions that are assigned to a consumer.
func (*PartitionAssignment) Descriptor ¶ added in v1.8.0
func (*PartitionAssignment) Descriptor() ([]byte, []int)
func (*PartitionAssignment) GetPartitions ¶ added in v1.8.0
func (m *PartitionAssignment) GetPartitions() []int32
func (*PartitionAssignment) GetStream ¶ added in v1.8.0
func (m *PartitionAssignment) GetStream() string
func (*PartitionAssignment) Marshal ¶ added in v1.8.0
func (m *PartitionAssignment) Marshal() (dAtA []byte, err error)
func (*PartitionAssignment) MarshalTo ¶ added in v1.8.0
func (m *PartitionAssignment) MarshalTo(dAtA []byte) (int, error)
func (*PartitionAssignment) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *PartitionAssignment) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PartitionAssignment) ProtoMessage ¶ added in v1.8.0
func (*PartitionAssignment) ProtoMessage()
func (*PartitionAssignment) Reset ¶ added in v1.8.0
func (m *PartitionAssignment) Reset()
func (*PartitionAssignment) Size ¶ added in v1.8.0
func (m *PartitionAssignment) Size() (n int)
func (*PartitionAssignment) String ¶ added in v1.8.0
func (m *PartitionAssignment) String() string
func (*PartitionAssignment) Unmarshal ¶ added in v1.8.0
func (m *PartitionAssignment) Unmarshal(dAtA []byte) error
func (*PartitionAssignment) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *PartitionAssignment) XXX_DiscardUnknown()
func (*PartitionAssignment) XXX_Marshal ¶ added in v1.8.0
func (m *PartitionAssignment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PartitionAssignment) XXX_Merge ¶ added in v1.8.0
func (m *PartitionAssignment) XXX_Merge(src proto.Message)
func (*PartitionAssignment) XXX_Size ¶ added in v1.8.0
func (m *PartitionAssignment) XXX_Size() int
func (*PartitionAssignment) XXX_Unmarshal ¶ added in v1.8.0
func (m *PartitionAssignment) XXX_Unmarshal(b []byte) error
type PartitionEventTimestamps ¶ added in v1.4.0
type PartitionEventTimestamps struct { FirstTimestamp int64 `protobuf:"varint,1,opt,name=firstTimestamp,proto3" json:"firstTimestamp,omitempty"` LatestTimestamp int64 `protobuf:"varint,2,opt,name=latestTimestamp,proto3" json:"latestTimestamp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PartitionEventTimestamps contains timestamps related to a stream partition.
func (*PartitionEventTimestamps) Descriptor ¶ added in v1.4.0
func (*PartitionEventTimestamps) Descriptor() ([]byte, []int)
func (*PartitionEventTimestamps) GetFirstTimestamp ¶ added in v1.4.0
func (m *PartitionEventTimestamps) GetFirstTimestamp() int64
func (*PartitionEventTimestamps) GetLatestTimestamp ¶ added in v1.4.0
func (m *PartitionEventTimestamps) GetLatestTimestamp() int64
func (*PartitionEventTimestamps) Marshal ¶ added in v1.4.0
func (m *PartitionEventTimestamps) Marshal() (dAtA []byte, err error)
func (*PartitionEventTimestamps) MarshalTo ¶ added in v1.4.0
func (m *PartitionEventTimestamps) MarshalTo(dAtA []byte) (int, error)
func (*PartitionEventTimestamps) MarshalToSizedBuffer ¶ added in v1.5.0
func (m *PartitionEventTimestamps) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PartitionEventTimestamps) ProtoMessage ¶ added in v1.4.0
func (*PartitionEventTimestamps) ProtoMessage()
func (*PartitionEventTimestamps) Reset ¶ added in v1.4.0
func (m *PartitionEventTimestamps) Reset()
func (*PartitionEventTimestamps) Size ¶ added in v1.4.0
func (m *PartitionEventTimestamps) Size() (n int)
func (*PartitionEventTimestamps) String ¶ added in v1.4.0
func (m *PartitionEventTimestamps) String() string
func (*PartitionEventTimestamps) Unmarshal ¶ added in v1.4.0
func (m *PartitionEventTimestamps) Unmarshal(dAtA []byte) error
func (*PartitionEventTimestamps) XXX_DiscardUnknown ¶ added in v1.4.0
func (m *PartitionEventTimestamps) XXX_DiscardUnknown()
func (*PartitionEventTimestamps) XXX_Marshal ¶ added in v1.4.0
func (m *PartitionEventTimestamps) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PartitionEventTimestamps) XXX_Merge ¶ added in v1.4.0
func (m *PartitionEventTimestamps) XXX_Merge(src proto.Message)
func (*PartitionEventTimestamps) XXX_Size ¶ added in v1.4.0
func (m *PartitionEventTimestamps) XXX_Size() int
func (*PartitionEventTimestamps) XXX_Unmarshal ¶ added in v1.4.0
func (m *PartitionEventTimestamps) 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"` Readonly bool `protobuf:"varint,8,opt,name=readonly,proto3" json:"readonly,omitempty"` MessagesReceivedTimestamps *PartitionEventTimestamps `protobuf:"bytes,9,opt,name=messagesReceivedTimestamps,proto3" json:"messagesReceivedTimestamps,omitempty"` PauseTimestamps *PartitionEventTimestamps `protobuf:"bytes,10,opt,name=pauseTimestamps,proto3" json:"pauseTimestamps,omitempty"` ReadonlyTimestamps *PartitionEventTimestamps `protobuf:"bytes,11,opt,name=readonlyTimestamps,proto3" json:"readonlyTimestamps,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.3.0
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) GetMessagesReceivedTimestamps ¶ added in v1.4.0
func (m *PartitionMetadata) GetMessagesReceivedTimestamps() *PartitionEventTimestamps
func (*PartitionMetadata) GetNewestOffset ¶ added in v1.3.0
func (m *PartitionMetadata) GetNewestOffset() int64
func (*PartitionMetadata) GetPauseTimestamps ¶ added in v1.4.0
func (m *PartitionMetadata) GetPauseTimestamps() *PartitionEventTimestamps
func (*PartitionMetadata) GetPaused ¶ added in v1.3.0
func (m *PartitionMetadata) GetPaused() bool
func (*PartitionMetadata) GetReadonly ¶ added in v1.4.0
func (m *PartitionMetadata) GetReadonly() bool
func (*PartitionMetadata) GetReadonlyTimestamps ¶ added in v1.4.0
func (m *PartitionMetadata) GetReadonlyTimestamps() *PartitionEventTimestamps
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 PublishAsyncError ¶ added in v1.3.0
type PublishAsyncError struct { Code PublishAsyncError_Code `protobuf:"varint,1,opt,name=code,proto3,enum=proto.PublishAsyncError_Code" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PublishAsyncError is returned on the PublishAsync stream if a publish failed.
func (*PublishAsyncError) Descriptor ¶ added in v1.3.0
func (*PublishAsyncError) Descriptor() ([]byte, []int)
func (*PublishAsyncError) GetCode ¶ added in v1.3.0
func (m *PublishAsyncError) GetCode() PublishAsyncError_Code
func (*PublishAsyncError) GetMessage ¶ added in v1.3.0
func (m *PublishAsyncError) GetMessage() string
func (*PublishAsyncError) Marshal ¶ added in v1.3.0
func (m *PublishAsyncError) Marshal() (dAtA []byte, err error)
func (*PublishAsyncError) MarshalTo ¶ added in v1.3.0
func (m *PublishAsyncError) MarshalTo(dAtA []byte) (int, error)
func (*PublishAsyncError) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *PublishAsyncError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PublishAsyncError) ProtoMessage ¶ added in v1.3.0
func (*PublishAsyncError) ProtoMessage()
func (*PublishAsyncError) Reset ¶ added in v1.3.0
func (m *PublishAsyncError) Reset()
func (*PublishAsyncError) Size ¶ added in v1.3.0
func (m *PublishAsyncError) Size() (n int)
func (*PublishAsyncError) String ¶ added in v1.3.0
func (m *PublishAsyncError) String() string
func (*PublishAsyncError) Unmarshal ¶ added in v1.3.0
func (m *PublishAsyncError) Unmarshal(dAtA []byte) error
func (*PublishAsyncError) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *PublishAsyncError) XXX_DiscardUnknown()
func (*PublishAsyncError) XXX_Marshal ¶ added in v1.3.0
func (m *PublishAsyncError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PublishAsyncError) XXX_Merge ¶ added in v1.3.0
func (m *PublishAsyncError) XXX_Merge(src proto.Message)
func (*PublishAsyncError) XXX_Size ¶ added in v1.3.0
func (m *PublishAsyncError) XXX_Size() int
func (*PublishAsyncError) XXX_Unmarshal ¶ added in v1.3.0
func (m *PublishAsyncError) XXX_Unmarshal(b []byte) error
type PublishAsyncError_Code ¶ added in v1.3.0
type PublishAsyncError_Code int32
const ( PublishAsyncError_UNKNOWN PublishAsyncError_Code = 0 PublishAsyncError_BAD_REQUEST PublishAsyncError_Code = 1 PublishAsyncError_NOT_FOUND PublishAsyncError_Code = 2 PublishAsyncError_INTERNAL PublishAsyncError_Code = 3 PublishAsyncError_READONLY PublishAsyncError_Code = 4 PublishAsyncError_INCORRECT_OFFSET PublishAsyncError_Code = 5 PublishAsyncError_ENCRYPTION_FAILED PublishAsyncError_Code = 6 PublishAsyncError_PERMISSION_DENIED PublishAsyncError_Code = 7 )
func (PublishAsyncError_Code) EnumDescriptor ¶ added in v1.3.0
func (PublishAsyncError_Code) EnumDescriptor() ([]byte, []int)
func (PublishAsyncError_Code) String ¶ added in v1.3.0
func (x PublishAsyncError_Code) String() string
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"` ExpectedOffset int64 `protobuf:"varint,9,opt,name=expectedOffset,proto3" json:"expectedOffset,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) GetExpectedOffset ¶ added in v1.4.0
func (m *PublishRequest) GetExpectedOffset() int64
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"` AsyncError *PublishAsyncError `protobuf:"bytes,2,opt,name=asyncError,proto3" json:"asyncError,omitempty"` CorrelationId string `protobuf:"bytes,3,opt,name=correlationId,proto3" json:"correlationId,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) GetAsyncError ¶ added in v1.3.0
func (m *PublishResponse) GetAsyncError() *PublishAsyncError
func (*PublishResponse) GetCorrelationId ¶ added in v1.3.0
func (m *PublishResponse) GetCorrelationId() string
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 ReportConsumerGroupCoordinatorRequest ¶ added in v1.8.0
type ReportConsumerGroupCoordinatorRequest struct { GroupId string `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"` ConsumerId string `protobuf:"bytes,2,opt,name=consumerId,proto3" json:"consumerId,omitempty"` Coordinator string `protobuf:"bytes,3,opt,name=coordinator,proto3" json:"coordinator,omitempty"` Epoch uint64 `protobuf:"varint,4,opt,name=epoch,proto3" json:"epoch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ReportConsumerGroupCoordinatorRequest is sent by a consumer group member to report the group coordinator as failed.
func (*ReportConsumerGroupCoordinatorRequest) Descriptor ¶ added in v1.8.0
func (*ReportConsumerGroupCoordinatorRequest) Descriptor() ([]byte, []int)
func (*ReportConsumerGroupCoordinatorRequest) GetConsumerId ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) GetConsumerId() string
func (*ReportConsumerGroupCoordinatorRequest) GetCoordinator ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) GetCoordinator() string
func (*ReportConsumerGroupCoordinatorRequest) GetEpoch ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) GetEpoch() uint64
func (*ReportConsumerGroupCoordinatorRequest) GetGroupId ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) GetGroupId() string
func (*ReportConsumerGroupCoordinatorRequest) Marshal ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) Marshal() (dAtA []byte, err error)
func (*ReportConsumerGroupCoordinatorRequest) MarshalTo ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) MarshalTo(dAtA []byte) (int, error)
func (*ReportConsumerGroupCoordinatorRequest) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReportConsumerGroupCoordinatorRequest) ProtoMessage ¶ added in v1.8.0
func (*ReportConsumerGroupCoordinatorRequest) ProtoMessage()
func (*ReportConsumerGroupCoordinatorRequest) Reset ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) Reset()
func (*ReportConsumerGroupCoordinatorRequest) Size ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) Size() (n int)
func (*ReportConsumerGroupCoordinatorRequest) String ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) String() string
func (*ReportConsumerGroupCoordinatorRequest) Unmarshal ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) Unmarshal(dAtA []byte) error
func (*ReportConsumerGroupCoordinatorRequest) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) XXX_DiscardUnknown()
func (*ReportConsumerGroupCoordinatorRequest) XXX_Marshal ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReportConsumerGroupCoordinatorRequest) XXX_Merge ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) XXX_Merge(src proto.Message)
func (*ReportConsumerGroupCoordinatorRequest) XXX_Size ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) XXX_Size() int
func (*ReportConsumerGroupCoordinatorRequest) XXX_Unmarshal ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorRequest) XXX_Unmarshal(b []byte) error
type ReportConsumerGroupCoordinatorResponse ¶ added in v1.8.0
type ReportConsumerGroupCoordinatorResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ReportConsumerGroupCoordinatorResponse is sent by the server in response to a request to report a consumer group coordinator.
func (*ReportConsumerGroupCoordinatorResponse) Descriptor ¶ added in v1.8.0
func (*ReportConsumerGroupCoordinatorResponse) Descriptor() ([]byte, []int)
func (*ReportConsumerGroupCoordinatorResponse) Marshal ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorResponse) Marshal() (dAtA []byte, err error)
func (*ReportConsumerGroupCoordinatorResponse) MarshalTo ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorResponse) MarshalTo(dAtA []byte) (int, error)
func (*ReportConsumerGroupCoordinatorResponse) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReportConsumerGroupCoordinatorResponse) ProtoMessage ¶ added in v1.8.0
func (*ReportConsumerGroupCoordinatorResponse) ProtoMessage()
func (*ReportConsumerGroupCoordinatorResponse) Reset ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorResponse) Reset()
func (*ReportConsumerGroupCoordinatorResponse) Size ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorResponse) Size() (n int)
func (*ReportConsumerGroupCoordinatorResponse) String ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorResponse) String() string
func (*ReportConsumerGroupCoordinatorResponse) Unmarshal ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorResponse) Unmarshal(dAtA []byte) error
func (*ReportConsumerGroupCoordinatorResponse) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorResponse) XXX_DiscardUnknown()
func (*ReportConsumerGroupCoordinatorResponse) XXX_Marshal ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReportConsumerGroupCoordinatorResponse) XXX_Merge ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorResponse) XXX_Merge(src proto.Message)
func (*ReportConsumerGroupCoordinatorResponse) XXX_Size ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorResponse) XXX_Size() int
func (*ReportConsumerGroupCoordinatorResponse) XXX_Unmarshal ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorResponse) 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 SetCursorRequest ¶ added in v1.3.0
type SetCursorRequest 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"` CursorId string `protobuf:"bytes,3,opt,name=cursorId,proto3" json:"cursorId,omitempty"` Offset int64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SetCursorRequest is sent to set a consumer's cursor position for a particular stream partition.
func (*SetCursorRequest) Descriptor ¶ added in v1.3.0
func (*SetCursorRequest) Descriptor() ([]byte, []int)
func (*SetCursorRequest) GetCursorId ¶ added in v1.3.0
func (m *SetCursorRequest) GetCursorId() string
func (*SetCursorRequest) GetOffset ¶ added in v1.3.0
func (m *SetCursorRequest) GetOffset() int64
func (*SetCursorRequest) GetPartition ¶ added in v1.3.0
func (m *SetCursorRequest) GetPartition() int32
func (*SetCursorRequest) GetStream ¶ added in v1.3.0
func (m *SetCursorRequest) GetStream() string
func (*SetCursorRequest) Marshal ¶ added in v1.3.0
func (m *SetCursorRequest) Marshal() (dAtA []byte, err error)
func (*SetCursorRequest) MarshalTo ¶ added in v1.3.0
func (m *SetCursorRequest) MarshalTo(dAtA []byte) (int, error)
func (*SetCursorRequest) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *SetCursorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetCursorRequest) ProtoMessage ¶ added in v1.3.0
func (*SetCursorRequest) ProtoMessage()
func (*SetCursorRequest) Reset ¶ added in v1.3.0
func (m *SetCursorRequest) Reset()
func (*SetCursorRequest) Size ¶ added in v1.3.0
func (m *SetCursorRequest) Size() (n int)
func (*SetCursorRequest) String ¶ added in v1.3.0
func (m *SetCursorRequest) String() string
func (*SetCursorRequest) Unmarshal ¶ added in v1.3.0
func (m *SetCursorRequest) Unmarshal(dAtA []byte) error
func (*SetCursorRequest) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *SetCursorRequest) XXX_DiscardUnknown()
func (*SetCursorRequest) XXX_Marshal ¶ added in v1.3.0
func (m *SetCursorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetCursorRequest) XXX_Merge ¶ added in v1.3.0
func (m *SetCursorRequest) XXX_Merge(src proto.Message)
func (*SetCursorRequest) XXX_Size ¶ added in v1.3.0
func (m *SetCursorRequest) XXX_Size() int
func (*SetCursorRequest) XXX_Unmarshal ¶ added in v1.3.0
func (m *SetCursorRequest) XXX_Unmarshal(b []byte) error
type SetCursorResponse ¶ added in v1.3.0
type SetCursorResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SetCursorResponse is sent by the server after setting a consumer cursor.
func (*SetCursorResponse) Descriptor ¶ added in v1.3.0
func (*SetCursorResponse) Descriptor() ([]byte, []int)
func (*SetCursorResponse) Marshal ¶ added in v1.3.0
func (m *SetCursorResponse) Marshal() (dAtA []byte, err error)
func (*SetCursorResponse) MarshalTo ¶ added in v1.3.0
func (m *SetCursorResponse) MarshalTo(dAtA []byte) (int, error)
func (*SetCursorResponse) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *SetCursorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetCursorResponse) ProtoMessage ¶ added in v1.3.0
func (*SetCursorResponse) ProtoMessage()
func (*SetCursorResponse) Reset ¶ added in v1.3.0
func (m *SetCursorResponse) Reset()
func (*SetCursorResponse) Size ¶ added in v1.3.0
func (m *SetCursorResponse) Size() (n int)
func (*SetCursorResponse) String ¶ added in v1.3.0
func (m *SetCursorResponse) String() string
func (*SetCursorResponse) Unmarshal ¶ added in v1.3.0
func (m *SetCursorResponse) Unmarshal(dAtA []byte) error
func (*SetCursorResponse) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *SetCursorResponse) XXX_DiscardUnknown()
func (*SetCursorResponse) XXX_Marshal ¶ added in v1.3.0
func (m *SetCursorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetCursorResponse) XXX_Merge ¶ added in v1.3.0
func (m *SetCursorResponse) XXX_Merge(src proto.Message)
func (*SetCursorResponse) XXX_Size ¶ added in v1.3.0
func (m *SetCursorResponse) XXX_Size() int
func (*SetCursorResponse) XXX_Unmarshal ¶ added in v1.3.0
func (m *SetCursorResponse) XXX_Unmarshal(b []byte) error
type SetStreamReadonlyOp ¶ added in v1.3.0
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.3.0
func (*SetStreamReadonlyOp) Descriptor() ([]byte, []int)
func (*SetStreamReadonlyOp) GetPartitions ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) GetPartitions() []int32
func (*SetStreamReadonlyOp) GetReadonly ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) GetReadonly() bool
func (*SetStreamReadonlyOp) GetStream ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) GetStream() string
func (*SetStreamReadonlyOp) Marshal ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) Marshal() (dAtA []byte, err error)
func (*SetStreamReadonlyOp) MarshalTo ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) MarshalTo(dAtA []byte) (int, error)
func (*SetStreamReadonlyOp) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetStreamReadonlyOp) ProtoMessage ¶ added in v1.3.0
func (*SetStreamReadonlyOp) ProtoMessage()
func (*SetStreamReadonlyOp) Reset ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) Reset()
func (*SetStreamReadonlyOp) Size ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) Size() (n int)
func (*SetStreamReadonlyOp) String ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) String() string
func (*SetStreamReadonlyOp) Unmarshal ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) Unmarshal(dAtA []byte) error
func (*SetStreamReadonlyOp) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) XXX_DiscardUnknown()
func (*SetStreamReadonlyOp) XXX_Marshal ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetStreamReadonlyOp) XXX_Merge ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) XXX_Merge(src proto.Message)
func (*SetStreamReadonlyOp) XXX_Size ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) XXX_Size() int
func (*SetStreamReadonlyOp) XXX_Unmarshal ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) XXX_Unmarshal(b []byte) error
type SetStreamReadonlyRequest ¶ added in v1.3.0
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.3.0
func (*SetStreamReadonlyRequest) Descriptor() ([]byte, []int)
func (*SetStreamReadonlyRequest) GetName ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) GetName() string
func (*SetStreamReadonlyRequest) GetPartitions ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) GetPartitions() []int32
func (*SetStreamReadonlyRequest) GetReadonly ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) GetReadonly() bool
func (*SetStreamReadonlyRequest) Marshal ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) Marshal() (dAtA []byte, err error)
func (*SetStreamReadonlyRequest) MarshalTo ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) MarshalTo(dAtA []byte) (int, error)
func (*SetStreamReadonlyRequest) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetStreamReadonlyRequest) ProtoMessage ¶ added in v1.3.0
func (*SetStreamReadonlyRequest) ProtoMessage()
func (*SetStreamReadonlyRequest) Reset ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) Reset()
func (*SetStreamReadonlyRequest) Size ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) Size() (n int)
func (*SetStreamReadonlyRequest) String ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) String() string
func (*SetStreamReadonlyRequest) Unmarshal ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) Unmarshal(dAtA []byte) error
func (*SetStreamReadonlyRequest) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) XXX_DiscardUnknown()
func (*SetStreamReadonlyRequest) XXX_Marshal ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetStreamReadonlyRequest) XXX_Merge ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) XXX_Merge(src proto.Message)
func (*SetStreamReadonlyRequest) XXX_Size ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) XXX_Size() int
func (*SetStreamReadonlyRequest) XXX_Unmarshal ¶ added in v1.3.0
func (m *SetStreamReadonlyRequest) XXX_Unmarshal(b []byte) error
type SetStreamReadonlyResponse ¶ added in v1.3.0
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.3.0
func (*SetStreamReadonlyResponse) Descriptor() ([]byte, []int)
func (*SetStreamReadonlyResponse) Marshal ¶ added in v1.3.0
func (m *SetStreamReadonlyResponse) Marshal() (dAtA []byte, err error)
func (*SetStreamReadonlyResponse) MarshalTo ¶ added in v1.3.0
func (m *SetStreamReadonlyResponse) MarshalTo(dAtA []byte) (int, error)
func (*SetStreamReadonlyResponse) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *SetStreamReadonlyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetStreamReadonlyResponse) ProtoMessage ¶ added in v1.3.0
func (*SetStreamReadonlyResponse) ProtoMessage()
func (*SetStreamReadonlyResponse) Reset ¶ added in v1.3.0
func (m *SetStreamReadonlyResponse) Reset()
func (*SetStreamReadonlyResponse) Size ¶ added in v1.3.0
func (m *SetStreamReadonlyResponse) Size() (n int)
func (*SetStreamReadonlyResponse) String ¶ added in v1.3.0
func (m *SetStreamReadonlyResponse) String() string
func (*SetStreamReadonlyResponse) Unmarshal ¶ added in v1.3.0
func (m *SetStreamReadonlyResponse) Unmarshal(dAtA []byte) error
func (*SetStreamReadonlyResponse) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *SetStreamReadonlyResponse) XXX_DiscardUnknown()
func (*SetStreamReadonlyResponse) XXX_Marshal ¶ added in v1.3.0
func (m *SetStreamReadonlyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetStreamReadonlyResponse) XXX_Merge ¶ added in v1.3.0
func (m *SetStreamReadonlyResponse) XXX_Merge(src proto.Message)
func (*SetStreamReadonlyResponse) XXX_Size ¶ added in v1.3.0
func (m *SetStreamReadonlyResponse) XXX_Size() int
func (*SetStreamReadonlyResponse) XXX_Unmarshal ¶ added in v1.3.0
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 StopPosition ¶ added in v1.4.0
type StopPosition int32
StopPosition determines the stop-position type on a subscription.
const ( StopPosition_STOP_ON_CANCEL StopPosition = 0 StopPosition_STOP_OFFSET StopPosition = 1 StopPosition_STOP_LATEST StopPosition = 2 StopPosition_STOP_TIMESTAMP StopPosition = 3 )
func (StopPosition) EnumDescriptor ¶ added in v1.4.0
func (StopPosition) EnumDescriptor() ([]byte, []int)
func (StopPosition) String ¶ added in v1.4.0
func (x StopPosition) 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 */ CreationTimestamp int64 `protobuf:"varint,5,opt,name=creationTimestamp,proto3" json:"creationTimestamp,omitempty"` 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) GetCreationTimestamp ¶ added in v1.4.0
func (m *StreamMetadata) GetCreationTimestamp() int64
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"` StopPosition StopPosition `protobuf:"varint,8,opt,name=stopPosition,proto3,enum=proto.StopPosition" json:"stopPosition,omitempty"` StopOffset int64 `protobuf:"varint,9,opt,name=stopOffset,proto3" json:"stopOffset,omitempty"` StopTimestamp int64 `protobuf:"varint,10,opt,name=stopTimestamp,proto3" json:"stopTimestamp,omitempty"` Consumer *Consumer `protobuf:"bytes,11,opt,name=consumer,proto3" json:"consumer,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) GetConsumer ¶ added in v1.8.0
func (m *SubscribeRequest) GetConsumer() *Consumer
func (*SubscribeRequest) GetPartition ¶
func (m *SubscribeRequest) GetPartition() int32
func (*SubscribeRequest) GetReadISRReplica ¶
func (m *SubscribeRequest) GetReadISRReplica() bool
func (*SubscribeRequest) GetResume ¶ added in v1.3.0
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) GetStopOffset ¶ added in v1.4.0
func (m *SubscribeRequest) GetStopOffset() int64
func (*SubscribeRequest) GetStopPosition ¶ added in v1.4.0
func (m *SubscribeRequest) GetStopPosition() StopPosition
func (*SubscribeRequest) GetStopTimestamp ¶ added in v1.4.0
func (m *SubscribeRequest) GetStopTimestamp() 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) FetchConsumerGroupAssignments ¶ added in v1.8.0
func (*UnimplementedAPIServer) FetchConsumerGroupAssignments(ctx context.Context, req *FetchConsumerGroupAssignmentsRequest) (*FetchConsumerGroupAssignmentsResponse, error)
func (*UnimplementedAPIServer) FetchCursor ¶ added in v1.3.0
func (*UnimplementedAPIServer) FetchCursor(ctx context.Context, req *FetchCursorRequest) (*FetchCursorResponse, error)
func (*UnimplementedAPIServer) FetchMetadata ¶ added in v1.1.0
func (*UnimplementedAPIServer) FetchMetadata(ctx context.Context, req *FetchMetadataRequest) (*FetchMetadataResponse, error)
func (*UnimplementedAPIServer) FetchPartitionMetadata ¶ added in v1.3.0
func (*UnimplementedAPIServer) FetchPartitionMetadata(ctx context.Context, req *FetchPartitionMetadataRequest) (*FetchPartitionMetadataResponse, error)
func (*UnimplementedAPIServer) JoinConsumerGroup ¶ added in v1.8.0
func (*UnimplementedAPIServer) JoinConsumerGroup(ctx context.Context, req *JoinConsumerGroupRequest) (*JoinConsumerGroupResponse, error)
func (*UnimplementedAPIServer) LeaveConsumerGroup ¶ added in v1.8.0
func (*UnimplementedAPIServer) LeaveConsumerGroup(ctx context.Context, req *LeaveConsumerGroupRequest) (*LeaveConsumerGroupResponse, 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) ReportConsumerGroupCoordinator ¶ added in v1.8.0
func (*UnimplementedAPIServer) ReportConsumerGroupCoordinator(ctx context.Context, req *ReportConsumerGroupCoordinatorRequest) (*ReportConsumerGroupCoordinatorResponse, error)
func (*UnimplementedAPIServer) SetCursor ¶ added in v1.3.0
func (*UnimplementedAPIServer) SetCursor(ctx context.Context, req *SetCursorRequest) (*SetCursorResponse, error)
func (*UnimplementedAPIServer) SetStreamReadonly ¶ added in v1.3.0
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