messaging_pb

package
v0.0.0-...-935c85c Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SubscriberMessage_InitMessage_StartPosition_name = map[int32]string{
		0: "LATEST",
		1: "EARLIEST",
		2: "TIMESTAMP",
	}
	SubscriberMessage_InitMessage_StartPosition_value = map[string]int32{
		"LATEST":    0,
		"EARLIEST":  1,
		"TIMESTAMP": 2,
	}
)

Enum value maps for SubscriberMessage_InitMessage_StartPosition.

View Source 
var (
	TopicConfiguration_Partitioning_name = map[int32]string{
		0: "NonNullKeyHash",
		1: "KeyHash",
		2: "RoundRobin",
	}
	TopicConfiguration_Partitioning_value = map[string]int32{
		"NonNullKeyHash": 0,
		"KeyHash":        1,
		"RoundRobin":     2,
	}
)

Enum value maps for TopicConfiguration_Partitioning.

View Source 
var File_messaging_proto protoreflect.FileDescriptor

Functions

func RegisterSeaweedMessagingServer 

func RegisterSeaweedMessagingServer(s *grpc.Server, srv SeaweedMessagingServer)

Types

type BrokerMessage 

type BrokerMessage struct {
	Data *Message `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*BrokerMessage) Descriptor deprecated 

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

Deprecated: Use BrokerMessage.ProtoReflect.Descriptor instead.

func (*BrokerMessage) GetData 

func (x *BrokerMessage) GetData() *Message

func (*BrokerMessage) ProtoMessage 

func (*BrokerMessage) ProtoMessage()

func (*BrokerMessage) ProtoReflect 

func (x *BrokerMessage) ProtoReflect() protoreflect.Message

func (*BrokerMessage) Reset 

func (x *BrokerMessage) Reset()

func (*BrokerMessage) String 

func (x *BrokerMessage) String() string

type ConfigureTopicRequest 

type ConfigureTopicRequest struct {
	Namespace     string              `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Topic         string              `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Configuration *TopicConfiguration `protobuf:"bytes,3,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigureTopicRequest) Descriptor deprecated 

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

Deprecated: Use ConfigureTopicRequest.ProtoReflect.Descriptor instead.

func (*ConfigureTopicRequest) GetConfiguration 

func (x *ConfigureTopicRequest) GetConfiguration() *TopicConfiguration

func (*ConfigureTopicRequest) GetNamespace 

func (x *ConfigureTopicRequest) GetNamespace() string

func (*ConfigureTopicRequest) GetTopic 

func (x *ConfigureTopicRequest) GetTopic() string

func (*ConfigureTopicRequest) ProtoMessage 

func (*ConfigureTopicRequest) ProtoMessage()

func (*ConfigureTopicRequest) ProtoReflect 

func (x *ConfigureTopicRequest) ProtoReflect() protoreflect.Message

func (*ConfigureTopicRequest) Reset 

func (x *ConfigureTopicRequest) Reset()

func (*ConfigureTopicRequest) String 

func (x *ConfigureTopicRequest) String() string

type ConfigureTopicResponse 

type ConfigureTopicResponse struct {
	// contains filtered or unexported fields
}

func (*ConfigureTopicResponse) Descriptor deprecated 

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

Deprecated: Use ConfigureTopicResponse.ProtoReflect.Descriptor instead.

func (*ConfigureTopicResponse) ProtoMessage 

func (*ConfigureTopicResponse) ProtoMessage()

func (*ConfigureTopicResponse) ProtoReflect 

func (x *ConfigureTopicResponse) ProtoReflect() protoreflect.Message

func (*ConfigureTopicResponse) Reset 

func (x *ConfigureTopicResponse) Reset()

func (*ConfigureTopicResponse) String 

func (x *ConfigureTopicResponse) String() string

type DeleteTopicRequest 

type DeleteTopicRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Topic     string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTopicRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTopicRequest.ProtoReflect.Descriptor instead.

func (*DeleteTopicRequest) GetNamespace 

func (x *DeleteTopicRequest) GetNamespace() string

func (*DeleteTopicRequest) GetTopic 

func (x *DeleteTopicRequest) GetTopic() string

func (*DeleteTopicRequest) ProtoMessage 

func (*DeleteTopicRequest) ProtoMessage()

func (*DeleteTopicRequest) ProtoReflect 

func (x *DeleteTopicRequest) ProtoReflect() protoreflect.Message

func (*DeleteTopicRequest) Reset 

func (x *DeleteTopicRequest) Reset()

func (*DeleteTopicRequest) String 

func (x *DeleteTopicRequest) String() string

type DeleteTopicResponse 

type DeleteTopicResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteTopicResponse) Descriptor deprecated 

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

Deprecated: Use DeleteTopicResponse.ProtoReflect.Descriptor instead.

func (*DeleteTopicResponse) ProtoMessage 

func (*DeleteTopicResponse) ProtoMessage()

func (*DeleteTopicResponse) ProtoReflect 

func (x *DeleteTopicResponse) ProtoReflect() protoreflect.Message

func (*DeleteTopicResponse) Reset 

func (x *DeleteTopicResponse) Reset()

func (*DeleteTopicResponse) String 

func (x *DeleteTopicResponse) String() string

type FindBrokerRequest 

type FindBrokerRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Topic     string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Parition  int32  `protobuf:"varint,3,opt,name=parition,proto3" json:"parition,omitempty"`
	// contains filtered or unexported fields
}

func (*FindBrokerRequest) Descriptor deprecated 

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

Deprecated: Use FindBrokerRequest.ProtoReflect.Descriptor instead.

func (*FindBrokerRequest) GetNamespace 

func (x *FindBrokerRequest) GetNamespace() string

func (*FindBrokerRequest) GetParition 

func (x *FindBrokerRequest) GetParition() int32

func (*FindBrokerRequest) GetTopic 

func (x *FindBrokerRequest) GetTopic() string

func (*FindBrokerRequest) ProtoMessage 

func (*FindBrokerRequest) ProtoMessage()

func (*FindBrokerRequest) ProtoReflect 

func (x *FindBrokerRequest) ProtoReflect() protoreflect.Message

func (*FindBrokerRequest) Reset 

func (x *FindBrokerRequest) Reset()

func (*FindBrokerRequest) String 

func (x *FindBrokerRequest) String() string

type FindBrokerResponse 

type FindBrokerResponse struct {
	Broker string `protobuf:"bytes,1,opt,name=broker,proto3" json:"broker,omitempty"`
	// contains filtered or unexported fields
}

func (*FindBrokerResponse) Descriptor deprecated 

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

Deprecated: Use FindBrokerResponse.ProtoReflect.Descriptor instead.

func (*FindBrokerResponse) GetBroker 

func (x *FindBrokerResponse) GetBroker() string

func (*FindBrokerResponse) ProtoMessage 

func (*FindBrokerResponse) ProtoMessage()

func (*FindBrokerResponse) ProtoReflect 

func (x *FindBrokerResponse) ProtoReflect() protoreflect.Message

func (*FindBrokerResponse) Reset 

func (x *FindBrokerResponse) Reset()

func (*FindBrokerResponse) String 

func (x *FindBrokerResponse) String() string

type GetTopicConfigurationRequest 

type GetTopicConfigurationRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Topic     string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTopicConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use GetTopicConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetTopicConfigurationRequest) GetNamespace 

func (x *GetTopicConfigurationRequest) GetNamespace() string

func (*GetTopicConfigurationRequest) GetTopic 

func (x *GetTopicConfigurationRequest) GetTopic() string

func (*GetTopicConfigurationRequest) ProtoMessage 

func (*GetTopicConfigurationRequest) ProtoMessage()

func (*GetTopicConfigurationRequest) ProtoReflect 

func (x *GetTopicConfigurationRequest) ProtoReflect() protoreflect.Message

func (*GetTopicConfigurationRequest) Reset 

func (x *GetTopicConfigurationRequest) Reset()

func (*GetTopicConfigurationRequest) String 

func (x *GetTopicConfigurationRequest) String() string

type GetTopicConfigurationResponse 

type GetTopicConfigurationResponse struct {
	Configuration *TopicConfiguration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTopicConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use GetTopicConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetTopicConfigurationResponse) GetConfiguration 

func (x *GetTopicConfigurationResponse) GetConfiguration() *TopicConfiguration

func (*GetTopicConfigurationResponse) ProtoMessage 

func (*GetTopicConfigurationResponse) ProtoMessage()

func (*GetTopicConfigurationResponse) ProtoReflect 

func (x *GetTopicConfigurationResponse) ProtoReflect() protoreflect.Message

func (*GetTopicConfigurationResponse) Reset 

func (x *GetTopicConfigurationResponse) Reset()

func (*GetTopicConfigurationResponse) String 

func (x *GetTopicConfigurationResponse) String() string

type Message 

type Message struct {
	EventTimeNs int64             `protobuf:"varint,1,opt,name=event_time_ns,json=eventTimeNs,proto3" json:"event_time_ns,omitempty"`
	Key         []byte            `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`     // Message key
	Value       []byte            `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // Message payload
	Headers     map[string][]byte ``                                                                // Message headers
	/* 155-byte string literal not displayed */
	IsClose bool `protobuf:"varint,5,opt,name=is_close,json=isClose,proto3" json:"is_close,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetEventTimeNs 

func (x *Message) GetEventTimeNs() int64

func (*Message) GetHeaders 

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

func (*Message) GetIsClose 

func (x *Message) GetIsClose() bool

func (*Message) GetKey 

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

func (*Message) GetValue 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type PublishRequest 

type PublishRequest struct {
	Init *PublishRequest_InitMessage `protobuf:"bytes,1,opt,name=init,proto3" json:"init,omitempty"`
	Data *Message                    `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor deprecated 

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetData 

func (x *PublishRequest) GetData() *Message

func (*PublishRequest) GetInit 

func (x *PublishRequest) GetInit() *PublishRequest_InitMessage

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect 

func (x *PublishRequest) ProtoReflect() protoreflect.Message

func (*PublishRequest) Reset 

func (x *PublishRequest) Reset()

func (*PublishRequest) String 

func (x *PublishRequest) String() string

type PublishRequest_InitMessage 

type PublishRequest_InitMessage struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` // only needed on the initial request
	Topic     string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`         // only needed on the initial request
	Partition int32  `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest_InitMessage) Descriptor deprecated 

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

Deprecated: Use PublishRequest_InitMessage.ProtoReflect.Descriptor instead.

func (*PublishRequest_InitMessage) GetNamespace 

func (x *PublishRequest_InitMessage) GetNamespace() string

func (*PublishRequest_InitMessage) GetPartition 

func (x *PublishRequest_InitMessage) GetPartition() int32

func (*PublishRequest_InitMessage) GetTopic 

func (x *PublishRequest_InitMessage) GetTopic() string

func (*PublishRequest_InitMessage) ProtoMessage 

func (*PublishRequest_InitMessage) ProtoMessage()

func (*PublishRequest_InitMessage) ProtoReflect 

func (x *PublishRequest_InitMessage) ProtoReflect() protoreflect.Message

func (*PublishRequest_InitMessage) Reset 

func (x *PublishRequest_InitMessage) Reset()

func (*PublishRequest_InitMessage) String 

func (x *PublishRequest_InitMessage) String() string

type PublishResponse 

type PublishResponse struct {
	Config   *PublishResponse_ConfigMessage   `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Redirect *PublishResponse_RedirectMessage `protobuf:"bytes,2,opt,name=redirect,proto3" json:"redirect,omitempty"`
	IsClosed bool                             `protobuf:"varint,3,opt,name=is_closed,json=isClosed,proto3" json:"is_closed,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishResponse) Descriptor deprecated 

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) GetConfig 

func (x *PublishResponse) GetConfig() *PublishResponse_ConfigMessage

func (*PublishResponse) GetIsClosed 

func (x *PublishResponse) GetIsClosed() bool

func (*PublishResponse) GetRedirect 

func (x *PublishResponse) GetRedirect() *PublishResponse_RedirectMessage

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect 

func (x *PublishResponse) ProtoReflect() protoreflect.Message

func (*PublishResponse) Reset 

func (x *PublishResponse) Reset()

func (*PublishResponse) String 

func (x *PublishResponse) String() string

type PublishResponse_ConfigMessage 

type PublishResponse_ConfigMessage struct {
	PartitionCount int32 `protobuf:"varint,1,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishResponse_ConfigMessage) Descriptor deprecated 

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

Deprecated: Use PublishResponse_ConfigMessage.ProtoReflect.Descriptor instead.

func (*PublishResponse_ConfigMessage) GetPartitionCount 

func (x *PublishResponse_ConfigMessage) GetPartitionCount() int32

func (*PublishResponse_ConfigMessage) ProtoMessage 

func (*PublishResponse_ConfigMessage) ProtoMessage()

func (*PublishResponse_ConfigMessage) ProtoReflect 

func (x *PublishResponse_ConfigMessage) ProtoReflect() protoreflect.Message

func (*PublishResponse_ConfigMessage) Reset 

func (x *PublishResponse_ConfigMessage) Reset()

func (*PublishResponse_ConfigMessage) String 

func (x *PublishResponse_ConfigMessage) String() string

type PublishResponse_RedirectMessage 

type PublishResponse_RedirectMessage struct {
	NewBroker string `protobuf:"bytes,1,opt,name=new_broker,json=newBroker,proto3" json:"new_broker,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishResponse_RedirectMessage) Descriptor deprecated 

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

Deprecated: Use PublishResponse_RedirectMessage.ProtoReflect.Descriptor instead.

func (*PublishResponse_RedirectMessage) GetNewBroker 

func (x *PublishResponse_RedirectMessage) GetNewBroker() string

func (*PublishResponse_RedirectMessage) ProtoMessage 

func (*PublishResponse_RedirectMessage) ProtoMessage()

func (*PublishResponse_RedirectMessage) ProtoReflect 

func (x *PublishResponse_RedirectMessage) ProtoReflect() protoreflect.Message

func (*PublishResponse_RedirectMessage) Reset 

func (x *PublishResponse_RedirectMessage) Reset()

func (*PublishResponse_RedirectMessage) String 

func (x *PublishResponse_RedirectMessage) String() string

type SeaweedMessagingClient 

type SeaweedMessagingClient interface {
	Subscribe(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_SubscribeClient, error)
	Publish(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_PublishClient, error)
	DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*DeleteTopicResponse, error)
	ConfigureTopic(ctx context.Context, in *ConfigureTopicRequest, opts ...grpc.CallOption) (*ConfigureTopicResponse, error)
	GetTopicConfiguration(ctx context.Context, in *GetTopicConfigurationRequest, opts ...grpc.CallOption) (*GetTopicConfigurationResponse, error)
	FindBroker(ctx context.Context, in *FindBrokerRequest, opts ...grpc.CallOption) (*FindBrokerResponse, error)
}

SeaweedMessagingClient is the client API for SeaweedMessaging service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSeaweedMessagingClient 

func NewSeaweedMessagingClient(cc grpc.ClientConnInterface) SeaweedMessagingClient

type SeaweedMessagingServer 

type SeaweedMessagingServer interface {
	Subscribe(SeaweedMessaging_SubscribeServer) error
	Publish(SeaweedMessaging_PublishServer) error
	DeleteTopic(context.Context, *DeleteTopicRequest) (*DeleteTopicResponse, error)
	ConfigureTopic(context.Context, *ConfigureTopicRequest) (*ConfigureTopicResponse, error)
	GetTopicConfiguration(context.Context, *GetTopicConfigurationRequest) (*GetTopicConfigurationResponse, error)
	FindBroker(context.Context, *FindBrokerRequest) (*FindBrokerResponse, error)
}

SeaweedMessagingServer is the server API for SeaweedMessaging service.

type SeaweedMessaging_PublishClient 

type SeaweedMessaging_PublishClient interface {
	Send(*PublishRequest) error
	Recv() (*PublishResponse, error)
	grpc.ClientStream
}

type SeaweedMessaging_PublishServer 

type SeaweedMessaging_PublishServer interface {
	Send(*PublishResponse) error
	Recv() (*PublishRequest, error)
	grpc.ServerStream
}

type SeaweedMessaging_SubscribeClient 

type SeaweedMessaging_SubscribeClient interface {
	Send(*SubscriberMessage) error
	Recv() (*BrokerMessage, error)
	grpc.ClientStream
}

type SeaweedMessaging_SubscribeServer 

type SeaweedMessaging_SubscribeServer interface {
	Send(*BrokerMessage) error
	Recv() (*SubscriberMessage, error)
	grpc.ServerStream
}

type SubscriberMessage 

type SubscriberMessage struct {
	Init    *SubscriberMessage_InitMessage `protobuf:"bytes,1,opt,name=init,proto3" json:"init,omitempty"`
	Ack     *SubscriberMessage_AckMessage  `protobuf:"bytes,2,opt,name=ack,proto3" json:"ack,omitempty"`
	IsClose bool                           `protobuf:"varint,3,opt,name=is_close,json=isClose,proto3" json:"is_close,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriberMessage) Descriptor deprecated 

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

Deprecated: Use SubscriberMessage.ProtoReflect.Descriptor instead.

func (*SubscriberMessage) GetAck 

func (x *SubscriberMessage) GetAck() *SubscriberMessage_AckMessage

func (*SubscriberMessage) GetInit 

func (x *SubscriberMessage) GetInit() *SubscriberMessage_InitMessage

func (*SubscriberMessage) GetIsClose 

func (x *SubscriberMessage) GetIsClose() bool

func (*SubscriberMessage) ProtoMessage 

func (*SubscriberMessage) ProtoMessage()

func (*SubscriberMessage) ProtoReflect 

func (x *SubscriberMessage) ProtoReflect() protoreflect.Message

func (*SubscriberMessage) Reset 

func (x *SubscriberMessage) Reset()

func (*SubscriberMessage) String 

func (x *SubscriberMessage) String() string

type SubscriberMessage_AckMessage 

type SubscriberMessage_AckMessage struct {
	MessageId int64 `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriberMessage_AckMessage) Descriptor deprecated 

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

Deprecated: Use SubscriberMessage_AckMessage.ProtoReflect.Descriptor instead.

func (*SubscriberMessage_AckMessage) GetMessageId 

func (x *SubscriberMessage_AckMessage) GetMessageId() int64

func (*SubscriberMessage_AckMessage) ProtoMessage 

func (*SubscriberMessage_AckMessage) ProtoMessage()

func (*SubscriberMessage_AckMessage) ProtoReflect 

func (x *SubscriberMessage_AckMessage) ProtoReflect() protoreflect.Message

func (*SubscriberMessage_AckMessage) Reset 

func (x *SubscriberMessage_AckMessage) Reset()

func (*SubscriberMessage_AckMessage) String 

func (x *SubscriberMessage_AckMessage) String() string

type SubscriberMessage_InitMessage 

type SubscriberMessage_InitMessage struct {
	Namespace     string                                      `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Topic         string                                      `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition     int32                                       `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	StartPosition SubscriberMessage_InitMessage_StartPosition `` // Where to begin consuming from
	/* 142-byte string literal not displayed */
	TimestampNs  int64  `protobuf:"varint,5,opt,name=timestampNs,proto3" json:"timestampNs,omitempty"`                      // timestamp in nano seconds
	SubscriberId string `protobuf:"bytes,6,opt,name=subscriber_id,json=subscriberId,proto3" json:"subscriber_id,omitempty"` // uniquely identify a subscriber to track consumption
	// contains filtered or unexported fields
}

func (*SubscriberMessage_InitMessage) Descriptor deprecated 

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

Deprecated: Use SubscriberMessage_InitMessage.ProtoReflect.Descriptor instead.

func (*SubscriberMessage_InitMessage) GetNamespace 

func (x *SubscriberMessage_InitMessage) GetNamespace() string

func (*SubscriberMessage_InitMessage) GetPartition 

func (x *SubscriberMessage_InitMessage) GetPartition() int32

func (*SubscriberMessage_InitMessage) GetStartPosition 

func (x *SubscriberMessage_InitMessage) GetStartPosition() SubscriberMessage_InitMessage_StartPosition

func (*SubscriberMessage_InitMessage) GetSubscriberId 

func (x *SubscriberMessage_InitMessage) GetSubscriberId() string

func (*SubscriberMessage_InitMessage) GetTimestampNs 

func (x *SubscriberMessage_InitMessage) GetTimestampNs() int64

func (*SubscriberMessage_InitMessage) GetTopic 

func (x *SubscriberMessage_InitMessage) GetTopic() string

func (*SubscriberMessage_InitMessage) ProtoMessage 

func (*SubscriberMessage_InitMessage) ProtoMessage()

func (*SubscriberMessage_InitMessage) ProtoReflect 

func (x *SubscriberMessage_InitMessage) ProtoReflect() protoreflect.Message

func (*SubscriberMessage_InitMessage) Reset 

func (x *SubscriberMessage_InitMessage) Reset()

func (*SubscriberMessage_InitMessage) String 

func (x *SubscriberMessage_InitMessage) String() string

type SubscriberMessage_InitMessage_StartPosition 

type SubscriberMessage_InitMessage_StartPosition int32
const (
	SubscriberMessage_InitMessage_LATEST    SubscriberMessage_InitMessage_StartPosition = 0 // Start at the newest message
	SubscriberMessage_InitMessage_EARLIEST  SubscriberMessage_InitMessage_StartPosition = 1 // Start at the oldest message
	SubscriberMessage_InitMessage_TIMESTAMP SubscriberMessage_InitMessage_StartPosition = 2 // Start after a specified timestamp, exclusive
)

func (SubscriberMessage_InitMessage_StartPosition) Descriptor 

func (SubscriberMessage_InitMessage_StartPosition) Descriptor() protoreflect.EnumDescriptor

func (SubscriberMessage_InitMessage_StartPosition) Enum 

func (x SubscriberMessage_InitMessage_StartPosition) Enum() *SubscriberMessage_InitMessage_StartPosition

func (SubscriberMessage_InitMessage_StartPosition) EnumDescriptor deprecated 

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

Deprecated: Use SubscriberMessage_InitMessage_StartPosition.Descriptor instead.

func (SubscriberMessage_InitMessage_StartPosition) Number 

func (x SubscriberMessage_InitMessage_StartPosition) Number() protoreflect.EnumNumber

func (SubscriberMessage_InitMessage_StartPosition) String 

func (x SubscriberMessage_InitMessage_StartPosition) String() string

func (SubscriberMessage_InitMessage_StartPosition) Type 

func (SubscriberMessage_InitMessage_StartPosition) Type() protoreflect.EnumType

type TopicConfiguration 

type TopicConfiguration struct {
	PartitionCount int32                           `protobuf:"varint,1,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
	Collection     string                          `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	Replication    string                          `protobuf:"bytes,3,opt,name=replication,proto3" json:"replication,omitempty"`
	IsTransient    bool                            `protobuf:"varint,4,opt,name=is_transient,json=isTransient,proto3" json:"is_transient,omitempty"`
	Partitoning    TopicConfiguration_Partitioning `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TopicConfiguration) Descriptor deprecated 

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

Deprecated: Use TopicConfiguration.ProtoReflect.Descriptor instead.

func (*TopicConfiguration) GetCollection 

func (x *TopicConfiguration) GetCollection() string

func (*TopicConfiguration) GetIsTransient 

func (x *TopicConfiguration) GetIsTransient() bool

func (*TopicConfiguration) GetPartitionCount 

func (x *TopicConfiguration) GetPartitionCount() int32

func (*TopicConfiguration) GetPartitoning 

func (x *TopicConfiguration) GetPartitoning() TopicConfiguration_Partitioning

func (*TopicConfiguration) GetReplication 

func (x *TopicConfiguration) GetReplication() string

func (*TopicConfiguration) ProtoMessage 

func (*TopicConfiguration) ProtoMessage()

func (*TopicConfiguration) ProtoReflect 

func (x *TopicConfiguration) ProtoReflect() protoreflect.Message

func (*TopicConfiguration) Reset 

func (x *TopicConfiguration) Reset()

func (*TopicConfiguration) String 

func (x *TopicConfiguration) String() string

type TopicConfiguration_Partitioning 

type TopicConfiguration_Partitioning int32
const (
	TopicConfiguration_NonNullKeyHash TopicConfiguration_Partitioning = 0 // If not null, hash by key value. If null, round robin
	TopicConfiguration_KeyHash        TopicConfiguration_Partitioning = 1 // hash by key value
	TopicConfiguration_RoundRobin     TopicConfiguration_Partitioning = 2 // round robin pick one partition
)

func (TopicConfiguration_Partitioning) Descriptor 

func (TopicConfiguration_Partitioning) Descriptor() protoreflect.EnumDescriptor

func (TopicConfiguration_Partitioning) Enum 

func (x TopicConfiguration_Partitioning) Enum() *TopicConfiguration_Partitioning

func (TopicConfiguration_Partitioning) EnumDescriptor deprecated 

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

Deprecated: Use TopicConfiguration_Partitioning.Descriptor instead.

func (TopicConfiguration_Partitioning) Number 

func (x TopicConfiguration_Partitioning) Number() protoreflect.EnumNumber

func (TopicConfiguration_Partitioning) String 

func (x TopicConfiguration_Partitioning) String() string

func (TopicConfiguration_Partitioning) Type 

func (TopicConfiguration_Partitioning) Type() protoreflect.EnumType

type UnimplementedSeaweedMessagingServer 

type UnimplementedSeaweedMessagingServer struct {
}

UnimplementedSeaweedMessagingServer can be embedded to have forward compatible implementations.

func (*UnimplementedSeaweedMessagingServer) ConfigureTopic 

func (*UnimplementedSeaweedMessagingServer) ConfigureTopic(context.Context, *ConfigureTopicRequest) (*ConfigureTopicResponse, error)

func (*UnimplementedSeaweedMessagingServer) DeleteTopic 

func (*UnimplementedSeaweedMessagingServer) DeleteTopic(context.Context, *DeleteTopicRequest) (*DeleteTopicResponse, error)

func (*UnimplementedSeaweedMessagingServer) FindBroker 

func (*UnimplementedSeaweedMessagingServer) FindBroker(context.Context, *FindBrokerRequest) (*FindBrokerResponse, error)

func (*UnimplementedSeaweedMessagingServer) GetTopicConfiguration 

func (*UnimplementedSeaweedMessagingServer) GetTopicConfiguration(context.Context, *GetTopicConfigurationRequest) (*GetTopicConfigurationResponse, error)

func (*UnimplementedSeaweedMessagingServer) Publish 

func (*UnimplementedSeaweedMessagingServer) Publish(SeaweedMessaging_PublishServer) error

func (*UnimplementedSeaweedMessagingServer) Subscribe 

func (*UnimplementedSeaweedMessagingServer) Subscribe(SeaweedMessaging_SubscribeServer) 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.