Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pct

package

Go to main page

Versions in this module

v1

v1.18.0

Jun 20, 2022

v1.7.0

Jan 22, 2018

v1.6.0

Jan 4, 2018

v1.5.3

Dec 13, 2017

v1.5.0

Nov 21, 2017

Changes in this version

type API

+ func (a *API) GetConnectionConfig() ConnectionConfig

type APIConnector

+ GetConnectionConfig func() ConnectionConfig

+ type ConnectionConfig struct

+ Password string

+ UseInsecureSSL bool

+ UseSSL bool

+ User string

v1.0.0

Apr 17, 2016

Changes in this version

+ const BIN_DIR

+ const CONFIG_DIR

+ const CONFIG_FILE_SUFFIX

+ const DATA_DIR

+ const DEFAULT_BASEDIR

+ const INSTANCE_DIR

+ const INSTANCE_FILE_SUFFIX

+ const START_LOCK

+ const START_SCRIPT

+ const TRASH_DIR

+ var Basedir basedir

+ var ErrNoSystemTree error = errors.New("No local system tree file")

+ func AtLeastVersion(v1, v2 string) (bool, error)

+ func Bytes(bytes uint64) string

+ func Duration(s float64) string

+ func FileExists(file string) bool

+ func FileSize(fileName string) (int64, error)

+ func MakeDir(dir string) error

+ func MakeStartLock() error

+ func Mbps(bytes uint64, seconds float64) string

+ func Ping(hostname string, headers map[string]string) (int, error)

+ func RemoveFile(file string) error

+ func SameFile(file1, file2 string) (bool, error)

+ func TimeString(t time.Time) string

+ func TimeoutDialer(config *TimeoutClientConfig) func(net, addr string) (c net.Conn, err error)

+ func ToBool(s string) bool

+ func URL(hostname string, paths ...string) string

+ func WaitStartLock() error

+ type API struct

+ func NewAPI() *API

+ func (a *API) AgentLink(resource string) string

+ func (a *API) AgentUuid() string

+ func (a *API) Connect(hostname, agentUuid string) error

+ func (a *API) CreateInstance(url string, in interface{}) (bool, error)

+ func (a *API) EntryLink(resource string) string

+ func (a *API) Get(url string) (int, []byte, error)

+ func (a *API) Hostname() string

+ func (a *API) Init(hostname string, headers map[string]string) (int, error)

+ func (a *API) Origin() string

+ func (a *API) Post(url string, data []byte) (*http.Response, []byte, error)

+ func (a *API) Put(url string, data []byte) (*http.Response, []byte, error)

+ func (a *API) URL(paths ...string) string

+ type APIConnector interface

+ AgentLink func(resource string) string

+ AgentUuid func() string

+ Connect func(hostname, agentUuid string) error

+ CreateInstance func(url string, it interface{}) (bool, error)

+ EntryLink func(resource string) string

+ Get func(url string) (int, []byte, error)

+ Hostname func() string

+ Init func(hostname string, headers map[string]string) (code int, err error)

+ Origin func() string

+ Post func(url string, data []byte) (*http.Response, []byte, error)

+ Put func(url string, data []byte) (*http.Response, []byte, error)

+ URL func(paths ...string) string

+ type Backoff struct

+ NowFunc func() time.Time

+ func NewBackoff(maxWait int, resetAfter time.Duration) *Backoff

+ func (b *Backoff) Success()

+ func (b *Backoff) Wait() time.Duration

+ type CmdRejectedError struct

+ Cmd string

+ Reason string

+ func (e CmdRejectedError) Error() string

+ type CmdTimeoutError struct

+ Cmd string

+ func (e CmdTimeoutError) Error() string

+ type InvalidInstanceError struct

+ UUID string

+ func (e InvalidInstanceError) Error() string

+ type Logger struct

+ func NewLogger(logChan chan proto.LogEntry, service string) *Logger

+ func (l *Logger) Debug(entry ...interface{})

+ func (l *Logger) DebugOffline(entry ...interface{})

+ func (l *Logger) Error(entry ...interface{})

+ func (l *Logger) Fatal(entry ...interface{})

+ func (l *Logger) Info(entry ...interface{})

+ func (l *Logger) LogChan() chan proto.LogEntry

+ func (l *Logger) Service() string

+ func (l *Logger) Warn(entry ...interface{})

+ type PidFile struct

+ func NewPidFile() *PidFile

+ func (p *PidFile) Get() string

+ func (p *PidFile) Remove() error

+ func (p *PidFile) Set(pidFile string) error

+ type QueueFullError struct

+ Cmd string

+ Name string

+ Size uint

+ func (e QueueFullError) Error() string

+ type ServiceIsNotRunningError struct

+ Service string

+ func (e ServiceIsNotRunningError) Error() string

+ type ServiceIsRunningError struct

+ Service string

+ func (e ServiceIsRunningError) Error() string

+ type ServiceManager interface

+ GetConfig func() ([]proto.AgentConfig, []error)

+ GetDefaults func() map[string]interface{}

+ Handle func(cmd *proto.Cmd) *proto.Reply

+ Start func() error

+ Status func() map[string]string

+ Stop func() error

+ type Status struct

+ func NewStatus(procs []string) *Status

+ func (s *Status) All() map[string]string

+ func (s *Status) Get(proc string) string

+ func (s *Status) Merge(others ...map[string]string) map[string]string

+ func (s *Status) Update(proc string, status string)

+ func (s *Status) UpdateRe(proc string, status string, cmd *proto.Cmd)

+ type StatusReporter interface

+ Status func() map[string]string

+ type SyncChan struct

+ Crash bool

+ CrashChan chan bool

+ DoneChan chan bool

+ StartChan chan bool

+ StopChan chan bool

+ func NewSyncChan() *SyncChan

+ func (sync *SyncChan) Done()

+ func (sync *SyncChan) Graceful()

+ func (sync *SyncChan) IsGraceful() bool

+ func (sync *SyncChan) Start() bool

+ func (sync *SyncChan) Stop()

+ func (sync *SyncChan) Wait()

+ type TimeoutClientConfig struct

+ ConnectTimeout time.Duration

+ ReadWriteTimeout time.Duration

+ type UnknownCmdError struct

+ Cmd string

+ func (e UnknownCmdError) Error() string

+ type UnknownServiceError struct

+ Service string

+ func (e UnknownServiceError) Error() string

+ type WebsocketClient interface

+ Conn func() *websocket.Conn

+ Connect func()

+ ConnectChan func() chan bool

+ ConnectOnce func(timeout uint) error

+ Disconnect func() error

+ DisconnectOnce func() error

+ ErrorChan func() chan error

+ Recv func(data interface{}, timeout uint) error

+ RecvChan func() chan *proto.Cmd

+ Send func(data interface{}, timeout uint) error

+ SendBytes func(data []byte, timeout uint) error

+ SendChan func() chan *proto.Reply

+ Start func()

+ Status func() map[string]string

+ Stop func()