Versions in this module Expand all Collapse all v0 v0.0.4 Jul 9, 2022 Changes in this version + const OperationEventServiceEvent + var EventService_ServiceDesc = grpc.ServiceDesc + var File_event_api_v1_event_proto protoreflect.FileDescriptor + func RegisterEventServiceHTTPServer(s *http.Server, srv EventServiceHTTPServer) + func RegisterEventServiceServer(s grpc.ServiceRegistrar, srv EventServiceServer) + type EventRequest struct + Message *MessageProto + Service string + func (*EventRequest) Descriptor() ([]byte, []int) + func (*EventRequest) ProtoMessage() + func (m *EventRequest) Validate() error + func (m *EventRequest) ValidateAll() error + func (x *EventRequest) GetMessage() *MessageProto + func (x *EventRequest) GetService() string + func (x *EventRequest) ProtoReflect() protoreflect.Message + func (x *EventRequest) Reset() + func (x *EventRequest) String() string + type EventRequestMultiError []error + func (m EventRequestMultiError) AllErrors() []error + func (m EventRequestMultiError) Error() string + type EventRequestValidationError struct + func (e EventRequestValidationError) Cause() error + func (e EventRequestValidationError) Error() string + func (e EventRequestValidationError) ErrorName() string + func (e EventRequestValidationError) Field() string + func (e EventRequestValidationError) Key() bool + func (e EventRequestValidationError) Reason() string + type EventServiceClient interface + Event func(ctx context.Context, in *EventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + func NewEventServiceClient(cc grpc.ClientConnInterface) EventServiceClient + type EventServiceHTTPClient interface + Event func(ctx context.Context, req *EventRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error) + func NewEventServiceHTTPClient(client *http.Client) EventServiceHTTPClient + type EventServiceHTTPClientImpl struct + func (c *EventServiceHTTPClientImpl) Event(ctx context.Context, in *EventRequest, opts ...http.CallOption) (*emptypb.Empty, error) + type EventServiceHTTPServer interface + Event func(context.Context, *EventRequest) (*emptypb.Empty, error) + type EventServiceServer interface + Event func(context.Context, *EventRequest) (*emptypb.Empty, error) + func NewEventServiceClientProxy(cc EventServiceClient) EventServiceServer + type MessageProto struct + Header map[string]string + Key string + Value []byte + func FromEvent(e event.Event) *MessageProto + func (*MessageProto) Descriptor() ([]byte, []int) + func (*MessageProto) ProtoMessage() + func (m *MessageProto) Validate() error + func (m *MessageProto) ValidateAll() error + func (x *MessageProto) GetHeader() map[string]string + func (x *MessageProto) GetKey() string + func (x *MessageProto) GetValue() []byte + func (x *MessageProto) ProtoReflect() protoreflect.Message + func (x *MessageProto) Reset() + func (x *MessageProto) String() string + func (x *MessageProto) ToEvent() event.Event + type MessageProtoMultiError []error + func (m MessageProtoMultiError) AllErrors() []error + func (m MessageProtoMultiError) Error() string + type MessageProtoValidationError struct + func (e MessageProtoValidationError) Cause() error + func (e MessageProtoValidationError) Error() string + func (e MessageProtoValidationError) ErrorName() string + func (e MessageProtoValidationError) Field() string + func (e MessageProtoValidationError) Key() bool + func (e MessageProtoValidationError) Reason() string + type UnimplementedEventServiceServer struct + func (UnimplementedEventServiceServer) Event(context.Context, *EventRequest) (*emptypb.Empty, error) + type UnsafeEventServiceServer interface