Documentation ¶
Overview ¶
Package proto is a generated protocol buffer package.
It is generated from these files:
api.proto
It has these top-level messages:
CreateStreamRequest CreateStreamResponse SubscribeRequest FetchMetadataRequest FetchMetadataResponse PublishRequest PublishResponse Broker StreamMetadata PartitionMetadata Message Ack
Index ¶
- Variables
- func RegisterAPIServer(s *grpc.Server, srv APIServer)
- type APIClient
- type APIServer
- type API_SubscribeClient
- type API_SubscribeServer
- type Ack
- func (*Ack) Descriptor() ([]byte, []int)
- func (m *Ack) GetAckInbox() string
- func (m *Ack) GetAckPolicy() AckPolicy
- func (m *Ack) GetCorrelationId() string
- func (m *Ack) GetMsgSubject() string
- func (m *Ack) GetOffset() int64
- func (m *Ack) GetPartitionSubject() string
- func (m *Ack) GetStream() string
- func (m *Ack) Marshal() (dAtA []byte, err error)
- func (m *Ack) MarshalTo(dAtA []byte) (int, error)
- func (*Ack) ProtoMessage()
- func (m *Ack) Reset()
- func (m *Ack) Size() (n int)
- func (m *Ack) String() string
- func (m *Ack) Unmarshal(dAtA []byte) error
- type AckPolicy
- type Broker
- func (*Broker) Descriptor() ([]byte, []int)
- func (m *Broker) GetHost() string
- func (m *Broker) GetId() string
- func (m *Broker) GetPort() int32
- func (m *Broker) Marshal() (dAtA []byte, err error)
- func (m *Broker) MarshalTo(dAtA []byte) (int, error)
- func (*Broker) ProtoMessage()
- func (m *Broker) Reset()
- func (m *Broker) Size() (n int)
- func (m *Broker) String() string
- func (m *Broker) Unmarshal(dAtA []byte) error
- type CreateStreamRequest
- func (*CreateStreamRequest) Descriptor() ([]byte, []int)
- func (m *CreateStreamRequest) GetGroup() string
- func (m *CreateStreamRequest) GetName() string
- func (m *CreateStreamRequest) GetPartitions() int32
- func (m *CreateStreamRequest) GetReplicationFactor() int32
- func (m *CreateStreamRequest) GetSubject() string
- func (m *CreateStreamRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateStreamRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CreateStreamRequest) ProtoMessage()
- func (m *CreateStreamRequest) Reset()
- func (m *CreateStreamRequest) Size() (n int)
- func (m *CreateStreamRequest) String() string
- func (m *CreateStreamRequest) Unmarshal(dAtA []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 (*CreateStreamResponse) ProtoMessage()
- func (m *CreateStreamResponse) Reset()
- func (m *CreateStreamResponse) Size() (n int)
- func (m *CreateStreamResponse) String() string
- func (m *CreateStreamResponse) Unmarshal(dAtA []byte) error
- type FetchMetadataRequest
- func (*FetchMetadataRequest) Descriptor() ([]byte, []int)
- func (m *FetchMetadataRequest) GetStreams() []string
- func (m *FetchMetadataRequest) Marshal() (dAtA []byte, err error)
- func (m *FetchMetadataRequest) MarshalTo(dAtA []byte) (int, error)
- func (*FetchMetadataRequest) ProtoMessage()
- func (m *FetchMetadataRequest) Reset()
- func (m *FetchMetadataRequest) Size() (n int)
- func (m *FetchMetadataRequest) String() string
- func (m *FetchMetadataRequest) Unmarshal(dAtA []byte) error
- type FetchMetadataResponse
- func (*FetchMetadataResponse) Descriptor() ([]byte, []int)
- func (m *FetchMetadataResponse) GetBrokers() []*Broker
- func (m *FetchMetadataResponse) GetMetadata() []*StreamMetadata
- func (m *FetchMetadataResponse) Marshal() (dAtA []byte, err error)
- func (m *FetchMetadataResponse) MarshalTo(dAtA []byte) (int, error)
- func (*FetchMetadataResponse) ProtoMessage()
- func (m *FetchMetadataResponse) Reset()
- func (m *FetchMetadataResponse) Size() (n int)
- func (m *FetchMetadataResponse) String() string
- func (m *FetchMetadataResponse) Unmarshal(dAtA []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 (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) Size() (n int)
- func (m *Message) String() string
- func (m *Message) Unmarshal(dAtA []byte) error
- type PartitionMetadata
- func (*PartitionMetadata) Descriptor() ([]byte, []int)
- func (m *PartitionMetadata) GetId() int32
- func (m *PartitionMetadata) GetIsr() []string
- func (m *PartitionMetadata) GetLeader() string
- func (m *PartitionMetadata) GetReplicas() []string
- func (m *PartitionMetadata) Marshal() (dAtA []byte, err error)
- func (m *PartitionMetadata) MarshalTo(dAtA []byte) (int, error)
- func (*PartitionMetadata) ProtoMessage()
- func (m *PartitionMetadata) Reset()
- func (m *PartitionMetadata) Size() (n int)
- func (m *PartitionMetadata) String() string
- func (m *PartitionMetadata) Unmarshal(dAtA []byte) error
- type PublishRequest
- func (*PublishRequest) Descriptor() ([]byte, []int)
- func (m *PublishRequest) GetAckInbox() string
- func (m *PublishRequest) GetAckPolicy() AckPolicy
- func (m *PublishRequest) GetCorrelationId() string
- func (m *PublishRequest) GetHeaders() map[string][]byte
- func (m *PublishRequest) GetKey() []byte
- func (m *PublishRequest) GetPartition() int32
- func (m *PublishRequest) GetReplySubject() string
- func (m *PublishRequest) GetStream() string
- func (m *PublishRequest) GetSubject() string
- func (m *PublishRequest) GetValue() []byte
- func (m *PublishRequest) Marshal() (dAtA []byte, err error)
- func (m *PublishRequest) MarshalTo(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
- type PublishResponse
- func (*PublishResponse) Descriptor() ([]byte, []int)
- func (m *PublishResponse) GetAck() *Ack
- func (m *PublishResponse) Marshal() (dAtA []byte, err error)
- func (m *PublishResponse) MarshalTo(dAtA []byte) (int, error)
- func (*PublishResponse) ProtoMessage()
- func (m *PublishResponse) Reset()
- func (m *PublishResponse) Size() (n int)
- func (m *PublishResponse) String() string
- func (m *PublishResponse) Unmarshal(dAtA []byte) error
- type StartPosition
- type StreamMetadata
- func (*StreamMetadata) Descriptor() ([]byte, []int)
- func (m *StreamMetadata) GetError() StreamMetadata_Error
- func (m *StreamMetadata) GetName() string
- func (m *StreamMetadata) GetPartitions() map[int32]*PartitionMetadata
- func (m *StreamMetadata) GetSubject() string
- func (m *StreamMetadata) Marshal() (dAtA []byte, err error)
- func (m *StreamMetadata) MarshalTo(dAtA []byte) (int, error)
- func (*StreamMetadata) ProtoMessage()
- func (m *StreamMetadata) Reset()
- func (m *StreamMetadata) Size() (n int)
- func (m *StreamMetadata) String() string
- func (m *StreamMetadata) Unmarshal(dAtA []byte) error
- type StreamMetadata_Error
- type SubscribeRequest
- func (*SubscribeRequest) Descriptor() ([]byte, []int)
- func (m *SubscribeRequest) GetPartition() int32
- func (m *SubscribeRequest) GetStartOffset() int64
- func (m *SubscribeRequest) GetStartPosition() StartPosition
- func (m *SubscribeRequest) GetStartTimestamp() int64
- func (m *SubscribeRequest) GetStream() string
- func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)
- func (m *SubscribeRequest) MarshalTo(dAtA []byte) (int, error)
- func (*SubscribeRequest) ProtoMessage()
- func (m *SubscribeRequest) Reset()
- func (m *SubscribeRequest) Size() (n int)
- func (m *SubscribeRequest) String() string
- func (m *SubscribeRequest) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowApi = fmt.Errorf("proto: integer overflow") )
var AckPolicy_name = map[int32]string{
0: "LEADER",
1: "ALL",
2: "NONE",
}
var AckPolicy_value = map[string]int32{
"LEADER": 0,
"ALL": 1,
"NONE": 2,
}
var StartPosition_name = map[int32]string{
0: "NEW_ONLY",
1: "OFFSET",
2: "EARLIEST",
3: "LATEST",
4: "TIMESTAMP",
}
var StartPosition_value = map[string]int32{
"NEW_ONLY": 0,
"OFFSET": 1,
"EARLIEST": 2,
"LATEST": 3,
"TIMESTAMP": 4,
}
var StreamMetadata_Error_name = map[int32]string{
0: "OK",
1: "UNKNOWN_STREAM",
}
var StreamMetadata_Error_value = map[string]int32{
"OK": 0,
"UNKNOWN_STREAM": 1,
}
Functions ¶
func RegisterAPIServer ¶
Types ¶
type APIClient ¶
type APIClient interface { // CreateStream creates a new stream attached to a NATS subject. It returns // an AlreadyExists status code if a stream with the given subject and name // already exists. CreateStream(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*CreateStreamResponse, error) // Subscribe creates an ephemeral subscription for the given stream. It // begins to receive messages starting at the given offset and waits for // new messages when it reaches the end of the stream. Use the request // context to close the subscription. Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (API_SubscribeClient, error) // FetchMetadata retrieves the latest cluster metadata, including stream // broker information. FetchMetadata(ctx context.Context, in *FetchMetadataRequest, opts ...grpc.CallOption) (*FetchMetadataResponse, error) // Publish a new message to a subject. 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) }
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) // Subscribe creates an ephemeral subscription for the given stream. It // begins to receive messages starting at the given offset and waits for // new messages when it reaches the end of the stream. Use the request // context to close the subscription. Subscribe(*SubscribeRequest, API_SubscribeServer) error // FetchMetadata retrieves the latest cluster metadata, including stream // broker information. FetchMetadata(context.Context, *FetchMetadataRequest) (*FetchMetadataResponse, error) // Publish a new message to a subject. 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) }
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"` }
Ack represents an acknowledgement that a message was committed to a stream partition.
func (*Ack) Descriptor ¶
func (*Ack) GetAckInbox ¶
func (*Ack) GetAckPolicy ¶
func (*Ack) GetCorrelationId ¶
func (*Ack) GetMsgSubject ¶
func (*Ack) GetPartitionSubject ¶
func (*Ack) ProtoMessage ¶
func (*Ack) ProtoMessage()
type AckPolicy ¶
type AckPolicy int32
AckPolicy controls the behavior of message acknowledgements.
func (AckPolicy) EnumDescriptor ¶
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"` }
Broker contains information for a Liftbridge broker.
func (*Broker) Descriptor ¶
func (*Broker) ProtoMessage ¶
func (*Broker) ProtoMessage()
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"` }
CreateStreamRequest is sent to create a new stream.
func (*CreateStreamRequest) Descriptor ¶
func (*CreateStreamRequest) Descriptor() ([]byte, []int)
func (*CreateStreamRequest) GetGroup ¶
func (m *CreateStreamRequest) GetGroup() string
func (*CreateStreamRequest) GetName ¶
func (m *CreateStreamRequest) GetName() string
func (*CreateStreamRequest) GetPartitions ¶
func (m *CreateStreamRequest) GetPartitions() int32
func (*CreateStreamRequest) GetReplicationFactor ¶
func (m *CreateStreamRequest) GetReplicationFactor() int32
func (*CreateStreamRequest) 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) 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
type CreateStreamResponse ¶
type CreateStreamResponse struct { }
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) 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
type FetchMetadataRequest ¶
type FetchMetadataRequest struct {
Streams []string `protobuf:"bytes,1,rep,name=streams" json:"streams,omitempty"`
}
FetchMetadataRequest is sent to retrieve the latest cluster metadata.
func (*FetchMetadataRequest) Descriptor ¶
func (*FetchMetadataRequest) Descriptor() ([]byte, []int)
func (*FetchMetadataRequest) GetStreams ¶
func (m *FetchMetadataRequest) GetStreams() []string
func (*FetchMetadataRequest) Marshal ¶
func (m *FetchMetadataRequest) Marshal() (dAtA []byte, err error)
func (*FetchMetadataRequest) MarshalTo ¶
func (m *FetchMetadataRequest) MarshalTo(dAtA []byte) (int, error)
func (*FetchMetadataRequest) 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
type FetchMetadataResponse ¶
type FetchMetadataResponse struct { Brokers []*Broker `protobuf:"bytes,1,rep,name=brokers" json:"brokers,omitempty"` Metadata []*StreamMetadata `protobuf:"bytes,2,rep,name=metadata" json:"metadata,omitempty"` }
FetchMetadataResponse contains the cluster metadata requested.
func (*FetchMetadataResponse) Descriptor ¶
func (*FetchMetadataResponse) Descriptor() ([]byte, []int)
func (*FetchMetadataResponse) GetBrokers ¶
func (m *FetchMetadataResponse) GetBrokers() []*Broker
func (*FetchMetadataResponse) GetMetadata ¶
func (m *FetchMetadataResponse) GetMetadata() []*StreamMetadata
func (*FetchMetadataResponse) Marshal ¶
func (m *FetchMetadataResponse) Marshal() (dAtA []byte, err error)
func (*FetchMetadataResponse) MarshalTo ¶
func (m *FetchMetadataResponse) MarshalTo(dAtA []byte) (int, error)
func (*FetchMetadataResponse) 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
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 `` /* 148-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"` }
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) ProtoMessage ¶
func (*Message) ProtoMessage()
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" json:"replicas,omitempty"` Isr []string `protobuf:"bytes,4,rep,name=isr" json:"isr,omitempty"` }
PartitionMetadata contains information for a stream partition.
func (*PartitionMetadata) Descriptor ¶
func (*PartitionMetadata) Descriptor() ([]byte, []int)
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) 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) 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
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"` Subject string `protobuf:"bytes,5,opt,name=subject,proto3" json:"subject,omitempty"` ReplySubject string `protobuf:"bytes,6,opt,name=replySubject,proto3" json:"replySubject,omitempty"` Headers map[string][]byte `` /* 148-byte string literal not displayed */ AckInbox string `protobuf:"bytes,8,opt,name=ackInbox,proto3" json:"ackInbox,omitempty"` CorrelationId string `protobuf:"bytes,9,opt,name=correlationId,proto3" json:"correlationId,omitempty"` AckPolicy AckPolicy `protobuf:"varint,10,opt,name=ackPolicy,proto3,enum=proto.AckPolicy" json:"ackPolicy,omitempty"` }
PublishRequest is sent to publish a new message.
func (*PublishRequest) Descriptor ¶
func (*PublishRequest) Descriptor() ([]byte, []int)
func (*PublishRequest) GetAckInbox ¶
func (m *PublishRequest) GetAckInbox() string
func (*PublishRequest) GetAckPolicy ¶
func (m *PublishRequest) GetAckPolicy() AckPolicy
func (*PublishRequest) GetCorrelationId ¶
func (m *PublishRequest) GetCorrelationId() string
func (*PublishRequest) GetHeaders ¶
func (m *PublishRequest) GetHeaders() map[string][]byte
func (*PublishRequest) GetKey ¶
func (m *PublishRequest) GetKey() []byte
func (*PublishRequest) GetPartition ¶
func (m *PublishRequest) GetPartition() int32
func (*PublishRequest) GetReplySubject ¶
func (m *PublishRequest) GetReplySubject() string
func (*PublishRequest) GetStream ¶
func (m *PublishRequest) GetStream() string
func (*PublishRequest) GetSubject ¶
func (m *PublishRequest) GetSubject() string
func (*PublishRequest) GetValue ¶
func (m *PublishRequest) GetValue() []byte
func (*PublishRequest) Marshal ¶
func (m *PublishRequest) Marshal() (dAtA []byte, err 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
type PublishResponse ¶
type PublishResponse struct {
Ack *Ack `protobuf:"bytes,1,opt,name=ack" json:"ack,omitempty"`
}
PublishResponse is sent by the server after publishing a message.
func (*PublishResponse) Descriptor ¶
func (*PublishResponse) Descriptor() ([]byte, []int)
func (*PublishResponse) GetAck ¶
func (m *PublishResponse) GetAck() *Ack
func (*PublishResponse) Marshal ¶
func (m *PublishResponse) Marshal() (dAtA []byte, err error)
func (*PublishResponse) 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
type StartPosition ¶
type StartPosition int32
StartPosition determines the start-position type on a subscription.
const ( StartPosition_NEW_ONLY StartPosition = 0 StartPosition_OFFSET StartPosition = 1 StartPosition_EARLIEST StartPosition = 2 StartPosition_LATEST StartPosition = 3 StartPosition_TIMESTAMP StartPosition = 4 )
func (StartPosition) EnumDescriptor ¶
func (StartPosition) EnumDescriptor() ([]byte, []int)
func (StartPosition) String ¶
func (x StartPosition) String() string
type StreamMetadata ¶
type StreamMetadata struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Subject string `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"` Error StreamMetadata_Error `protobuf:"varint,3,opt,name=error,proto3,enum=proto.StreamMetadata_Error" json:"error,omitempty"` Partitions map[int32]*PartitionMetadata `` /* 148-byte string literal not displayed */ }
StreamMetadata contains information for a stream.
func (*StreamMetadata) Descriptor ¶
func (*StreamMetadata) Descriptor() ([]byte, []int)
func (*StreamMetadata) GetError ¶
func (m *StreamMetadata) GetError() StreamMetadata_Error
func (*StreamMetadata) GetName ¶
func (m *StreamMetadata) GetName() string
func (*StreamMetadata) GetPartitions ¶
func (m *StreamMetadata) GetPartitions() map[int32]*PartitionMetadata
func (*StreamMetadata) GetSubject ¶
func (m *StreamMetadata) GetSubject() string
func (*StreamMetadata) Marshal ¶
func (m *StreamMetadata) Marshal() (dAtA []byte, err error)
func (*StreamMetadata) 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
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"` }
SubscribeRequest is sent to subscribe to a stream partition.
func (*SubscribeRequest) Descriptor ¶
func (*SubscribeRequest) Descriptor() ([]byte, []int)
func (*SubscribeRequest) GetPartition ¶
func (m *SubscribeRequest) GetPartition() int32
func (*SubscribeRequest) GetStartOffset ¶
func (m *SubscribeRequest) GetStartOffset() int64
func (*SubscribeRequest) GetStartPosition ¶
func (m *SubscribeRequest) GetStartPosition() StartPosition
func (*SubscribeRequest) GetStartTimestamp ¶
func (m *SubscribeRequest) GetStartTimestamp() int64
func (*SubscribeRequest) GetStream ¶
func (m *SubscribeRequest) GetStream() string
func (*SubscribeRequest) Marshal ¶
func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)
func (*SubscribeRequest) 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