proto

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 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
DeleteStreamRequest
DeleteStreamResponse
PauseStreamRequest
PauseStreamResponse
SubscribeRequest
FetchMetadataRequest
FetchMetadataResponse
PublishRequest
PublishResponse
PublishToSubjectRequest
PublishToSubjectResponse
Broker
StreamMetadata
PartitionMetadata
Message
Ack
CreateStreamOp
DeleteStreamOp
PauseStreamOp
ResumeStreamOp
ActivityStreamEvent

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 ActivityStreamOp_name = map[int32]string{
	0: "CREATE_STREAM",
	1: "DELETE_STREAM",
	2: "PAUSE_STREAM",
	3: "RESUME_STREAM",
}
View Source 
var ActivityStreamOp_value = map[string]int32{
	"CREATE_STREAM": 0,
	"DELETE_STREAM": 1,
	"PAUSE_STREAM":  2,
	"RESUME_STREAM": 3,
}
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)
	// 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)
	// Subscribe creates an ephemeral subscription for the given stream. It
	// begins to receive messages starting at the given offset and waits for
	// new messages when it reaches the end of the stream. Use the request
	// context to close the subscription.
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (API_SubscribeClient, error)
	// FetchMetadata retrieves the latest cluster metadata, including stream
	// broker information.
	FetchMetadata(ctx context.Context, in *FetchMetadataRequest, opts ...grpc.CallOption) (*FetchMetadataResponse, error)
	// Publish a new message to a stream. If the AckPolicy is not NONE and a
	// deadline is provided, this will synchronously block until the ack is
	// received. If the ack is not received in time, a DeadlineExceeded status
	// code is returned.
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	// 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)
}

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)
	// Subscribe creates an ephemeral subscription for the given stream. It
	// begins to receive messages starting at the given offset and waits for
	// new messages when it reaches the end of the stream. Use the request
	// context to close the subscription.
	Subscribe(*SubscribeRequest, API_SubscribeServer) error
	// FetchMetadata retrieves the latest cluster metadata, including stream
	// broker information.
	FetchMetadata(context.Context, *FetchMetadataRequest) (*FetchMetadataResponse, error)
	// Publish a new message to a stream. If the AckPolicy is not NONE and a
	// deadline is provided, this will synchronously block until the ack is
	// received. If the ack is not received in time, a DeadlineExceeded status
	// code is returned.
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	// 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)
}

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 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" json:"createStreamOp,omitempty"`
	DeleteStreamOp *DeleteStreamOp  `protobuf:"bytes,4,opt,name=deleteStreamOp" json:"deleteStreamOp,omitempty"`
	PauseStreamOp  *PauseStreamOp   `protobuf:"bytes,5,opt,name=pauseStreamOp" json:"pauseStreamOp,omitempty"`
	ResumeStreamOp *ResumeStreamOp  `protobuf:"bytes,6,opt,name=resumeStreamOp" json:"resumeStreamOp,omitempty"`
}

ActivityStreamEvent represents an entry into the activity stream.

func (*ActivityStreamEvent) Descriptor 

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

func (*ActivityStreamEvent) GetCreateStreamOp 

func (m *ActivityStreamEvent) GetCreateStreamOp() *CreateStreamOp

func (*ActivityStreamEvent) GetDeleteStreamOp 

func (m *ActivityStreamEvent) GetDeleteStreamOp() *DeleteStreamOp

func (*ActivityStreamEvent) GetId 

func (m *ActivityStreamEvent) GetId() uint64

func (*ActivityStreamEvent) GetOp 

func (m *ActivityStreamEvent) GetOp() ActivityStreamOp

func (*ActivityStreamEvent) GetPauseStreamOp 

func (m *ActivityStreamEvent) GetPauseStreamOp() *PauseStreamOp

func (*ActivityStreamEvent) GetResumeStreamOp 

func (m *ActivityStreamEvent) GetResumeStreamOp() *ResumeStreamOp

func (*ActivityStreamEvent) Marshal 

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

func (*ActivityStreamEvent) MarshalTo 

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

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
)

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"`
}

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 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" json:"partitions,omitempty"`
}

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

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

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 DeleteStreamOp 

type DeleteStreamOp struct {
	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
}

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

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

type DeleteStreamRequest 

type DeleteStreamRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

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

type DeleteStreamResponse 

type DeleteStreamResponse struct {
}

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

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 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" json:"partitions,omitempty"`
	ResumeAll  bool    `protobuf:"varint,3,opt,name=resumeAll,proto3" json:"resumeAll,omitempty"`
}

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

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

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" json:"partitions,omitempty"`
	ResumeAll  bool    `protobuf:"varint,3,opt,name=resumeAll,proto3" json:"resumeAll,omitempty"`
}

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

type PauseStreamResponse 

type PauseStreamResponse struct {
}

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

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 `` /* 148-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"`
}

PublishRequest is sent to publish a new message to a stream.

func (*PublishRequest) Descriptor 

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

func (*PublishRequest) GetAckInbox 

func (m *PublishRequest) GetAckInbox() string

func (*PublishRequest) GetAckPolicy 

func (m *PublishRequest) GetAckPolicy() AckPolicy

func (*PublishRequest) GetCorrelationId 

func (m *PublishRequest) GetCorrelationId() string

func (*PublishRequest) GetHeaders 

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

func (*PublishRequest) GetKey 

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

func (*PublishRequest) GetPartition 

func (m *PublishRequest) GetPartition() int32

func (*PublishRequest) GetStream 

func (m *PublishRequest) GetStream() string

func (*PublishRequest) GetValue 

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

func (*PublishRequest) Marshal 

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

func (*PublishRequest) 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 to a stream.

func (*PublishResponse) Descriptor 

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

func (*PublishResponse) GetAck 

func (m *PublishResponse) GetAck() *Ack

func (*PublishResponse) Marshal 

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

func (*PublishResponse) 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 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 `` /* 148-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"`
}

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

type PublishToSubjectResponse 

type PublishToSubjectResponse struct {
	Ack *Ack `protobuf:"bytes,1,opt,name=ack" json:"ack,omitempty"`
}

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

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" json:"partitions,omitempty"`
}

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

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

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"`
	ReadISRReplica bool          `protobuf:"varint,6,opt,name=readISRReplica,proto3" json:"readISRReplica,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) GetReadISRReplica 

func (m *SubscribeRequest) GetReadISRReplica() bool

func (*SubscribeRequest) GetStartOffset 

func (m *SubscribeRequest) GetStartOffset() int64

func (*SubscribeRequest) GetStartPosition 

func (m *SubscribeRequest) GetStartPosition() StartPosition

func (*SubscribeRequest) GetStartTimestamp 

func (m *SubscribeRequest) GetStartTimestamp() int64

func (*SubscribeRequest) GetStream 

func (m *SubscribeRequest) GetStream() string

func (*SubscribeRequest) Marshal 

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

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