proto

package
v1.0.0-beta Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

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

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi   = fmt.Errorf("proto: integer overflow")
)
View Source 
var AckPolicy_name = map[int32]string{
	0: "LEADER",
	1: "ALL",
	2: "NONE",
}
View Source 
var AckPolicy_value = map[string]int32{
	"LEADER": 0,
	"ALL":    1,
	"NONE":   2,
}
View Source 
var StartPosition_name = map[int32]string{
	0: "NEW_ONLY",
	1: "OFFSET",
	2: "EARLIEST",
	3: "LATEST",
	4: "TIMESTAMP",
}
View Source 
var StartPosition_value = map[string]int32{
	"NEW_ONLY":  0,
	"OFFSET":    1,
	"EARLIEST":  2,
	"LATEST":    3,
	"TIMESTAMP": 4,
}
View Source 
var StreamMetadata_Error_name = map[int32]string{
	0: "OK",
	1: "UNKNOWN_STREAM",
}
View Source 
var StreamMetadata_Error_value = map[string]int32{
	"OK":             0,
	"UNKNOWN_STREAM": 1,
}

Functions

func RegisterAPIServer 

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

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) Descriptor() ([]byte, []int)

func (*Ack) GetAckInbox 

func (m *Ack) GetAckInbox() string

func (*Ack) GetAckPolicy 

func (m *Ack) GetAckPolicy() AckPolicy

func (*Ack) GetCorrelationId 

func (m *Ack) GetCorrelationId() string

func (*Ack) GetMsgSubject 

func (m *Ack) GetMsgSubject() string

func (*Ack) GetOffset 

func (m *Ack) GetOffset() int64

func (*Ack) GetPartitionSubject 

func (m *Ack) GetPartitionSubject() string

func (*Ack) GetStream 

func (m *Ack) GetStream() string

func (*Ack) Marshal 

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

func (*Ack) MarshalTo 

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

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) Reset 

func (m *Ack) Reset()

func (*Ack) Size 

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

func (*Ack) String 

func (m *Ack) String() string

func (*Ack) Unmarshal 

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

type AckPolicy 

type AckPolicy int32

AckPolicy controls the behavior of message acknowledgements. 

const (
	AckPolicy_LEADER AckPolicy = 0
	AckPolicy_ALL    AckPolicy = 1
	AckPolicy_NONE   AckPolicy = 2
)

func (AckPolicy) EnumDescriptor 

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

func (AckPolicy) String 

func (x AckPolicy) 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"`
}

Broker contains information for a Liftbridge broker.

func (*Broker) Descriptor 

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

func (*Broker) GetHost 

func (m *Broker) GetHost() string

func (*Broker) GetId 

func (m *Broker) GetId() string

func (*Broker) GetPort 

func (m *Broker) GetPort() int32

func (*Broker) Marshal 

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

func (*Broker) MarshalTo 

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

func (*Broker) ProtoMessage 

func (*Broker) ProtoMessage()

func (*Broker) Reset 

func (m *Broker) Reset()

func (*Broker) Size 

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

func (*Broker) String 

func (m *Broker) String() string

func (*Broker) Unmarshal 

func (m *Broker) Unmarshal(dAtA []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"`
}

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) Descriptor() ([]byte, []int)

func (*Message) GetAckInbox 

func (m *Message) GetAckInbox() string

func (*Message) GetAckPolicy 

func (m *Message) GetAckPolicy() AckPolicy

func (*Message) GetCorrelationId 

func (m *Message) GetCorrelationId() string

func (*Message) GetHeaders 

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

func (*Message) GetKey 

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

func (*Message) GetOffset 

func (m *Message) GetOffset() int64

func (*Message) GetPartition 

func (m *Message) GetPartition() int32

func (*Message) GetReplySubject 

func (m *Message) GetReplySubject() string

func (*Message) GetStream 

func (m *Message) GetStream() string

func (*Message) GetSubject 

func (m *Message) GetSubject() string

func (*Message) GetTimestamp 

func (m *Message) GetTimestamp() int64

func (*Message) GetValue 

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

func (*Message) Marshal 

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

func (*Message) MarshalTo 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

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

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

func (m *Message) Unmarshal(dAtA []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" 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) MarshalTo 

func (m *PublishRequest) MarshalTo(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

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) MarshalTo 

func (m *PublishResponse) MarshalTo(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

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) MarshalTo 

func (m *StreamMetadata) MarshalTo(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

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) MarshalTo 

func (m *SubscribeRequest) MarshalTo(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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.