grpc

Documentation

Index

• func NewGRPCClient(ctx context.Context, handleCmd types.AgentCmdHandleFunc, cfg interface{}) (client.Interface, error)
• type Client
  • func (c *Client) Close() error
  • func (c *Client) Connect(dialCtx context.Context) error
  • func (c *Client) PostMsg(msg *aranyagopb.Msg) error
  • func (c *Client) Start(ctx context.Context) error
• type Config

Functions

func NewGRPCClient

func NewGRPCClient(
	ctx context.Context,
	handleCmd types.AgentCmdHandleFunc,
	cfg interface{},
) (client.Interface, error)

Types

type Client

type Client struct {
	*clientutil.BaseClient
	// contains filtered or unexported fields
}

func (*Client) Close

func (c *Client) Close() error

func (*Client) Connect

func (c *Client) Connect(dialCtx context.Context) error

func (*Client) PostMsg

func (c *Client) PostMsg(msg *aranyagopb.Msg) error

func (*Client) Start

func (c *Client) Start(ctx context.Context) error

type Config

type Config struct {
	clientutil.CommonConfig `json:",inline" yaml:",inline"`
}