Versions in this module Expand all Collapse all v2 v2.9.0 Oct 28, 2020 Changes in this version type Client + func (c *Client) Sync() error + func (c *Client) Write(p []byte) (n int, err error) v2.8.0 Sep 15, 2020 Changes in this version type Client + AgentPermissions string v2.6.1 Aug 25, 2020 Changes in this version type Client + ServerVersion string v2.0.0 Apr 7, 2020 Changes in this version + const ProtocolMajorVersion + const ProtocolMinorVersion + type Client struct + AccountID uuid.UUID + ClusterID uuid.UUID + func InitClient(args map[string]interface{}, version string, startID string, ...) (*Client, error) + func (client *Client) AddListener(kind proto.PacketKind, listener func(in []byte) ([]byte, error)) + func (client *Client) Connect(connect chan bool) error + func (client *Client) Done(exitcode int, jitter bool) + func (client *Client) IsReady() bool + func (client *Client) Pipe(pack Package) + func (client *Client) PipeStatus(pack Package) + func (client *Client) Recover() + func (client *Client) Send(kind proto.PacketKind, in interface{}, out interface{}) error + func (client *Client) SendRaw(rawResources map[string]interface{}) + func (client *Client) StartWatchdog() + func (client *Client) WaitExit() + func (client *Client) WaitForConnection(timeout time.Duration) bool + func (client *Client) WithBackoff(fn func() error) + func (client *Client) WithBackoffLimit(fn func() error, limit int) error + type DefaultPipeStore struct + func NewDefaultPipeStore() *DefaultPipeStore + func (s *DefaultPipeStore) Ack(pack *Package) + func (s *DefaultPipeStore) Add(pack *Package) int + func (s *DefaultPipeStore) Len() int + func (s *DefaultPipeStore) Peek() *Package + func (s *DefaultPipeStore) Pop() *Package + type Package struct + Data interface{} + ExpiryCount int + ExpiryTime *time.Time + Kind proto.PacketKind + Priority int + Retries int + type Pipe struct + func NewPipe(sender PipeSender, logger *log.Logger) *Pipe + func (p *Pipe) Len() int + func (p *Pipe) Send(pack Package) int + func (p *Pipe) Start(workers int) + type PipeSender interface + Send func(kind proto.PacketKind, in interface{}, out interface{}) error + type PipeStore interface + Ack func(*Package) + Add func(*Package) int + Len func() int + Peek func() *Package + Pop func() *Package + type PriorityQueue []*Package + func (pq *PriorityQueue) First() interface{} + func (pq *PriorityQueue) Pop() interface{} + func (pq *PriorityQueue) Push(x interface{}) + func (pq PriorityQueue) Len() int + func (pq PriorityQueue) Less(i, j int) bool + func (pq PriorityQueue) Swap(i, j int) Other modules containing this package github.com/MagalixCorp/magalix-agent github.com/MagalixCorp/magalix-agent/v3
Go to main page