pct

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

type APIConnector interface {
	Connect(hostname, apiKey, agentUuid string) error
	Get(apiKey, url string) (int, []byte, error)
	Post(apiKey, url string, data []byte) (*http.Response, []byte, error)
	Put(apiKey, url string, data []byte) (*http.Response, []byte, error)
	EntryLink(resource string) string
	AgentLink(resource string) string
	Origin() string
	Hostname() string
	ApiKey() string
	AgentUuid() 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 DuplicateServiceInstanceError struct {
	Service string
	Id      uint
}

type InvalidServiceInstanceError struct {
	Service string
	Id      uint
}

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)
	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 UnknownServiceInstanceError struct {
	Service string
	Id      uint
}

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

type WebsocketClient interface {
	Connect()
	ConnectOnce() error
	Disconnect() error
	Status() map[string]string

	// Channel interface:
	Start()
	Stop()
	SendChan() chan *proto.Reply
	RecvChan() chan *proto.Cmd
	ConnectChan() chan bool
	ErrorChan() chan error

	// Direct interface:
	SendBytes(data []byte) error
	Send(data interface{}, timeout uint) error
	Recv(data interface{}, timeout uint) error
	Conn() *websocket.Conn
}