eventspb

Documentation

Index

• Variables
• func RegisterEventsServiceServer(s *grpc.Server, srv EventsServiceServer)
• type EventsServiceClient
  • func NewEventsServiceClient(cc grpc.ClientConnInterface) EventsServiceClient
• type EventsServiceServer
• type EventsService_PublishEventClient
• type EventsService_PublishEventServer
• type Header
  • func (*Header) Descriptor() ([]byte, []int)
  • func (x *Header) GetField1() string
  • func (x *Header) GetField2() string
  • func (x *Header) GetField3() string
  • func (x *Header) GetField4() string
  • func (x *Header) GetField5() string
  • func (x *Header) GetField6() string
  • func (x *Header) GetField7() string
  • func (x *Header) GetField8() string
  • func (x *Header) GetField9() string
  • func (*Header) ProtoMessage()
  • func (x *Header) ProtoReflect() protoreflect.Message
  • func (x *Header) Reset()
  • func (x *Header) String() string
• type PublishEventRequest
  • func (*PublishEventRequest) Descriptor() ([]byte, []int)
  • func (x *PublishEventRequest) GetEvent() []byte
  • func (x *PublishEventRequest) GetHeader() *Header
  • func (*PublishEventRequest) ProtoMessage()
  • func (x *PublishEventRequest) ProtoReflect() protoreflect.Message
  • func (x *PublishEventRequest) Reset()
  • func (x *PublishEventRequest) String() string
• type PublishEventResponse
  • func (*PublishEventResponse) Descriptor() ([]byte, []int)
  • func (*PublishEventResponse) ProtoMessage()
  • func (x *PublishEventResponse) ProtoReflect() protoreflect.Message
  • func (x *PublishEventResponse) Reset()
  • func (x *PublishEventResponse) String() string
• type UnimplementedEventsServiceServer
  • func (*UnimplementedEventsServiceServer) PublishEvent(EventsService_PublishEventServer) error

Variables

var File_go_meet_bangalore_2022_protos_service_proto protoreflect.FileDescriptor

Functions

func RegisterEventsServiceServer

func RegisterEventsServiceServer(s *grpc.Server, srv EventsServiceServer)

Types

type EventsServiceClient

type EventsServiceClient interface {
	PublishEvent(ctx context.Context, opts ...grpc.CallOption) (EventsService_PublishEventClient, error)
}

EventsServiceClient is the client API for EventsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewEventsServiceClient

func NewEventsServiceClient(cc grpc.ClientConnInterface) EventsServiceClient

type EventsServiceServer

type EventsServiceServer interface {
	PublishEvent(EventsService_PublishEventServer) error
	// contains filtered or unexported methods
}

EventsServiceServer is the server API for EventsService service. All implementations must embed UnimplementedEventsServiceServer for forward compatibility

type EventsService_PublishEventClient

type EventsService_PublishEventClient interface {
	Send(*PublishEventRequest) error
	Recv() (*PublishEventResponse, error)
	grpc.ClientStream
}

type EventsService_PublishEventServer

type EventsService_PublishEventServer interface {
	Send(*PublishEventResponse) error
	Recv() (*PublishEventRequest, error)
	grpc.ServerStream
}

type Header

type Header struct {
	Field1 string `protobuf:"bytes,1,opt,name=field1,proto3" json:"field1,omitempty"`
	Field2 string `protobuf:"bytes,2,opt,name=field2,proto3" json:"field2,omitempty"`
	Field3 string `protobuf:"bytes,3,opt,name=field3,proto3" json:"field3,omitempty"`
	Field4 string `protobuf:"bytes,4,opt,name=field4,proto3" json:"field4,omitempty"`
	Field5 string `protobuf:"bytes,5,opt,name=field5,proto3" json:"field5,omitempty"`
	Field6 string `protobuf:"bytes,6,opt,name=field6,proto3" json:"field6,omitempty"`
	Field7 string `protobuf:"bytes,7,opt,name=field7,proto3" json:"field7,omitempty"`
	Field8 string `protobuf:"bytes,8,opt,name=field8,proto3" json:"field8,omitempty"`
	Field9 string `protobuf:"bytes,9,opt,name=field9,proto3" json:"field9,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetField1

func (x *Header) GetField1() string

func (*Header) GetField2

func (x *Header) GetField2() string

func (*Header) GetField3

func (x *Header) GetField3() string

func (*Header) GetField4

func (x *Header) GetField4() string

func (*Header) GetField5

func (x *Header) GetField5() string

func (*Header) GetField6

func (x *Header) GetField6() string

func (*Header) GetField7

func (x *Header) GetField7() string

func (*Header) GetField8

func (x *Header) GetField8() string

func (*Header) GetField9

func (x *Header) GetField9() string

func (*Header) ProtoMessage

func (*Header) ProtoMessage()

func (*Header) ProtoReflect

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

func (*Header) Reset

func (x *Header) Reset()

func (*Header) String

func (x *Header) String() string

type PublishEventRequest

type PublishEventRequest struct {
	Header *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Event  []byte  `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishEventRequest) Descriptor

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

Deprecated: Use PublishEventRequest.ProtoReflect.Descriptor instead.

func (*PublishEventRequest) GetEvent

func (x *PublishEventRequest) GetEvent() []byte

func (*PublishEventRequest) GetHeader

func (x *PublishEventRequest) GetHeader() *Header

func (*PublishEventRequest) ProtoMessage

func (*PublishEventRequest) ProtoMessage()

func (*PublishEventRequest) ProtoReflect

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

func (*PublishEventRequest) Reset

func (x *PublishEventRequest) Reset()

func (*PublishEventRequest) String

func (x *PublishEventRequest) String() string

type PublishEventResponse

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

func (*PublishEventResponse) Descriptor

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

Deprecated: Use PublishEventResponse.ProtoReflect.Descriptor instead.

func (*PublishEventResponse) ProtoMessage

func (*PublishEventResponse) ProtoMessage()

func (*PublishEventResponse) ProtoReflect

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

func (*PublishEventResponse) Reset

func (x *PublishEventResponse) Reset()

func (*PublishEventResponse) String

func (x *PublishEventResponse) String() string

type UnimplementedEventsServiceServer

type UnimplementedEventsServiceServer struct {
}

UnimplementedEventsServiceServer must be embedded to have forward compatible implementations.

func (*UnimplementedEventsServiceServer) PublishEvent

func (*UnimplementedEventsServiceServer) PublishEvent(EventsService_PublishEventServer) error