proto

Documentation

Index

• Constants
• Variables
• func RegisterEventMultiServiceServer(s grpc.ServiceRegistrar, srv EventMultiServiceServer)
• type Action
  • func (Action) Descriptor() protoreflect.EnumDescriptor
  • func (x Action) Enum() *Action
  • func (Action) EnumDescriptor() ([]byte, []int)
  • func (x Action) Number() protoreflect.EnumNumber
  • func (x Action) String() string
  • func (Action) Type() protoreflect.EnumType
• type Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (x *Event) GetAction() Action
  • func (x *Event) GetId() string
  • func (x *Event) GetPayload() []byte
  • func (*Event) ProtoMessage()
  • func (x *Event) ProtoReflect() protoreflect.Message
  • func (x *Event) Reset()
  • func (x *Event) String() string
• type EventMultiServiceClient
  • func NewEventMultiServiceClient(cc grpc.ClientConnInterface) EventMultiServiceClient
• type EventMultiServiceServer
• type EventMultiService_EventStreamingClient
• type EventMultiService_EventStreamingServer
• type UnimplementedEventMultiServiceServer
  • func (UnimplementedEventMultiServiceServer) EventStreaming(EventMultiService_EventStreamingServer) error
• type UnsafeEventMultiServiceServer

Constants

const (
	EventMultiService_EventStreaming_FullMethodName = "/proto.EventMultiService/EventStreaming"
)

Variables

var (
	Action_name = map[int32]string{
		0: "EMPTY",
		1: "NOTIFICATION",
		2: "SWITCH",
	}
	Action_value = map[string]int32{
		"EMPTY":        0,
		"NOTIFICATION": 1,
		"SWITCH":       2,
	}
)

Enum value maps for Action.

var EventMultiService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.EventMultiService",
	HandlerType: (*EventMultiServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "EventStreaming",
			Handler:       _EventMultiService_EventStreaming_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "event.proto",
}

EventMultiService_ServiceDesc is the grpc.ServiceDesc for EventMultiService 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_proto protoreflect.FileDescriptor

Functions

func RegisterEventMultiServiceServer

func RegisterEventMultiServiceServer(s grpc.ServiceRegistrar, srv EventMultiServiceServer)

Types

type Action

type Action int32

const (
	Action_EMPTY        Action = 0
	Action_NOTIFICATION Action = 1
	Action_SWITCH       Action = 2
)

func (Action) Descriptor

func (Action) Descriptor() protoreflect.EnumDescriptor

func (Action) Enum

func (x Action) Enum() *Action

func (Action) EnumDescriptor

func (Action) EnumDescriptor() ([]byte, []int)

Deprecated: Use Action.Descriptor instead.

func (Action) Number

func (x Action) Number() protoreflect.EnumNumber

func (Action) String

func (x Action) String() string

func (Action) Type

func (Action) Type() protoreflect.EnumType

type Event

type Event struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Action  Action `protobuf:"varint,2,opt,name=action,proto3,enum=proto.Action" json:"action,omitempty"`
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAction

func (x *Event) GetAction() Action

func (*Event) GetId

func (x *Event) GetId() string

func (*Event) GetPayload

func (x *Event) GetPayload() []byte

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 EventMultiServiceClient

type EventMultiServiceClient interface {
	EventStreaming(ctx context.Context, opts ...grpc.CallOption) (EventMultiService_EventStreamingClient, error)
}

EventMultiServiceClient is the client API for EventMultiService 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 NewEventMultiServiceClient

func NewEventMultiServiceClient(cc grpc.ClientConnInterface) EventMultiServiceClient

type EventMultiServiceServer

type EventMultiServiceServer interface {
	EventStreaming(EventMultiService_EventStreamingServer) error
	// contains filtered or unexported methods
}

EventMultiServiceServer is the server API for EventMultiService service. All implementations must embed UnimplementedEventMultiServiceServer for forward compatibility

type EventMultiService_EventStreamingClient

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

type EventMultiService_EventStreamingServer

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

type UnimplementedEventMultiServiceServer

type UnimplementedEventMultiServiceServer struct {
}

UnimplementedEventMultiServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEventMultiServiceServer) EventStreaming

func (UnimplementedEventMultiServiceServer) EventStreaming(EventMultiService_EventStreamingServer) error

type UnsafeEventMultiServiceServer

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

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