pb

Documentation

Overview

Package pb is a generated protocol buffer package.

It is generated from these files:

eventbus.proto

It has these top-level messages:

PublishRequest
SubscribeRequest
SubscribeResponse

Index

• func RegisterEventBusServer(s *grpc.Server, srv EventBusServer)
• type EventBusClient
  • func NewEventBusClient(cc *grpc.ClientConn) EventBusClient
• type EventBusServer
• type EventBus_SubscribeClient
• type EventBus_SubscribeServer
• type PublishRequest
  • func (*PublishRequest) Descriptor() ([]byte, []int)
  • func (m *PublishRequest) GetEvent() *google_protobuf.Any
  • func (*PublishRequest) ProtoMessage()
  • func (m *PublishRequest) Reset()
  • func (m *PublishRequest) String() string
• type SubscribeRequest
  • func (*SubscribeRequest) Descriptor() ([]byte, []int)
  • func (m *SubscribeRequest) GetOffset() string
  • func (*SubscribeRequest) ProtoMessage()
  • func (m *SubscribeRequest) Reset()
  • func (m *SubscribeRequest) String() string
• type SubscribeResponse
  • func (*SubscribeResponse) Descriptor() ([]byte, []int)
  • func (m *SubscribeResponse) GetEvent() *google_protobuf.Any
  • func (m *SubscribeResponse) GetOffset() string
  • func (*SubscribeResponse) ProtoMessage()
  • func (m *SubscribeResponse) Reset()
  • func (m *SubscribeResponse) String() string

Functions

func RegisterEventBusServer

func RegisterEventBusServer(s *grpc.Server, srv EventBusServer)

Types

type EventBusClient

type EventBusClient interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (EventBus_SubscribeClient, error)
}

func NewEventBusClient

func NewEventBusClient(cc *grpc.ClientConn) EventBusClient

type EventBusServer

type EventBusServer interface {
	Publish(context.Context, *PublishRequest) (*google_protobuf1.Empty, error)
	Subscribe(*SubscribeRequest, EventBus_SubscribeServer) error
}

type EventBus_SubscribeClient

type EventBus_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type EventBus_SubscribeServer

type EventBus_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type PublishRequest

type PublishRequest struct {
	Event *google_protobuf.Any `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
}

func (*PublishRequest) Descriptor

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

func (*PublishRequest) GetEvent

func (m *PublishRequest) GetEvent() *google_protobuf.Any

func (*PublishRequest) ProtoMessage

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset

func (m *PublishRequest) Reset()

func (*PublishRequest) String

func (m *PublishRequest) String() string

type SubscribeRequest

type SubscribeRequest struct {
	Offset string `protobuf:"bytes,1,opt,name=offset" json:"offset,omitempty"`
}

func (*SubscribeRequest) Descriptor

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

func (*SubscribeRequest) GetOffset

func (m *SubscribeRequest) GetOffset() string

func (*SubscribeRequest) ProtoMessage

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String

func (m *SubscribeRequest) String() string

type SubscribeResponse

type SubscribeResponse struct {
	Offset string               `protobuf:"bytes,1,opt,name=offset" json:"offset,omitempty"`
	Event  *google_protobuf.Any `protobuf:"bytes,2,opt,name=event" json:"event,omitempty"`
}

func (*SubscribeResponse) Descriptor

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

func (*SubscribeResponse) GetEvent

func (m *SubscribeResponse) GetEvent() *google_protobuf.Any

func (*SubscribeResponse) GetOffset

func (m *SubscribeResponse) GetOffset() string

func (*SubscribeResponse) ProtoMessage

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) Reset

func (m *SubscribeResponse) Reset()

func (*SubscribeResponse) String

func (m *SubscribeResponse) String() string