pct

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

type APIConnector interface {
	Connect(hostname, agentUuid string) error
	Init(hostname string, headers map[string]string) (code int, err error)
	Get(url string) (int, []byte, error)
	Post(url string, data []byte) (*http.Response, []byte, error)
	Put(url string, data []byte) (*http.Response, []byte, error)
	CreateInstance(url string, it interface{}) (bool, error)
	EntryLink(resource string) string
	AgentLink(resource string) string
	Origin() string
	Hostname() string
	AgentUuid() string
	URL(paths ...string) string
}

type Backoff struct {
	NowFunc func() time.Time
	// contains filtered or unexported fields
}

type CmdRejectedError struct {
	Cmd    string
	Reason string
}

type CmdTimeoutError struct {
	Cmd string
}

type InvalidInstanceError struct {
	UUID string
}

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

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

type QueueFullError struct {
	Cmd  string
	Name string
	Size uint
}

type ServiceIsNotRunningError struct {
	Service string
}

type ServiceIsRunningError struct {
	Service string
}

type ServiceManager interface {
	Start() error
	Stop() error
	Status() map[string]string
	GetConfig() ([]proto.AgentConfig, []error)
	GetDefaults() map[string]interface{}
	Handle(cmd *proto.Cmd) *proto.Reply
}

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

type StatusReporter interface {
	Status() map[string]string
}

type SyncChan struct {
	StartChan chan bool
	StopChan  chan bool
	DoneChan  chan bool
	CrashChan chan bool
	Crash     bool
}

type TimeoutClientConfig struct {
	ConnectTimeout   time.Duration
	ReadWriteTimeout time.Duration
}

type UnknownCmdError struct {
	Cmd string
}

type UnknownServiceError struct {
	Service string
}

type WebsocketClient interface {
	Conn() *websocket.Conn
	Status() map[string]string

	// Cmd/Reply chans:
	Start()                      // start the send/recv chans
	Stop()                       // stop the send/recv chans manually
	RecvChan() chan *proto.Cmd   // get the (recv) cmdChan
	SendChan() chan *proto.Reply // get the (send) replyChan

	// Async connect:
	Connect()               // try forever to connect, notify via ConnectChan
	Disconnect() error      // disconnect manually, notify via ConnectChan
	ConnectChan() chan bool // true on connect, false on disconnect
	ErrorChan() chan error  // get err from send/recv chans

	// Sync connect:
	ConnectOnce(timeout uint) error
	DisconnectOnce() error

	// Data transfer:
	SendBytes(data []byte, timeout uint) error // send data (data/sender)
	Recv(data interface{}, timeout uint) error // recv proto.Response (data/sender)
	Send(data interface{}, timeout uint) error // send proto.LogEntry (log/relay)
}