mock

package
v1.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 13, 2014 License: AGPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ClientConnectChan = make(chan *client, 1)
View Source 
var ClientConnectChanWss = make(chan *clientWss, 1)
View Source 
var ClientDisconnectChan = make(chan *client)
View Source 
var ClientDisconnectChanWss = make(chan *clientWss)
View Source 
var ClientRmChan = make(chan *client, 5)
View Source 
var ClientRmChanWss = make(chan *clientWss, 5)
View Source 
var Clients = make(map[*client]*client)
View Source 
var ClientsWss = make(map[*clientWss]*clientWss)
View Source 
var RecvChan chan interface{}
View Source 
var RecvChanWss chan interface{}
View Source 
var SendChan chan interface{}
View Source 
var SendChanWss chan interface{}

Functions

func DisconnectClient 

func DisconnectClient(c *client)

func DisconnectClientWss added in v1.0.4 

func DisconnectClientWss(c *clientWss)

func NewQanWorkerFactory 

func NewQanWorkerFactory(workers []*QanWorker) qan.WorkerFactory

func PingAPI 

func PingAPI(hostname, apiKey string) (bool, *http.Response)

Types

type API 

type API struct {
	GetCode  []int
	GetData  [][]byte
	GetError []error
	// contains filtered or unexported fields
}

func NewAPI 

func NewAPI(origin, hostname, apiKey, agentUuid string, links map[string]string) *API
func (a *API) AgentLink(resource string) string

func (*API) AgentUuid 

func (a *API) AgentUuid() string

func (*API) ApiKey 

func (a *API) ApiKey() string

func (*API) Connect 

func (a *API) Connect(hostname, apiKey, agentUuid string) error
func (a *API) EntryLink(resource string) string

func (*API) Get 

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

func (*API) Hostname 

func (a *API) Hostname() string

func (*API) Origin 

func (a *API) Origin() string

func (*API) Post 

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

func (*API) Put 

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

type Clock 

type Clock struct {
	Added   []uint
	Removed []chan time.Time
	Eta     float64
}

func NewClock 

func NewClock() *Clock

func (*Clock) Add 

func (m *Clock) Add(c chan time.Time, t uint, sync bool)

func (*Clock) ETA 

func (m *Clock) ETA(c chan time.Time) float64

func (*Clock) Remove 

func (m *Clock) Remove(c chan time.Time)

type ConnectionFactory 

type ConnectionFactory struct {
	Conn mysql.Connector
}

func (*ConnectionFactory) Make 

func (f *ConnectionFactory) Make(dsn string) mysql.Connector

type DataClient 

type DataClient struct {

	// --
	ErrChan   chan error
	RecvError chan error
	// contains filtered or unexported fields
}

func NewDataClient 

func NewDataClient(dataChan chan []byte, respChan chan interface{}) *DataClient

func (*DataClient) Conn 

func (c *DataClient) Conn() *websocket.Conn

func (*DataClient) Connect 

func (c *DataClient) Connect()

func (*DataClient) ConnectChan 

func (c *DataClient) ConnectChan() chan bool

func (*DataClient) ConnectOnce 

func (c *DataClient) ConnectOnce(timeout uint) error

func (*DataClient) Disconnect 

func (c *DataClient) Disconnect() error

func (*DataClient) ErrorChan 

func (c *DataClient) ErrorChan() chan error

func (*DataClient) Recv 

func (c *DataClient) Recv(resp interface{}, timeout uint) error

Second, agent calls this to recv response from API to previous send.

func (*DataClient) RecvChan 

func (c *DataClient) RecvChan() chan *proto.Cmd

func (*DataClient) Send 

func (c *DataClient) Send(data interface{}, timeout uint) error

func (*DataClient) SendBytes 

func (c *DataClient) SendBytes(data []byte) error

First, agent calls this to send encoded proto.Data to API.

func (*DataClient) SendChan 

func (c *DataClient) SendChan() chan *proto.Reply

func (*DataClient) SetConnectChan 

func (c *DataClient) SetConnectChan(connectChan chan bool)

func (*DataClient) Start 

func (c *DataClient) Start()

func (*DataClient) Status 

func (c *DataClient) Status() map[string]string

func (*DataClient) Stop 

func (c *DataClient) Stop()

type HttpClient 

type HttpClient struct {
	PostChan chan []byte
}

func (*HttpClient) Get 

func (c *HttpClient) Get(url string, v interface{}, timeout time.Duration) error

func (*HttpClient) Post 

func (c *HttpClient) Post(url string, data []byte) error

type IntervalIterFactory 

type IntervalIterFactory struct {
	Iters []qan.IntervalIter

	TickChans map[qan.IntervalIter]chan time.Time
	// contains filtered or unexported fields
}

func (*IntervalIterFactory) Make 

func (tf *IntervalIterFactory) Make(collectFrom string, filename qan.FilenameFunc, tickChan chan time.Time) qan.IntervalIter

func (*IntervalIterFactory) Reset 

func (tf *IntervalIterFactory) Reset()

type MmMonitor 

type MmMonitor struct {
	ReadyChan chan bool
	// contains filtered or unexported fields
}

func NewMmMonitor 

func NewMmMonitor() *MmMonitor

func (*MmMonitor) Config 

func (m *MmMonitor) Config() interface{}

func (*MmMonitor) SetConfig 

func (m *MmMonitor) SetConfig(v interface{})

func (*MmMonitor) Start 

func (m *MmMonitor) Start(tickChan chan time.Time, collectionChan chan *mm.Collection) error

func (*MmMonitor) Status 

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

func (*MmMonitor) Stop 

func (m *MmMonitor) Stop() error

func (*MmMonitor) TickChan 

func (m *MmMonitor) TickChan() chan time.Time

type MmMonitorFactory 

type MmMonitorFactory struct {
	Made []string
	// contains filtered or unexported fields
}

func NewMmMonitorFactory 

func NewMmMonitorFactory(monitors map[string]mm.Monitor) *MmMonitorFactory

func (*MmMonitorFactory) Make 

func (f *MmMonitorFactory) Make(service string, id uint, data []byte) (mm.Monitor, error)

type MockIntervalIter 

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

func NewMockIntervalIter 

func NewMockIntervalIter(intervalChan chan *qan.Interval) *MockIntervalIter

func (*MockIntervalIter) IntervalChan 

func (i *MockIntervalIter) IntervalChan() chan *qan.Interval

func (*MockIntervalIter) Start 

func (i *MockIntervalIter) Start()

func (*MockIntervalIter) Stop 

func (i *MockIntervalIter) Stop()

type MockServiceManager 

type MockServiceManager struct {
	StartErr     error
	StopErr      error
	IsRunningVal bool
	// contains filtered or unexported fields
}

func NewMockServiceManager 

func NewMockServiceManager(name string, readyChan chan bool, traceChan chan string) *MockServiceManager

func (*MockServiceManager) GetConfig 

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

func (*MockServiceManager) Handle 

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

func (*MockServiceManager) IsRunning 

func (m *MockServiceManager) IsRunning() bool

func (*MockServiceManager) Reset 

func (m *MockServiceManager) Reset()

func (*MockServiceManager) Start 

func (m *MockServiceManager) Start() error

func (*MockServiceManager) Status 

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

func (*MockServiceManager) Stop 

func (m *MockServiceManager) Stop() error

type MrmsMonitor added in v1.0.4 

type MrmsMonitor struct {
}

func NewMrmsMonitor added in v1.0.4 

func NewMrmsMonitor() *MrmsMonitor

func (*MrmsMonitor) Add added in v1.0.4 

func (m *MrmsMonitor) Add(dsn string) (c chan bool, err error)

func (*MrmsMonitor) Check added in v1.0.4 

func (m *MrmsMonitor) Check()

func (*MrmsMonitor) Remove added in v1.0.4 

func (m *MrmsMonitor) Remove(dsn string, c chan bool)

func (*MrmsMonitor) Start added in v1.0.4 

func (m *MrmsMonitor) Start(interval time.Duration) error

func (*MrmsMonitor) Status added in v1.0.4 

func (m *MrmsMonitor) Status() (status map[string]string)

func (*MrmsMonitor) Stop added in v1.0.4 

func (m *MrmsMonitor) Stop() error

type NullClient 

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

func NewNullClient 

func NewNullClient() *NullClient

func (*NullClient) Conn 

func (c *NullClient) Conn() *websocket.Conn

func (*NullClient) Connect 

func (c *NullClient) Connect()

func (*NullClient) ConnectChan 

func (c *NullClient) ConnectChan() chan bool

func (*NullClient) ConnectOnce 

func (c *NullClient) ConnectOnce() error

func (*NullClient) Disconnect 

func (c *NullClient) Disconnect() error

func (*NullClient) ErrorChan 

func (c *NullClient) ErrorChan() chan error

func (*NullClient) Recv 

func (c *NullClient) Recv(data interface{}, timeout uint) error

func (*NullClient) RecvChan 

func (c *NullClient) RecvChan() chan *proto.Cmd

func (*NullClient) Send 

func (c *NullClient) Send(data interface{}, timeout uint) error

func (*NullClient) SendBytes 

func (c *NullClient) SendBytes(data []byte) error

func (*NullClient) SendChan 

func (c *NullClient) SendChan() chan *proto.Reply

func (*NullClient) Start 

func (c *NullClient) Start()

func (*NullClient) Stop 

func (c *NullClient) Stop()

type NullMySQL 

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

func NewNullMySQL 

func NewNullMySQL() *NullMySQL

func (*NullMySQL) Close 

func (n *NullMySQL) Close()

func (*NullMySQL) Connect 

func (n *NullMySQL) Connect(tries uint) error

func (*NullMySQL) DB 

func (n *NullMySQL) DB() *sql.DB

func (*NullMySQL) DSN 

func (n *NullMySQL) DSN() string

func (*NullMySQL) Explain added in v1.0.4 

func (n *NullMySQL) Explain(query string, db string) (explain *proto.ExplainResult, err error)

func (*NullMySQL) GetGlobalVarString 

func (n *NullMySQL) GetGlobalVarString(varName string) string

func (*NullMySQL) GetSet 

func (n *NullMySQL) GetSet() []mysql.Query

func (*NullMySQL) GetUptimeCount added in v1.0.4 

func (n *NullMySQL) GetUptimeCount() uint

func (*NullMySQL) Reset 

func (n *NullMySQL) Reset()

func (*NullMySQL) Set 

func (n *NullMySQL) Set(queries []mysql.Query) error

func (*NullMySQL) SetExplain added in v1.0.4 

func (n *NullMySQL) SetExplain(query string, explain *proto.ExplainResult)

func (*NullMySQL) SetUptime added in v1.0.4 

func (n *NullMySQL) SetUptime(uptime int64)

func (*NullMySQL) Uptime added in v1.0.4 

func (n *NullMySQL) Uptime() int64

type QanWorker 

type QanWorker struct {
	Job *qan.Job
	// contains filtered or unexported fields
}

func NewQanWorker 

func NewQanWorker(name string, stopChan chan bool, result *qan.Result, err error, crash bool) *QanWorker

func (*QanWorker) Name 

func (w *QanWorker) Name() string

func (*QanWorker) Run 

func (w *QanWorker) Run(job *qan.Job) (*qan.Result, error)

func (*QanWorker) Running 

func (w *QanWorker) Running() chan bool

func (*QanWorker) Status 

func (w *QanWorker) Status() string

type QanWorkerFactory 

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

func (*QanWorkerFactory) Make 

func (f *QanWorkerFactory) Make(collectFrom, name string, mysqlConn mysql.Connector) qan.Worker

type QueryService added in v1.0.4 

type QueryService struct {
}

func NewQueryService added in v1.0.4 

func NewQueryService() *QueryService

func (*QueryService) Handle added in v1.0.4 

func (q *QueryService) Handle(cmd *proto.Cmd) (reply *proto.Reply)

type Spooler 

type Spooler struct {
	FilesOut []string          // test provides
	DataOut  map[string][]byte // test provides
	DataIn   []interface{}
	// contains filtered or unexported fields
}

func NewSpooler 

func NewSpooler(dataChan chan interface{}) *Spooler

func (*Spooler) Files 

func (s *Spooler) Files() <-chan string

func (*Spooler) Read 

func (s *Spooler) Read(file string) ([]byte, error)

func (*Spooler) Remove 

func (s *Spooler) Remove(file string) error

func (*Spooler) Start 

func (s *Spooler) Start(sz data.Serializer) error

func (*Spooler) Status 

func (s *Spooler) Status() map[string]string

func (*Spooler) Stop 

func (s *Spooler) Stop() error

func (*Spooler) Write 

func (s *Spooler) Write(service string, data interface{}) error

type SysconfigMonitor 

type SysconfigMonitor struct {
	ReadyChan chan bool
	// contains filtered or unexported fields
}

func NewSysconfigMonitor 

func NewSysconfigMonitor() *SysconfigMonitor

func (*SysconfigMonitor) Config 

func (m *SysconfigMonitor) Config() interface{}

func (*SysconfigMonitor) SetConfig 

func (m *SysconfigMonitor) SetConfig(v interface{})

func (*SysconfigMonitor) Start 

func (m *SysconfigMonitor) Start(tickChan chan time.Time, reportChan chan *sysconfig.Report) error

func (*SysconfigMonitor) Status 

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

func (*SysconfigMonitor) Stop 

func (m *SysconfigMonitor) Stop() error

func (*SysconfigMonitor) TickChan 

func (m *SysconfigMonitor) TickChan() chan time.Time

type SysconfigMonitorFactory 

type SysconfigMonitorFactory struct {
	Made []string
	// contains filtered or unexported fields
}

func NewSysconfigMonitorFactory 

func NewSysconfigMonitorFactory(monitors []sysconfig.Monitor) *SysconfigMonitorFactory

func (*SysconfigMonitorFactory) Make 

func (f *SysconfigMonitorFactory) Make(service string, id uint, data []byte) (sysconfig.Monitor, error)

func (*SysconfigMonitorFactory) Set 

func (f *SysconfigMonitorFactory) Set(monitors []sysconfig.Monitor)

type Ticker 

type Ticker struct {
	Added       []chan time.Time
	RunningChan chan bool
	// contains filtered or unexported fields
}

func NewTicker 

func NewTicker(syncChan chan bool) *Ticker

func (*Ticker) Add 

func (t *Ticker) Add(c chan time.Time)

func (*Ticker) ETA 

func (t *Ticker) ETA(now int64) float64

func (*Ticker) Remove 

func (t *Ticker) Remove(c chan time.Time)

func (*Ticker) Run 

func (t *Ticker) Run(now int64)

func (*Ticker) Stop 

func (t *Ticker) Stop()

type TickerFactory 

type TickerFactory struct {
	Made []uint
	// contains filtered or unexported fields
}

func NewTickerFactory 

func NewTickerFactory() *TickerFactory

func (*TickerFactory) Make 

func (tf *TickerFactory) Make(atInterval uint, sync bool) ticker.Ticker

func (*TickerFactory) Set 

func (tf *TickerFactory) Set(tickers []ticker.Ticker)

type WebsocketClient 

type WebsocketClient struct {
	ErrChan   chan error
	RecvError chan error

	RecvBytes chan []byte
	TraceChan chan string
	// contains filtered or unexported fields
}

func NewWebsocketClient 

func NewWebsocketClient(sendChan chan *proto.Cmd, recvChan chan *proto.Reply, sendDataChan chan interface{}, recvDataChan chan interface{}) *WebsocketClient

func (*WebsocketClient) Conn 

func (c *WebsocketClient) Conn() *websocket.Conn

func (*WebsocketClient) Connect 

func (c *WebsocketClient) Connect()

func (*WebsocketClient) ConnectChan 

func (c *WebsocketClient) ConnectChan() chan bool

func (*WebsocketClient) ConnectOnce 

func (c *WebsocketClient) ConnectOnce(timeout uint) error

func (*WebsocketClient) Disconnect 

func (c *WebsocketClient) Disconnect() error

func (*WebsocketClient) ErrorChan 

func (c *WebsocketClient) ErrorChan() chan error

func (*WebsocketClient) Recv 

func (c *WebsocketClient) Recv(data interface{}, timeout uint) error

func (*WebsocketClient) RecvChan 

func (c *WebsocketClient) RecvChan() chan *proto.Cmd

func (*WebsocketClient) Send 

func (c *WebsocketClient) Send(data interface{}, timeout uint) error

func (*WebsocketClient) SendBytes 

func (c *WebsocketClient) SendBytes(data []byte) error

func (*WebsocketClient) SendChan 

func (c *WebsocketClient) SendChan() chan *proto.Reply

func (*WebsocketClient) SetConnectChan 

func (c *WebsocketClient) SetConnectChan(connectChan chan bool)

func (*WebsocketClient) Start 

func (c *WebsocketClient) Start()

func (*WebsocketClient) Status 

func (c *WebsocketClient) Status() map[string]string

func (*WebsocketClient) Stop 

func (c *WebsocketClient) Stop()

type WebsocketServer 

type WebsocketServer struct {
}

func (*WebsocketServer) Run 

func (s *WebsocketServer) Run(addr string, endpoint string)

addr: http://127.0.0.1:8000 endpoint: /agent

type WebsocketServerWss added in v1.0.4 

type WebsocketServerWss struct {
}

func (*WebsocketServerWss) RunWss added in v1.0.4 

func (s *WebsocketServerWss) RunWss(addr string, endpoint string)

addr: https://127.0.0.1:8443 endpoint: /agent

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.