Versions in this module Expand all Collapse all v1 v1.2.4 Feb 13, 2019 Changes in this version + var ErrIntOverflowEvents = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthEvents = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterEventsServer(s *grpc.Server, srv EventsServer) + type Envelope struct + Event *google_protobuf1.Any + Namespace string + Timestamp time.Time + Topic string + 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) Reset() + func (m *Envelope) Size() (n int) + func (m *Envelope) Unmarshal(dAtA []byte) error + func (this *Envelope) String() string + type EventsClient interface + Forward func(ctx context.Context, in *ForwardRequest, opts ...grpc.CallOption) (*google_protobuf2.Empty, error) + Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*google_protobuf2.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) (*google_protobuf2.Empty, error) + Publish func(context.Context, *PublishRequest) (*google_protobuf2.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 + 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) Reset() + func (m *ForwardRequest) Size() (n int) + func (m *ForwardRequest) Unmarshal(dAtA []byte) error + func (this *ForwardRequest) String() string + type PublishRequest struct + Event *google_protobuf1.Any + Topic string + 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) Reset() + func (m *PublishRequest) Size() (n int) + func (m *PublishRequest) Unmarshal(dAtA []byte) error + func (this *PublishRequest) String() string + type SubscribeRequest struct + Filters []string + 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) Reset() + func (m *SubscribeRequest) Size() (n int) + func (m *SubscribeRequest) Unmarshal(dAtA []byte) error + func (this *SubscribeRequest) String() string