eventstreamapi

Documentation

Index

• Variables
• func RegisterEventStreamServer(s grpc.ServiceRegistrar, srv EventStreamServer)
• type Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (x *Event) GetEvent() *pb.CloudEvent
  • func (*Event) ProtoMessage()
  • func (x *Event) ProtoReflect() protoreflect.Message
  • func (x *Event) Reset()
  • func (x *Event) String() string
• type EventStreamClient
  • func NewEventStreamClient(cc grpc.ClientConnInterface) EventStreamClient
• type EventStreamServer
• type EventStream_PushClient
• type EventStream_PushServer
• type EventStream_SubscribeClient
• type EventStream_SubscribeServer
• type PingRequest
  • func (*PingRequest) Descriptor() ([]byte, []int)
  • func (*PingRequest) ProtoMessage()
  • func (x *PingRequest) ProtoReflect() protoreflect.Message
  • func (x *PingRequest) Reset()
  • func (x *PingRequest) String() string
• type PongReply
  • func (*PongReply) Descriptor() ([]byte, []int)
  • func (*PongReply) ProtoMessage()
  • func (x *PongReply) ProtoReflect() protoreflect.Message
  • func (x *PongReply) Reset()
  • func (x *PongReply) String() string
• type PushSummary
  • func (*PushSummary) Descriptor() ([]byte, []int)
  • func (x *PushSummary) GetProcessed() int32
  • func (x *PushSummary) GetReceived() int32
  • func (x *PushSummary) GetResult() string
  • func (*PushSummary) ProtoMessage()
  • func (x *PushSummary) ProtoReflect() protoreflect.Message
  • func (x *PushSummary) Reset()
  • func (x *PushSummary) String() string
• type UnimplementedEventStreamServer
  • func (UnimplementedEventStreamServer) Ping(context.Context, *PingRequest) (*PongReply, error)
  • func (UnimplementedEventStreamServer) Push(EventStream_PushServer) error
  • func (UnimplementedEventStreamServer) Subscribe(EventStream_SubscribeServer) error
• type UnsafeEventStreamServer

Variables

var EventStream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "eventstreamapi.EventStream",
	HandlerType: (*EventStreamServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _EventStream_Ping_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _EventStream_Subscribe_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "Push",
			Handler:       _EventStream_Push_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "eventstream.proto",
}

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

var File_eventstream_proto protoreflect.FileDescriptor

Functions

func RegisterEventStreamServer

func RegisterEventStreamServer(s grpc.ServiceRegistrar, srv EventStreamServer)

Types

type Event

type Event struct {
	Event *pb.CloudEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

Event describes an event

func (*Event) Descriptor

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetEvent

func (x *Event) GetEvent() *pb.CloudEvent

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

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

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

type EventStreamClient

type EventStreamClient interface {
	Subscribe(ctx context.Context, opts ...grpc.CallOption) (EventStream_SubscribeClient, error)
	Push(ctx context.Context, opts ...grpc.CallOption) (EventStream_PushClient, error)
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PongReply, error)
}

EventStreamClient is the client API for EventStream 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 NewEventStreamClient

func NewEventStreamClient(cc grpc.ClientConnInterface) EventStreamClient

type EventStreamServer

type EventStreamServer interface {
	Subscribe(EventStream_SubscribeServer) error
	Push(EventStream_PushServer) error
	Ping(context.Context, *PingRequest) (*PongReply, error)
	// contains filtered or unexported methods
}

EventStreamServer is the server API for EventStream service. All implementations must embed UnimplementedEventStreamServer for forward compatibility

type EventStream_PushClient

type EventStream_PushClient interface {
	Send(*Event) error
	CloseAndRecv() (*PushSummary, error)
	grpc.ClientStream
}

type EventStream_PushServer

type EventStream_PushServer interface {
	SendAndClose(*PushSummary) error
	Recv() (*Event, error)
	grpc.ServerStream
}

type EventStream_SubscribeClient

type EventStream_SubscribeClient interface {
	Send(*Event) error
	Recv() (*Event, error)
	grpc.ClientStream
}

type EventStream_SubscribeServer

type EventStream_SubscribeServer interface {
	Send(*Event) error
	Recv() (*Event, error)
	grpc.ServerStream
}

type PingRequest

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

func (*PingRequest) Descriptor

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect

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

func (*PingRequest) Reset

func (x *PingRequest) Reset()

func (*PingRequest) String

func (x *PingRequest) String() string

type PongReply

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

func (*PongReply) Descriptor

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

Deprecated: Use PongReply.ProtoReflect.Descriptor instead.

func (*PongReply) ProtoMessage

func (*PongReply) ProtoMessage()

func (*PongReply) ProtoReflect

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

func (*PongReply) Reset

func (x *PongReply) Reset()

func (*PongReply) String

func (x *PongReply) String() string

type PushSummary

type PushSummary struct {
	Result    string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Received  int32  `protobuf:"varint,2,opt,name=received,proto3" json:"received,omitempty"`
	Processed int32  `protobuf:"varint,3,opt,name=processed,proto3" json:"processed,omitempty"`
	// contains filtered or unexported fields
}

func (*PushSummary) Descriptor

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

Deprecated: Use PushSummary.ProtoReflect.Descriptor instead.

func (*PushSummary) GetProcessed

func (x *PushSummary) GetProcessed() int32

func (*PushSummary) GetReceived

func (x *PushSummary) GetReceived() int32

func (*PushSummary) GetResult

func (x *PushSummary) GetResult() string

func (*PushSummary) ProtoMessage

func (*PushSummary) ProtoMessage()

func (*PushSummary) ProtoReflect

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

func (*PushSummary) Reset

func (x *PushSummary) Reset()

func (*PushSummary) String

func (x *PushSummary) String() string

type UnimplementedEventStreamServer

type UnimplementedEventStreamServer struct {
}

UnimplementedEventStreamServer must be embedded to have forward compatible implementations.

func (UnimplementedEventStreamServer) Ping

func (UnimplementedEventStreamServer) Ping(context.Context, *PingRequest) (*PongReply, error)

func (UnimplementedEventStreamServer) Push

func (UnimplementedEventStreamServer) Push(EventStream_PushServer) error

func (UnimplementedEventStreamServer) Subscribe

func (UnimplementedEventStreamServer) Subscribe(EventStream_SubscribeServer) error

type UnsafeEventStreamServer

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

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