client

Documentation

Index

• Constants
• type Client
• type RPCClient
  • func NewRPCClient(address string, tlsCfg security.TLSAuth) (*RPCClient, error)
  • func (c *RPCClient) Close()
  • func (c *RPCClient) GetServerInfo() ([]string, error)
  • func (c *RPCClient) SendRequest(ctx context.Context, address string, req *hstreamrpc.Request) (*hstreamrpc.Response, error)

Constants

const (
	DialTimeout    = 5 * time.Second
	RequestTimeout = 5 * time.Second
)

Types

type Client

type Client interface {
	// GetServerInfo returns the basic server infos of the cluster.
	GetServerInfo() ([]string, error)
	// SendRequest sends a rpc request to the server.
	SendRequest(ctx context.Context, address string, req *hstreamrpc.Request) (*hstreamrpc.Response, error)
	// Close closes the client.
	Close()
}

Client is a client that sends RPC to HStreamDB server. It should not be used after calling Close().

type RPCClient

type RPCClient struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

RPCClient will send rpc requests to HStreamDB server.

func NewRPCClient

func NewRPCClient(address string, tlsCfg security.TLSAuth) (*RPCClient, error)

NewRPCClient TODO：use connection pool for each address

func (*RPCClient) Close

func (c *RPCClient) Close()

func (*RPCClient) GetServerInfo

func (c *RPCClient) GetServerInfo() ([]string, error)

GetServerInfo returns cached server info

func (*RPCClient) SendRequest

func (c *RPCClient) SendRequest(ctx context.Context, address string, req *hstreamrpc.Request) (*hstreamrpc.Response, error)

SendRequest sends a hstreamrpc.Request to the specified server.