Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface { Ping() (*dispatcher.PingReply, error) Put(ctx context.Context, msg *transport.Message) (*transport.Message, error) Close() error }
Client is the client for DNC
type GRPCClient ¶
type GRPCClient struct {
// contains filtered or unexported fields
}
GRPCClient Calls the client.
func (*GRPCClient) Close ¶
func (s *GRPCClient) Close() error
func (*GRPCClient) Ping ¶
func (c *GRPCClient) Ping() (*dispatcher.PingReply, error)
Ping sends a ping request..
type NATSClient ¶
type NATSClient struct {
// contains filtered or unexported fields
}
func (*NATSClient) Close ¶
func (client *NATSClient) Close() error
func (*NATSClient) Ping ¶
func (client *NATSClient) Ping() (*dispatcher.PingReply, error)
Click to show internal directories.
Click to hide internal directories.