eventPb

Documentation

Index

• Variables
• func RegisterArchiveEventServiceServer(s grpc.ServiceRegistrar, srv ArchiveEventServiceServer)
• type ArchiveEvent
  • func (*ArchiveEvent) Descriptor() ([]byte, []int)
  • func (x *ArchiveEvent) GetArchiveEventId() string
  • func (*ArchiveEvent) ProtoMessage()
  • func (x *ArchiveEvent) ProtoReflect() protoreflect.Message
  • func (x *ArchiveEvent) Reset()
  • func (x *ArchiveEvent) String() string
• type ArchiveEventServiceClient
  • func NewArchiveEventServiceClient(cc grpc.ClientConnInterface) ArchiveEventServiceClient
• type ArchiveEventServiceServer
• type ArchiveEventService_ReceiveEventClient
• type ArchiveEventService_ReceiveEventServer
• type PublishEventResponse
  • func (*PublishEventResponse) Descriptor() ([]byte, []int)
  • func (x *PublishEventResponse) GetArchiveEventId() string
  • func (*PublishEventResponse) ProtoMessage()
  • func (x *PublishEventResponse) ProtoReflect() protoreflect.Message
  • func (x *PublishEventResponse) Reset()
  • func (x *PublishEventResponse) String() string
• type UnimplementedArchiveEventServiceServer
  • func (UnimplementedArchiveEventServiceServer) PublishEvent(context.Context, *emptypb.Empty) (*PublishEventResponse, error)
  • func (UnimplementedArchiveEventServiceServer) ReceiveEvent(*emptypb.Empty, ArchiveEventService_ReceiveEventServer) error
• type UnsafeArchiveEventServiceServer

Variables

var ArchiveEventService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "satellite.event.v1.ArchiveEventService",
	HandlerType: (*ArchiveEventServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PublishEvent",
			Handler:    _ArchiveEventService_PublishEvent_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReceiveEvent",
			Handler:       _ArchiveEventService_ReceiveEvent_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "event/v1/archive.proto",
}

ArchiveEventService_ServiceDesc is the grpc.ServiceDesc for ArchiveEventService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var File_event_v1_archive_proto protoreflect.FileDescriptor

Functions

func RegisterArchiveEventServiceServer

func RegisterArchiveEventServiceServer(s grpc.ServiceRegistrar, srv ArchiveEventServiceServer)

Types

type ArchiveEvent

type ArchiveEvent struct {
	ArchiveEventId string `protobuf:"bytes,1,opt,name=archive_event_id,json=archiveEventId,proto3" json:"archive_event_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ArchiveEvent) Descriptor

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

Deprecated: Use ArchiveEvent.ProtoReflect.Descriptor instead.

func (*ArchiveEvent) GetArchiveEventId

func (x *ArchiveEvent) GetArchiveEventId() string

func (*ArchiveEvent) ProtoMessage

func (*ArchiveEvent) ProtoMessage()

func (*ArchiveEvent) ProtoReflect

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

func (*ArchiveEvent) Reset

func (x *ArchiveEvent) Reset()

func (*ArchiveEvent) String

func (x *ArchiveEvent) String() string

type ArchiveEventServiceClient

type ArchiveEventServiceClient interface {
	PublishEvent(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PublishEventResponse, error)
	ReceiveEvent(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (ArchiveEventService_ReceiveEventClient, error)
}

ArchiveEventServiceClient is the client API for ArchiveEventService 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 NewArchiveEventServiceClient

func NewArchiveEventServiceClient(cc grpc.ClientConnInterface) ArchiveEventServiceClient

type ArchiveEventServiceServer

type ArchiveEventServiceServer interface {
	PublishEvent(context.Context, *emptypb.Empty) (*PublishEventResponse, error)
	ReceiveEvent(*emptypb.Empty, ArchiveEventService_ReceiveEventServer) error
	// contains filtered or unexported methods
}

ArchiveEventServiceServer is the server API for ArchiveEventService service. All implementations must embed UnimplementedArchiveEventServiceServer for forward compatibility

type ArchiveEventService_ReceiveEventClient

type ArchiveEventService_ReceiveEventClient interface {
	Recv() (*ArchiveEvent, error)
	grpc.ClientStream
}

type ArchiveEventService_ReceiveEventServer

type ArchiveEventService_ReceiveEventServer interface {
	Send(*ArchiveEvent) error
	grpc.ServerStream
}

type PublishEventResponse

type PublishEventResponse struct {
	ArchiveEventId string `protobuf:"bytes,1,opt,name=archive_event_id,json=archiveEventId,proto3" json:"archive_event_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishEventResponse) Descriptor

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

Deprecated: Use PublishEventResponse.ProtoReflect.Descriptor instead.

func (*PublishEventResponse) GetArchiveEventId

func (x *PublishEventResponse) GetArchiveEventId() string

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 UnimplementedArchiveEventServiceServer

type UnimplementedArchiveEventServiceServer struct {
}

UnimplementedArchiveEventServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedArchiveEventServiceServer) PublishEvent

func (UnimplementedArchiveEventServiceServer) PublishEvent(context.Context, *emptypb.Empty) (*PublishEventResponse, error)

func (UnimplementedArchiveEventServiceServer) ReceiveEvent

func (UnimplementedArchiveEventServiceServer) ReceiveEvent(*emptypb.Empty, ArchiveEventService_ReceiveEventServer) error

type UnsafeArchiveEventServiceServer

type UnsafeArchiveEventServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeArchiveEventServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ArchiveEventServiceServer will result in compilation errors.