log

Documentation

Index

• Constants
• type Config
• type Manager
  • func NewManager(client pct.WebsocketClient, logChan chan *proto.LogEntry) *Manager
  • func (m *Manager) GetConfig() ([]proto.AgentConfig, []error)
  • func (m *Manager) Handle(cmd *proto.Cmd) *proto.Reply
  • func (m *Manager) Relay() *Relay
  • func (m *Manager) Start() error
  • func (m *Manager) Status() map[string]string
  • func (m *Manager) Stop() error
• type Relay
  • func NewRelay(client pct.WebsocketClient, logChan chan *proto.LogEntry, logFile string, ...) *Relay
  • func (r *Relay) LogChan() chan *proto.LogEntry
  • func (r *Relay) LogFileChan() chan string
  • func (r *Relay) LogLevelChan() chan byte
  • func (r *Relay) Run()
  • func (r *Relay) Status() map[string]string

Constants

const (
	DEFAULT_LOG_FILE  = ""
	DEFAULT_LOG_LEVEL = "info"
)

const (
	BUFFER_SIZE int = 10
)

Types

type Config

type Config struct {
	Level   string
	File    string
	Offline bool
}

type Manager

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

func NewManager

func NewManager(client pct.WebsocketClient, logChan chan *proto.LogEntry) *Manager

func (*Manager) GetConfig

func (m *Manager) GetConfig() ([]proto.AgentConfig, []error)

func (*Manager) Handle

func (m *Manager) Handle(cmd *proto.Cmd) *proto.Reply

@goroutine[0]

func (*Manager) Relay

func (m *Manager) Relay() *Relay

@goroutine[0]

func (*Manager) Start

func (m *Manager) Start() error

@goroutine[0]

func (*Manager) Status

func (m *Manager) Status() map[string]string

@goroutine[0]

func (*Manager) Stop

func (m *Manager) Stop() error

@goroutine[0]

type Relay

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

func NewRelay

func NewRelay(client pct.WebsocketClient, logChan chan *proto.LogEntry, logFile string, logLevel byte, offline bool) *Relay

func (*Relay) LogChan

func (r *Relay) LogChan() chan *proto.LogEntry

func (*Relay) LogFileChan

func (r *Relay) LogFileChan() chan string

func (*Relay) LogLevelChan

func (r *Relay) LogLevelChan() chan byte

func (*Relay) Run

func (r *Relay) Run()

func (*Relay) Status

func (r *Relay) Status() map[string]string