Versions in this module Expand all Collapse all v1 v1.4.4 Mar 5, 2021 Changes in this version + var ErrIntOverflowEvents = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthEvents = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group") + func RegisterEventsServer(s *grpc.Server, srv EventsServer) + type Envelope struct + Event *types.Any + Namespace string + Timestamp time.Time + Topic string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Envelope) Descriptor() ([]byte, []int) + func (*Envelope) ProtoMessage() + func (m *Envelope) Field(fieldpath []string) (string, bool) + func (m *Envelope) Marshal() (dAtA []byte, err error) + func (m *Envelope) MarshalTo(dAtA []byte) (int, error) + func (m *Envelope) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Envelope) Reset() + func (m *Envelope) Size() (n int) + func (m *Envelope) Unmarshal(dAtA []byte) error + func (m *Envelope) XXX_DiscardUnknown() + func (m *Envelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Envelope) XXX_Merge(src proto.Message) + func (m *Envelope) XXX_Size() int + func (m *Envelope) XXX_Unmarshal(b []byte) error + func (this *Envelope) String() string + type EventsClient interface + Forward func(ctx context.Context, in *ForwardRequest, opts ...grpc.CallOption) (*types.Empty, error) + Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*types.Empty, error) + Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Events_SubscribeClient, error) + func NewEventsClient(cc *grpc.ClientConn) EventsClient + type EventsServer interface + Forward func(context.Context, *ForwardRequest) (*types.Empty, error) + Publish func(context.Context, *PublishRequest) (*types.Empty, error) + Subscribe func(*SubscribeRequest, Events_SubscribeServer) error + type Events_SubscribeClient interface + Recv func() (*Envelope, error) + type Events_SubscribeServer interface + Send func(*Envelope) error + type ForwardRequest struct + Envelope *Envelope + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ForwardRequest) Descriptor() ([]byte, []int) + func (*ForwardRequest) ProtoMessage() + func (m *ForwardRequest) Marshal() (dAtA []byte, err error) + func (m *ForwardRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ForwardRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ForwardRequest) Reset() + func (m *ForwardRequest) Size() (n int) + func (m *ForwardRequest) Unmarshal(dAtA []byte) error + func (m *ForwardRequest) XXX_DiscardUnknown() + func (m *ForwardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ForwardRequest) XXX_Merge(src proto.Message) + func (m *ForwardRequest) XXX_Size() int + func (m *ForwardRequest) XXX_Unmarshal(b []byte) error + func (this *ForwardRequest) String() string + type PublishRequest struct + Event *types.Any + Topic string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PublishRequest) Descriptor() ([]byte, []int) + func (*PublishRequest) ProtoMessage() + func (m *PublishRequest) Marshal() (dAtA []byte, err error) + func (m *PublishRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PublishRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PublishRequest) Reset() + func (m *PublishRequest) Size() (n int) + func (m *PublishRequest) Unmarshal(dAtA []byte) error + func (m *PublishRequest) XXX_DiscardUnknown() + func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PublishRequest) XXX_Merge(src proto.Message) + func (m *PublishRequest) XXX_Size() int + func (m *PublishRequest) XXX_Unmarshal(b []byte) error + func (this *PublishRequest) String() string + type SubscribeRequest struct + Filters []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SubscribeRequest) Descriptor() ([]byte, []int) + func (*SubscribeRequest) ProtoMessage() + func (m *SubscribeRequest) Marshal() (dAtA []byte, err error) + func (m *SubscribeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SubscribeRequest) Reset() + func (m *SubscribeRequest) Size() (n int) + func (m *SubscribeRequest) Unmarshal(dAtA []byte) error + func (m *SubscribeRequest) XXX_DiscardUnknown() + func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SubscribeRequest) XXX_Merge(src proto.Message) + func (m *SubscribeRequest) XXX_Size() int + func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error + func (this *SubscribeRequest) String() string + type UnimplementedEventsServer struct + func (*UnimplementedEventsServer) Forward(ctx context.Context, req *ForwardRequest) (*types.Empty, error) + func (*UnimplementedEventsServer) Publish(ctx context.Context, req *PublishRequest) (*types.Empty, error) + func (*UnimplementedEventsServer) Subscribe(req *SubscribeRequest, srv Events_SubscribeServer) error