clientutil

Documentation

Index

• Variables
• func CreateOnlineOfflineMessage(clientID string) (onlineMsgBytes, offlineMsgBytes []byte)
• type BaseClient
  • func NewBaseClient(ctx context.Context, handleCmd types.AgentCmdHandleFunc, maxPayloadSize int) (*BaseClient, error)
  • func (b *BaseClient) Context() context.Context
  • func (b *BaseClient) HandleCmd(cmdBytes []byte)
  • func (b *BaseClient) MaxPayloadSize() int
  • func (b *BaseClient) OnClose(doExit func() error) error
• type CommonConfig

Variables

var (
	ErrClientAlreadyConnected = errors.New("client already connected")
	ErrClientNotConnected     = errors.New("client not connected")
	ErrCmdRecvClosed          = errors.New("cmd recv closed")
)

Functions

func CreateOnlineOfflineMessage

func CreateOnlineOfflineMessage(clientID string) (onlineMsgBytes, offlineMsgBytes []byte)

Types

type BaseClient

type BaseClient struct {
	Log log.Interface
	// contains filtered or unexported fields
}

func NewBaseClient

func NewBaseClient(
	ctx context.Context,
	handleCmd types.AgentCmdHandleFunc,
	maxPayloadSize int,
) (*BaseClient, error)

func (*BaseClient) Context

func (b *BaseClient) Context() context.Context

func (*BaseClient) HandleCmd

func (b *BaseClient) HandleCmd(cmdBytes []byte)

func (*BaseClient) MaxPayloadSize

func (b *BaseClient) MaxPayloadSize() int

func (*BaseClient) OnClose

func (b *BaseClient) OnClose(doExit func() error) error

type CommonConfig

type CommonConfig struct {
	Endpoint       string              `json:"endpoint" yaml:"endpoint"`
	MaxPayloadSize int                 `json:"maxPayloadSize" yaml:"maxPayloadSize"`
	TLS            tlshelper.TLSConfig `json:"tls" yaml:"tls"`
}