Versions in this module Expand all Collapse all v0 v0.2.0 Dec 23, 2018 Changes in this version + func RegisterEventsServer(s *grpc.Server, srv EventsServer) + type Endpoint struct + Address string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Endpoint) Descriptor() ([]byte, []int) + func (*Endpoint) ProtoMessage() + func (dst *Endpoint) XXX_Merge(src proto.Message) + func (m *Endpoint) GetAddress() string + func (m *Endpoint) Reset() + func (m *Endpoint) String() string + func (m *Endpoint) XXX_DiscardUnknown() + func (m *Endpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Endpoint) XXX_Size() int + func (m *Endpoint) XXX_Unmarshal(b []byte) error + type EndpointRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EndpointRequest) Descriptor() ([]byte, []int) + func (*EndpointRequest) ProtoMessage() + func (dst *EndpointRequest) XXX_Merge(src proto.Message) + func (m *EndpointRequest) Reset() + func (m *EndpointRequest) String() string + func (m *EndpointRequest) XXX_DiscardUnknown() + func (m *EndpointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EndpointRequest) XXX_Size() int + func (m *EndpointRequest) XXX_Unmarshal(b []byte) error + type EndpointResponse struct + Endpoint *Endpoint + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EndpointResponse) Descriptor() ([]byte, []int) + func (*EndpointResponse) ProtoMessage() + func (dst *EndpointResponse) XXX_Merge(src proto.Message) + func (m *EndpointResponse) GetEndpoint() *Endpoint + func (m *EndpointResponse) Reset() + func (m *EndpointResponse) String() string + func (m *EndpointResponse) XXX_DiscardUnknown() + func (m *EndpointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EndpointResponse) XXX_Size() int + func (m *EndpointResponse) XXX_Unmarshal(b []byte) error + type EventsClient interface + Endpoint func(ctx context.Context, in *EndpointRequest, opts ...grpc.CallOption) (*EndpointResponse, error) + Info func(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error) + Publish func(ctx context.Context, in *Message, 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 + Endpoint func(context.Context, *EndpointRequest) (*EndpointResponse, error) + Info func(context.Context, *InfoRequest) (*InfoResponse, error) + Publish func(context.Context, *Message) (*types.Empty, error) + Subscribe func(*SubscribeRequest, Events_SubscribeServer) error + type Events_SubscribeClient interface + Recv func() (*Message, error) + type Events_SubscribeServer interface + Send func(*Message) error + type InfoRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*InfoRequest) Descriptor() ([]byte, []int) + func (*InfoRequest) ProtoMessage() + func (dst *InfoRequest) XXX_Merge(src proto.Message) + func (m *InfoRequest) Reset() + func (m *InfoRequest) String() string + func (m *InfoRequest) XXX_DiscardUnknown() + func (m *InfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *InfoRequest) XXX_Size() int + func (m *InfoRequest) XXX_Unmarshal(b []byte) error + type InfoResponse struct + ID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*InfoResponse) Descriptor() ([]byte, []int) + func (*InfoResponse) ProtoMessage() + func (dst *InfoResponse) XXX_Merge(src proto.Message) + func (m *InfoResponse) GetID() string + func (m *InfoResponse) Reset() + func (m *InfoResponse) String() string + func (m *InfoResponse) XXX_DiscardUnknown() + func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *InfoResponse) XXX_Size() int + func (m *InfoResponse) XXX_Unmarshal(b []byte) error + type Message struct + Data *types.Any + Subject string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (dst *Message) XXX_Merge(src proto.Message) + func (m *Message) GetData() *types.Any + func (m *Message) GetSubject() string + func (m *Message) Reset() + func (m *Message) String() string + func (m *Message) XXX_DiscardUnknown() + func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Message) XXX_Size() int + func (m *Message) XXX_Unmarshal(b []byte) error + type SubscribeRequest struct + Subject string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SubscribeRequest) Descriptor() ([]byte, []int) + func (*SubscribeRequest) ProtoMessage() + func (dst *SubscribeRequest) XXX_Merge(src proto.Message) + func (m *SubscribeRequest) GetSubject() string + func (m *SubscribeRequest) Reset() + func (m *SubscribeRequest) String() string + func (m *SubscribeRequest) XXX_DiscardUnknown() + func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SubscribeRequest) XXX_Size() int + func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error