Documentation ¶
Index ¶
- func RegisterPublisherServer(s *grpc.Server, srv PublisherServer)
- type CloseAllPeerConnectionsReply
- func (*CloseAllPeerConnectionsReply) Descriptor() ([]byte, []int)
- func (m *CloseAllPeerConnectionsReply) GetSuccess() bool
- func (*CloseAllPeerConnectionsReply) ProtoMessage()
- func (m *CloseAllPeerConnectionsReply) Reset()
- func (m *CloseAllPeerConnectionsReply) String() string
- func (m *CloseAllPeerConnectionsReply) XXX_DiscardUnknown()
- func (m *CloseAllPeerConnectionsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseAllPeerConnectionsReply) XXX_Merge(src proto.Message)
- func (m *CloseAllPeerConnectionsReply) XXX_Size() int
- func (m *CloseAllPeerConnectionsReply) XXX_Unmarshal(b []byte) error
- type ClosePeerConnectionsReply
- func (*ClosePeerConnectionsReply) Descriptor() ([]byte, []int)
- func (m *ClosePeerConnectionsReply) GetSuccess() bool
- func (*ClosePeerConnectionsReply) ProtoMessage()
- func (m *ClosePeerConnectionsReply) Reset()
- func (m *ClosePeerConnectionsReply) String() string
- func (m *ClosePeerConnectionsReply) XXX_DiscardUnknown()
- func (m *ClosePeerConnectionsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClosePeerConnectionsReply) XXX_Merge(src proto.Message)
- func (m *ClosePeerConnectionsReply) XXX_Size() int
- func (m *ClosePeerConnectionsReply) XXX_Unmarshal(b []byte) error
- type IDReply
- func (*IDReply) Descriptor() ([]byte, []int)
- func (m *IDReply) GetID() string
- func (*IDReply) ProtoMessage()
- func (m *IDReply) Reset()
- func (m *IDReply) String() string
- func (m *IDReply) XXX_DiscardUnknown()
- func (m *IDReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IDReply) XXX_Merge(src proto.Message)
- func (m *IDReply) XXX_Size() int
- func (m *IDReply) XXX_Unmarshal(b []byte) error
- type ListenAddressesReply
- func (*ListenAddressesReply) Descriptor() ([]byte, []int)
- func (m *ListenAddressesReply) GetAddresses() []string
- func (*ListenAddressesReply) ProtoMessage()
- func (m *ListenAddressesReply) Reset()
- func (m *ListenAddressesReply) String() string
- func (m *ListenAddressesReply) XXX_DiscardUnknown()
- func (m *ListenAddressesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListenAddressesReply) XXX_Merge(src proto.Message)
- func (m *ListenAddressesReply) XXX_Size() int
- func (m *ListenAddressesReply) XXX_Unmarshal(b []byte) error
- type Message
- func (*Message) Descriptor() ([]byte, []int)
- func (m *Message) GetData() []byte
- func (m *Message) GetId() string
- func (m *Message) GetSequence() int32
- func (*Message) ProtoMessage()
- 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_Merge(src proto.Message)
- func (m *Message) XXX_Size() int
- func (m *Message) XXX_Unmarshal(b []byte) error
- type OpenPeerConnectionReply
- func (*OpenPeerConnectionReply) Descriptor() ([]byte, []int)
- func (m *OpenPeerConnectionReply) GetPeer() string
- func (m *OpenPeerConnectionReply) GetSuccess() bool
- func (*OpenPeerConnectionReply) ProtoMessage()
- func (m *OpenPeerConnectionReply) Reset()
- func (m *OpenPeerConnectionReply) String() string
- func (m *OpenPeerConnectionReply) XXX_DiscardUnknown()
- func (m *OpenPeerConnectionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenPeerConnectionReply) XXX_Merge(src proto.Message)
- func (m *OpenPeerConnectionReply) XXX_Size() int
- func (m *OpenPeerConnectionReply) XXX_Unmarshal(b []byte) error
- type OpenPeersConnectionsReplies
- func (*OpenPeersConnectionsReplies) Descriptor() ([]byte, []int)
- func (m *OpenPeersConnectionsReplies) GetPeerConnections() []*OpenPeerConnectionReply
- func (*OpenPeersConnectionsReplies) ProtoMessage()
- func (m *OpenPeersConnectionsReplies) Reset()
- func (m *OpenPeersConnectionsReplies) String() string
- func (m *OpenPeersConnectionsReplies) XXX_DiscardUnknown()
- func (m *OpenPeersConnectionsReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenPeersConnectionsReplies) XXX_Merge(src proto.Message)
- func (m *OpenPeersConnectionsReplies) XXX_Size() int
- func (m *OpenPeersConnectionsReplies) XXX_Unmarshal(b []byte) error
- type PeersList
- func (*PeersList) Descriptor() ([]byte, []int)
- func (m *PeersList) GetPeers() []string
- func (*PeersList) ProtoMessage()
- func (m *PeersList) Reset()
- func (m *PeersList) String() string
- func (m *PeersList) XXX_DiscardUnknown()
- func (m *PeersList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeersList) XXX_Merge(src proto.Message)
- func (m *PeersList) XXX_Size() int
- func (m *PeersList) XXX_Unmarshal(b []byte) error
- type PublishReply
- func (*PublishReply) Descriptor() ([]byte, []int)
- func (m *PublishReply) GetMsgId() string
- func (m *PublishReply) GetSuccess() bool
- func (*PublishReply) ProtoMessage()
- func (m *PublishReply) Reset()
- func (m *PublishReply) String() string
- func (m *PublishReply) XXX_DiscardUnknown()
- func (m *PublishReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PublishReply) XXX_Merge(src proto.Message)
- func (m *PublishReply) XXX_Size() int
- func (m *PublishReply) XXX_Unmarshal(b []byte) error
- type PublisherClient
- type PublisherServer
- type ShutdownReply
- func (*ShutdownReply) Descriptor() ([]byte, []int)
- func (m *ShutdownReply) GetSuccess() bool
- func (*ShutdownReply) ProtoMessage()
- func (m *ShutdownReply) Reset()
- func (m *ShutdownReply) String() string
- func (m *ShutdownReply) XXX_DiscardUnknown()
- func (m *ShutdownReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShutdownReply) XXX_Merge(src proto.Message)
- func (m *ShutdownReply) XXX_Size() int
- func (m *ShutdownReply) XXX_Unmarshal(b []byte) error
- type UnimplementedPublisherServer
- func (*UnimplementedPublisherServer) CloseAllPeerConnections(ctx context.Context, req *empty.Empty) (*CloseAllPeerConnectionsReply, error)
- func (*UnimplementedPublisherServer) ClosePeerConnections(ctx context.Context, req *PeersList) (*ClosePeerConnectionsReply, error)
- func (*UnimplementedPublisherServer) ID(ctx context.Context, req *empty.Empty) (*IDReply, error)
- func (*UnimplementedPublisherServer) ListConnectedPeers(ctx context.Context, req *empty.Empty) (*PeersList, error)
- func (*UnimplementedPublisherServer) ListenAddresses(ctx context.Context, req *empty.Empty) (*ListenAddressesReply, error)
- func (*UnimplementedPublisherServer) OpenPeersConnections(ctx context.Context, req *PeersList) (*OpenPeersConnectionsReplies, error)
- func (*UnimplementedPublisherServer) PublishMessage(ctx context.Context, req *Message) (*PublishReply, error)
- func (*UnimplementedPublisherServer) Shutdown(ctx context.Context, req *empty.Empty) (*ShutdownReply, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterPublisherServer ¶
func RegisterPublisherServer(s *grpc.Server, srv PublisherServer)
Types ¶
type CloseAllPeerConnectionsReply ¶ added in v0.1.0
type CloseAllPeerConnectionsReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CloseAllPeerConnectionsReply) Descriptor ¶ added in v0.1.0
func (*CloseAllPeerConnectionsReply) Descriptor() ([]byte, []int)
func (*CloseAllPeerConnectionsReply) GetSuccess ¶ added in v0.1.0
func (m *CloseAllPeerConnectionsReply) GetSuccess() bool
func (*CloseAllPeerConnectionsReply) ProtoMessage ¶ added in v0.1.0
func (*CloseAllPeerConnectionsReply) ProtoMessage()
func (*CloseAllPeerConnectionsReply) Reset ¶ added in v0.1.0
func (m *CloseAllPeerConnectionsReply) Reset()
func (*CloseAllPeerConnectionsReply) String ¶ added in v0.1.0
func (m *CloseAllPeerConnectionsReply) String() string
func (*CloseAllPeerConnectionsReply) XXX_DiscardUnknown ¶ added in v0.1.0
func (m *CloseAllPeerConnectionsReply) XXX_DiscardUnknown()
func (*CloseAllPeerConnectionsReply) XXX_Marshal ¶ added in v0.1.0
func (m *CloseAllPeerConnectionsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseAllPeerConnectionsReply) XXX_Merge ¶ added in v0.1.0
func (m *CloseAllPeerConnectionsReply) XXX_Merge(src proto.Message)
func (*CloseAllPeerConnectionsReply) XXX_Size ¶ added in v0.1.0
func (m *CloseAllPeerConnectionsReply) XXX_Size() int
func (*CloseAllPeerConnectionsReply) XXX_Unmarshal ¶ added in v0.1.0
func (m *CloseAllPeerConnectionsReply) XXX_Unmarshal(b []byte) error
type ClosePeerConnectionsReply ¶ added in v0.1.0
type ClosePeerConnectionsReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClosePeerConnectionsReply) Descriptor ¶ added in v0.1.0
func (*ClosePeerConnectionsReply) Descriptor() ([]byte, []int)
func (*ClosePeerConnectionsReply) GetSuccess ¶ added in v0.1.0
func (m *ClosePeerConnectionsReply) GetSuccess() bool
func (*ClosePeerConnectionsReply) ProtoMessage ¶ added in v0.1.0
func (*ClosePeerConnectionsReply) ProtoMessage()
func (*ClosePeerConnectionsReply) Reset ¶ added in v0.1.0
func (m *ClosePeerConnectionsReply) Reset()
func (*ClosePeerConnectionsReply) String ¶ added in v0.1.0
func (m *ClosePeerConnectionsReply) String() string
func (*ClosePeerConnectionsReply) XXX_DiscardUnknown ¶ added in v0.1.0
func (m *ClosePeerConnectionsReply) XXX_DiscardUnknown()
func (*ClosePeerConnectionsReply) XXX_Marshal ¶ added in v0.1.0
func (m *ClosePeerConnectionsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClosePeerConnectionsReply) XXX_Merge ¶ added in v0.1.0
func (m *ClosePeerConnectionsReply) XXX_Merge(src proto.Message)
func (*ClosePeerConnectionsReply) XXX_Size ¶ added in v0.1.0
func (m *ClosePeerConnectionsReply) XXX_Size() int
func (*ClosePeerConnectionsReply) XXX_Unmarshal ¶ added in v0.1.0
func (m *ClosePeerConnectionsReply) XXX_Unmarshal(b []byte) error
type IDReply ¶ added in v0.1.0
type IDReply struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IDReply) Descriptor ¶ added in v0.1.0
func (*IDReply) ProtoMessage ¶ added in v0.1.0
func (*IDReply) ProtoMessage()
func (*IDReply) XXX_DiscardUnknown ¶ added in v0.1.0
func (m *IDReply) XXX_DiscardUnknown()
func (*IDReply) XXX_Marshal ¶ added in v0.1.0
func (*IDReply) XXX_Unmarshal ¶ added in v0.1.0
type ListenAddressesReply ¶ added in v0.1.0
type ListenAddressesReply struct { Addresses []string `protobuf:"bytes,1,rep,name=Addresses,proto3" json:"Addresses,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListenAddressesReply) Descriptor ¶ added in v0.1.0
func (*ListenAddressesReply) Descriptor() ([]byte, []int)
func (*ListenAddressesReply) GetAddresses ¶ added in v0.1.0
func (m *ListenAddressesReply) GetAddresses() []string
func (*ListenAddressesReply) ProtoMessage ¶ added in v0.1.0
func (*ListenAddressesReply) ProtoMessage()
func (*ListenAddressesReply) Reset ¶ added in v0.1.0
func (m *ListenAddressesReply) Reset()
func (*ListenAddressesReply) String ¶ added in v0.1.0
func (m *ListenAddressesReply) String() string
func (*ListenAddressesReply) XXX_DiscardUnknown ¶ added in v0.1.0
func (m *ListenAddressesReply) XXX_DiscardUnknown()
func (*ListenAddressesReply) XXX_Marshal ¶ added in v0.1.0
func (m *ListenAddressesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListenAddressesReply) XXX_Merge ¶ added in v0.1.0
func (m *ListenAddressesReply) XXX_Merge(src proto.Message)
func (*ListenAddressesReply) XXX_Size ¶ added in v0.1.0
func (m *ListenAddressesReply) XXX_Size() int
func (*ListenAddressesReply) XXX_Unmarshal ¶ added in v0.1.0
func (m *ListenAddressesReply) XXX_Unmarshal(b []byte) error
type Message ¶
type Message struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Sequence int32 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Message) Descriptor ¶
func (*Message) GetSequence ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) XXX_DiscardUnknown ¶
func (m *Message) XXX_DiscardUnknown()
func (*Message) XXX_Marshal ¶
func (*Message) XXX_Unmarshal ¶
type OpenPeerConnectionReply ¶ added in v0.1.0
type OpenPeerConnectionReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Peer string `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OpenPeerConnectionReply) Descriptor ¶ added in v0.1.0
func (*OpenPeerConnectionReply) Descriptor() ([]byte, []int)
func (*OpenPeerConnectionReply) GetPeer ¶ added in v0.1.0
func (m *OpenPeerConnectionReply) GetPeer() string
func (*OpenPeerConnectionReply) GetSuccess ¶ added in v0.1.0
func (m *OpenPeerConnectionReply) GetSuccess() bool
func (*OpenPeerConnectionReply) ProtoMessage ¶ added in v0.1.0
func (*OpenPeerConnectionReply) ProtoMessage()
func (*OpenPeerConnectionReply) Reset ¶ added in v0.1.0
func (m *OpenPeerConnectionReply) Reset()
func (*OpenPeerConnectionReply) String ¶ added in v0.1.0
func (m *OpenPeerConnectionReply) String() string
func (*OpenPeerConnectionReply) XXX_DiscardUnknown ¶ added in v0.1.0
func (m *OpenPeerConnectionReply) XXX_DiscardUnknown()
func (*OpenPeerConnectionReply) XXX_Marshal ¶ added in v0.1.0
func (m *OpenPeerConnectionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenPeerConnectionReply) XXX_Merge ¶ added in v0.1.0
func (m *OpenPeerConnectionReply) XXX_Merge(src proto.Message)
func (*OpenPeerConnectionReply) XXX_Size ¶ added in v0.1.0
func (m *OpenPeerConnectionReply) XXX_Size() int
func (*OpenPeerConnectionReply) XXX_Unmarshal ¶ added in v0.1.0
func (m *OpenPeerConnectionReply) XXX_Unmarshal(b []byte) error
type OpenPeersConnectionsReplies ¶ added in v0.1.0
type OpenPeersConnectionsReplies struct { PeerConnections []*OpenPeerConnectionReply `protobuf:"bytes,1,rep,name=PeerConnections,proto3" json:"PeerConnections,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OpenPeersConnectionsReplies) Descriptor ¶ added in v0.1.0
func (*OpenPeersConnectionsReplies) Descriptor() ([]byte, []int)
func (*OpenPeersConnectionsReplies) GetPeerConnections ¶ added in v0.1.0
func (m *OpenPeersConnectionsReplies) GetPeerConnections() []*OpenPeerConnectionReply
func (*OpenPeersConnectionsReplies) ProtoMessage ¶ added in v0.1.0
func (*OpenPeersConnectionsReplies) ProtoMessage()
func (*OpenPeersConnectionsReplies) Reset ¶ added in v0.1.0
func (m *OpenPeersConnectionsReplies) Reset()
func (*OpenPeersConnectionsReplies) String ¶ added in v0.1.0
func (m *OpenPeersConnectionsReplies) String() string
func (*OpenPeersConnectionsReplies) XXX_DiscardUnknown ¶ added in v0.1.0
func (m *OpenPeersConnectionsReplies) XXX_DiscardUnknown()
func (*OpenPeersConnectionsReplies) XXX_Marshal ¶ added in v0.1.0
func (m *OpenPeersConnectionsReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenPeersConnectionsReplies) XXX_Merge ¶ added in v0.1.0
func (m *OpenPeersConnectionsReplies) XXX_Merge(src proto.Message)
func (*OpenPeersConnectionsReplies) XXX_Size ¶ added in v0.1.0
func (m *OpenPeersConnectionsReplies) XXX_Size() int
func (*OpenPeersConnectionsReplies) XXX_Unmarshal ¶ added in v0.1.0
func (m *OpenPeersConnectionsReplies) XXX_Unmarshal(b []byte) error
type PeersList ¶ added in v0.1.0
type PeersList struct { Peers []string `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PeersList) Descriptor ¶ added in v0.1.0
func (*PeersList) ProtoMessage ¶ added in v0.1.0
func (*PeersList) ProtoMessage()
func (*PeersList) XXX_DiscardUnknown ¶ added in v0.1.0
func (m *PeersList) XXX_DiscardUnknown()
func (*PeersList) XXX_Marshal ¶ added in v0.1.0
func (*PeersList) XXX_Unmarshal ¶ added in v0.1.0
type PublishReply ¶
type PublishReply struct { MsgId string `protobuf:"bytes,1,opt,name=msgId,proto3" json:"msgId,omitempty"` Success bool `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PublishReply) Descriptor ¶
func (*PublishReply) Descriptor() ([]byte, []int)
func (*PublishReply) GetMsgId ¶
func (m *PublishReply) GetMsgId() string
func (*PublishReply) GetSuccess ¶
func (m *PublishReply) GetSuccess() bool
func (*PublishReply) ProtoMessage ¶
func (*PublishReply) ProtoMessage()
func (*PublishReply) Reset ¶
func (m *PublishReply) Reset()
func (*PublishReply) String ¶
func (m *PublishReply) String() string
func (*PublishReply) XXX_DiscardUnknown ¶
func (m *PublishReply) XXX_DiscardUnknown()
func (*PublishReply) XXX_Marshal ¶
func (m *PublishReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PublishReply) XXX_Merge ¶
func (m *PublishReply) XXX_Merge(src proto.Message)
func (*PublishReply) XXX_Size ¶
func (m *PublishReply) XXX_Size() int
func (*PublishReply) XXX_Unmarshal ¶
func (m *PublishReply) XXX_Unmarshal(b []byte) error
type PublisherClient ¶
type PublisherClient interface { // Publishes a message on the pubsub channel PublishMessage(ctx context.Context, in *Message, opts ...grpc.CallOption) (*PublishReply, error) // Closes all connections CloseAllPeerConnections(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*CloseAllPeerConnectionsReply, error) // Closes connections to listed peers ClosePeerConnections(ctx context.Context, in *PeersList, opts ...grpc.CallOption) (*ClosePeerConnectionsReply, error) // Opens connections to listed peers OpenPeersConnections(ctx context.Context, in *PeersList, opts ...grpc.CallOption) (*OpenPeersConnectionsReplies, error) // Lists the host's connected peers ListConnectedPeers(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PeersList, error) // Shuts the host down Shutdown(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ShutdownReply, error) // ID returns the host's id ID(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*IDReply, error) // ListenAddresses returns the host's listen addresses ListenAddresses(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListenAddressesReply, error) }
PublisherClient is the client API for Publisher service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewPublisherClient ¶
func NewPublisherClient(cc *grpc.ClientConn) PublisherClient
type PublisherServer ¶
type PublisherServer interface { // Publishes a message on the pubsub channel PublishMessage(context.Context, *Message) (*PublishReply, error) // Closes all connections CloseAllPeerConnections(context.Context, *empty.Empty) (*CloseAllPeerConnectionsReply, error) // Closes connections to listed peers ClosePeerConnections(context.Context, *PeersList) (*ClosePeerConnectionsReply, error) // Opens connections to listed peers OpenPeersConnections(context.Context, *PeersList) (*OpenPeersConnectionsReplies, error) // Lists the host's connected peers ListConnectedPeers(context.Context, *empty.Empty) (*PeersList, error) // Shuts the host down Shutdown(context.Context, *empty.Empty) (*ShutdownReply, error) // ID returns the host's id ID(context.Context, *empty.Empty) (*IDReply, error) // ListenAddresses returns the host's listen addresses ListenAddresses(context.Context, *empty.Empty) (*ListenAddressesReply, error) }
PublisherServer is the server API for Publisher service.
type ShutdownReply ¶ added in v0.1.0
type ShutdownReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ShutdownReply) Descriptor ¶ added in v0.1.0
func (*ShutdownReply) Descriptor() ([]byte, []int)
func (*ShutdownReply) GetSuccess ¶ added in v0.1.0
func (m *ShutdownReply) GetSuccess() bool
func (*ShutdownReply) ProtoMessage ¶ added in v0.1.0
func (*ShutdownReply) ProtoMessage()
func (*ShutdownReply) Reset ¶ added in v0.1.0
func (m *ShutdownReply) Reset()
func (*ShutdownReply) String ¶ added in v0.1.0
func (m *ShutdownReply) String() string
func (*ShutdownReply) XXX_DiscardUnknown ¶ added in v0.1.0
func (m *ShutdownReply) XXX_DiscardUnknown()
func (*ShutdownReply) XXX_Marshal ¶ added in v0.1.0
func (m *ShutdownReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShutdownReply) XXX_Merge ¶ added in v0.1.0
func (m *ShutdownReply) XXX_Merge(src proto.Message)
func (*ShutdownReply) XXX_Size ¶ added in v0.1.0
func (m *ShutdownReply) XXX_Size() int
func (*ShutdownReply) XXX_Unmarshal ¶ added in v0.1.0
func (m *ShutdownReply) XXX_Unmarshal(b []byte) error
type UnimplementedPublisherServer ¶
type UnimplementedPublisherServer struct { }
UnimplementedPublisherServer can be embedded to have forward compatible implementations.
func (*UnimplementedPublisherServer) CloseAllPeerConnections ¶ added in v0.1.0
func (*UnimplementedPublisherServer) CloseAllPeerConnections(ctx context.Context, req *empty.Empty) (*CloseAllPeerConnectionsReply, error)
func (*UnimplementedPublisherServer) ClosePeerConnections ¶ added in v0.1.0
func (*UnimplementedPublisherServer) ClosePeerConnections(ctx context.Context, req *PeersList) (*ClosePeerConnectionsReply, error)
func (*UnimplementedPublisherServer) ListConnectedPeers ¶ added in v0.1.0
func (*UnimplementedPublisherServer) ListenAddresses ¶ added in v0.1.0
func (*UnimplementedPublisherServer) ListenAddresses(ctx context.Context, req *empty.Empty) (*ListenAddressesReply, error)
func (*UnimplementedPublisherServer) OpenPeersConnections ¶ added in v0.1.0
func (*UnimplementedPublisherServer) OpenPeersConnections(ctx context.Context, req *PeersList) (*OpenPeersConnectionsReplies, error)
func (*UnimplementedPublisherServer) PublishMessage ¶
func (*UnimplementedPublisherServer) PublishMessage(ctx context.Context, req *Message) (*PublishReply, error)
func (*UnimplementedPublisherServer) Shutdown ¶ added in v0.1.0
func (*UnimplementedPublisherServer) Shutdown(ctx context.Context, req *empty.Empty) (*ShutdownReply, error)
Click to show internal directories.
Click to hide internal directories.