Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

proto

package

Go to main page

Versions in this module

v1

v1.0.4

Sep 5, 2023

v1.0.3

Jul 3, 2023

v1.0.2

May 16, 2023

v1.0.1

Apr 19, 2023

v0

v0.99.4

Dec 1, 2022

v0.99.3

Nov 16, 2022

Changes in this version

+ var ErrorCode_name = map[int32]string

+ var ErrorCode_value = map[string]int32

+ var File_pubsub_api_proto protoreflect.FileDescriptor

+ var PubSub_ServiceDesc = grpc.ServiceDesc

+ var ReplayPreset_name = map[int32]string

+ var ReplayPreset_value = map[string]int32

+ func RegisterPubSubServer(s grpc.ServiceRegistrar, srv PubSubServer)

+ type ConsumerEvent struct

+ Event *ProducerEvent

+ ReplayId []byte

+ func (*ConsumerEvent) Descriptor() ([]byte, []int)

+ func (*ConsumerEvent) ProtoMessage()

+ func (x *ConsumerEvent) GetEvent() *ProducerEvent

+ func (x *ConsumerEvent) GetReplayId() []byte

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

+ func (x *ConsumerEvent) Reset()

+ func (x *ConsumerEvent) String() string

+ type Error struct

+ Code ErrorCode

+ Msg string

+ func (*Error) Descriptor() ([]byte, []int)

+ func (*Error) ProtoMessage()

+ func (x *Error) GetCode() ErrorCode

+ func (x *Error) GetMsg() string

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

+ func (x *Error) Reset()

+ func (x *Error) String() string

+ type ErrorCode int32

+ const ErrorCode_PUBLISH

+ const ErrorCode_UNKNOWN

+ func (ErrorCode) Descriptor() protoreflect.EnumDescriptor

+ func (ErrorCode) EnumDescriptor() ([]byte, []int)

+ func (ErrorCode) Type() protoreflect.EnumType

+ func (x ErrorCode) Enum() *ErrorCode

+ func (x ErrorCode) Number() protoreflect.EnumNumber

+ func (x ErrorCode) String() string

+ type EventHeader struct

+ Key string

+ Value []byte

+ func (*EventHeader) Descriptor() ([]byte, []int)

+ func (*EventHeader) ProtoMessage()

+ func (x *EventHeader) GetKey() string

+ func (x *EventHeader) GetValue() []byte

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

+ func (x *EventHeader) Reset()

+ func (x *EventHeader) String() string

+ type FetchRequest struct

+ AuthRefresh string

+ NumRequested int32

+ ReplayId []byte

+ ReplayPreset ReplayPreset

+ TopicName string

+ func (*FetchRequest) Descriptor() ([]byte, []int)

+ func (*FetchRequest) ProtoMessage()

+ func (x *FetchRequest) GetAuthRefresh() string

+ func (x *FetchRequest) GetNumRequested() int32

+ func (x *FetchRequest) GetReplayId() []byte

+ func (x *FetchRequest) GetReplayPreset() ReplayPreset

+ func (x *FetchRequest) GetTopicName() string

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

+ func (x *FetchRequest) Reset()

+ func (x *FetchRequest) String() string

+ type FetchResponse struct

+ Events []*ConsumerEvent

+ LatestReplayId []byte

+ PendingNumRequested int32

+ RpcId string

+ func (*FetchResponse) Descriptor() ([]byte, []int)

+ func (*FetchResponse) ProtoMessage()

+ func (x *FetchResponse) GetEvents() []*ConsumerEvent

+ func (x *FetchResponse) GetLatestReplayId() []byte

+ func (x *FetchResponse) GetPendingNumRequested() int32

+ func (x *FetchResponse) GetRpcId() string

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

+ func (x *FetchResponse) Reset()

+ func (x *FetchResponse) String() string

+ type ProducerEvent struct

+ Headers []*EventHeader

+ Id string

+ Payload []byte

+ SchemaId string

+ func (*ProducerEvent) Descriptor() ([]byte, []int)

+ func (*ProducerEvent) ProtoMessage()

+ func (x *ProducerEvent) GetHeaders() []*EventHeader

+ func (x *ProducerEvent) GetId() string

+ func (x *ProducerEvent) GetPayload() []byte

+ func (x *ProducerEvent) GetSchemaId() string

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

+ func (x *ProducerEvent) Reset()

+ func (x *ProducerEvent) String() string

+ type PubSubClient interface

+ GetSchema func(ctx context.Context, in *SchemaRequest, opts ...grpc.CallOption) (*SchemaInfo, error)

+ GetTopic func(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*TopicInfo, error)

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)

+ PublishStream func(ctx context.Context, opts ...grpc.CallOption) (PubSub_PublishStreamClient, error)

+ Subscribe func(ctx context.Context, opts ...grpc.CallOption) (PubSub_SubscribeClient, error)

+ func NewPubSubClient(cc grpc.ClientConnInterface) PubSubClient

+ type PubSubServer interface

+ GetSchema func(context.Context, *SchemaRequest) (*SchemaInfo, error)

+ GetTopic func(context.Context, *TopicRequest) (*TopicInfo, error)

+ Publish func(context.Context, *PublishRequest) (*PublishResponse, error)

+ PublishStream func(PubSub_PublishStreamServer) error

+ Subscribe func(PubSub_SubscribeServer) error

+ type PubSub_PublishStreamClient interface

+ Recv func() (*PublishResponse, error)

+ Send func(*PublishRequest) error

+ type PubSub_PublishStreamServer interface

+ Recv func() (*PublishRequest, error)

+ Send func(*PublishResponse) error

+ type PubSub_SubscribeClient interface

+ Recv func() (*FetchResponse, error)

+ Send func(*FetchRequest) error

+ type PubSub_SubscribeServer interface

+ Recv func() (*FetchRequest, error)

+ Send func(*FetchResponse) error

+ type PublishRequest struct

+ AuthRefresh string

+ Events []*ProducerEvent

+ TopicName string

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

+ func (*PublishRequest) ProtoMessage()

+ func (x *PublishRequest) GetAuthRefresh() string

+ func (x *PublishRequest) GetEvents() []*ProducerEvent

+ func (x *PublishRequest) GetTopicName() string

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

+ func (x *PublishRequest) Reset()

+ func (x *PublishRequest) String() string

+ type PublishResponse struct

+ Results []*PublishResult

+ RpcId string

+ SchemaId string

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

+ func (*PublishResponse) ProtoMessage()

+ func (x *PublishResponse) GetResults() []*PublishResult

+ func (x *PublishResponse) GetRpcId() string

+ func (x *PublishResponse) GetSchemaId() string

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

+ func (x *PublishResponse) Reset()

+ func (x *PublishResponse) String() string

+ type PublishResult struct

+ CorrelationKey string

+ Error *Error

+ ReplayId []byte

+ func (*PublishResult) Descriptor() ([]byte, []int)

+ func (*PublishResult) ProtoMessage()

+ func (x *PublishResult) GetCorrelationKey() string

+ func (x *PublishResult) GetError() *Error

+ func (x *PublishResult) GetReplayId() []byte

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

+ func (x *PublishResult) Reset()

+ func (x *PublishResult) String() string

+ type ReplayPreset int32

+ const ReplayPreset_CUSTOM

+ const ReplayPreset_EARLIEST

+ const ReplayPreset_LATEST

+ func (ReplayPreset) Descriptor() protoreflect.EnumDescriptor

+ func (ReplayPreset) EnumDescriptor() ([]byte, []int)

+ func (ReplayPreset) Type() protoreflect.EnumType

+ func (x ReplayPreset) Enum() *ReplayPreset

+ func (x ReplayPreset) Number() protoreflect.EnumNumber

+ func (x ReplayPreset) String() string

+ type SchemaInfo struct

+ RpcId string

+ SchemaId string

+ SchemaJson string

+ func (*SchemaInfo) Descriptor() ([]byte, []int)

+ func (*SchemaInfo) ProtoMessage()

+ func (x *SchemaInfo) GetRpcId() string

+ func (x *SchemaInfo) GetSchemaId() string

+ func (x *SchemaInfo) GetSchemaJson() string

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

+ func (x *SchemaInfo) Reset()

+ func (x *SchemaInfo) String() string

+ type SchemaRequest struct

+ SchemaId string

+ func (*SchemaRequest) Descriptor() ([]byte, []int)

+ func (*SchemaRequest) ProtoMessage()

+ func (x *SchemaRequest) GetSchemaId() string

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

+ func (x *SchemaRequest) Reset()

+ func (x *SchemaRequest) String() string

+ type TopicInfo struct

+ CanPublish bool

+ CanSubscribe bool

+ RpcId string

+ SchemaId string

+ TenantGuid string

+ TopicName string

+ func (*TopicInfo) Descriptor() ([]byte, []int)

+ func (*TopicInfo) ProtoMessage()

+ func (x *TopicInfo) GetCanPublish() bool

+ func (x *TopicInfo) GetCanSubscribe() bool

+ func (x *TopicInfo) GetRpcId() string

+ func (x *TopicInfo) GetSchemaId() string

+ func (x *TopicInfo) GetTenantGuid() string

+ func (x *TopicInfo) GetTopicName() string

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

+ func (x *TopicInfo) Reset()

+ func (x *TopicInfo) String() string

+ type TopicRequest struct

+ TopicName string

+ func (*TopicRequest) Descriptor() ([]byte, []int)

+ func (*TopicRequest) ProtoMessage()

+ func (x *TopicRequest) GetTopicName() string

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

+ func (x *TopicRequest) Reset()

+ func (x *TopicRequest) String() string

+ type UnimplementedPubSubServer struct

+ func (UnimplementedPubSubServer) GetSchema(context.Context, *SchemaRequest) (*SchemaInfo, error)

+ func (UnimplementedPubSubServer) GetTopic(context.Context, *TopicRequest) (*TopicInfo, error)

+ func (UnimplementedPubSubServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

+ func (UnimplementedPubSubServer) PublishStream(PubSub_PublishStreamServer) error

+ func (UnimplementedPubSubServer) Subscribe(PubSub_SubscribeServer) error

+ type UnsafePubSubServer interface