client

Documentation

Index

• type Client
  • func New(opts ClientOptions) (*Client, error)
  • func (c *Client) RegisterCommand(name string, cmdFunc interface{}) error
  • func (c *Client) Run() error
• type ClientOptions
• type ConnOptions

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func New

func New(opts ClientOptions) (*Client, error)

func (*Client) RegisterCommand

func (c *Client) RegisterCommand(name string, cmdFunc interface{}) error

func (*Client) Run

func (c *Client) Run() error

type ClientOptions

type ClientOptions struct {
	TargetServer    string
	ClusterUuid     string
	BearerToken     string
	LogLevel        string
	WorkersCount    int
	FixedFetchLimit int
	Version         string
	ConnOptions     ConnOptions
}

type ConnOptions

type ConnOptions struct {
	TLS                          *tls.Config
	MaxMsgSize                   int
	EnableKeepAlive              bool
	KeepAliveTime                time.Duration
	KeepAliveTimeout             time.Duration
	KeepAlivePermitWithoutStream bool
	UserDialOptions              []grpc.DialOption
}