data

package

v1.0.2 Latest Latest Go to latest Published: May 27, 2014 License: AGPL-3.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/yvasiyarov/percona-agent

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type Config
type DiskvSpooler
- func NewDiskvSpooler(logger *pct.Logger, dataDir string, hostname string) *DiskvSpooler
- func (s *DiskvSpooler) Files() <-chan string
- func (s *DiskvSpooler) Read(file string) ([]byte, error)
- func (s *DiskvSpooler) Remove(file string) error
- func (s *DiskvSpooler) Start(sz Serializer) error
- func (s *DiskvSpooler) Status() map[string]string
- func (s *DiskvSpooler) Stop() error
- func (s *DiskvSpooler) Write(service string, data interface{}) error
type JsonGzipSerializer
- func NewJsonGzipSerializer() *JsonGzipSerializer
- func (s *JsonGzipSerializer) Concurrent() bool
- func (s *JsonGzipSerializer) Encoding() string
- func (s *JsonGzipSerializer) ToBytes(data interface{}) ([]byte, error)
type JsonSerializer
- func NewJsonSerializer() *JsonSerializer
- func (s *JsonSerializer) Concurrent() bool
- func (s *JsonSerializer) Encoding() string
- func (j *JsonSerializer) ToBytes(data interface{}) ([]byte, error)
type Manager
- func NewManager(logger *pct.Logger, dataDir string, hostname string, ...) *Manager
- func (m *Manager) GetConfig() ([]proto.AgentConfig, []error)
- func (m *Manager) Handle(cmd *proto.Cmd) *proto.Reply
- func (m *Manager) Sender() *Sender
- func (m *Manager) Spooler() Spooler
- func (m *Manager) Start() error
- func (m *Manager) Status() map[string]string
- func (m *Manager) Stop() error
type Sender
- func NewSender(logger *pct.Logger, client pct.WebsocketClient) *Sender
- func (s *Sender) Start(spool Spooler, tickerChan <-chan time.Time, blackhole bool) error
- func (s *Sender) Status() map[string]string
- func (s *Sender) Stop() error
type Serializer
type Spooler

Constants ¶

View Source

const (
	DEFAULT_DATA_ENCODING      = ""
	DEFAULT_DATA_SEND_INTERVAL = 63
)

View Source

const (
	WRITE_BUFFER = 100
	CACHE_SIZE   = 1024 * 1024 * 8 // 8M
)

Variables ¶

View Source

var ErrSpoolTimeout = errors.New("Timeout spooling data")

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	Encoding     string
	SendInterval int
	Blackhole    bool
}

type DiskvSpooler ¶

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

http://godoc.org/github.com/peterbourgon/diskv

func NewDiskvSpooler ¶

func NewDiskvSpooler(logger *pct.Logger, dataDir string, hostname string) *DiskvSpooler

func (*DiskvSpooler) Files ¶

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

func (*DiskvSpooler) Read ¶

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

func (*DiskvSpooler) Remove ¶

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

func (*DiskvSpooler) Start ¶

func (s *DiskvSpooler) Start(sz Serializer) error

func (*DiskvSpooler) Status ¶

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

func (*DiskvSpooler) Stop ¶

func (s *DiskvSpooler) Stop() error

func (*DiskvSpooler) Write ¶

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

type JsonGzipSerializer ¶

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

func NewJsonGzipSerializer ¶

func NewJsonGzipSerializer() *JsonGzipSerializer

func (*JsonGzipSerializer) Concurrent ¶

func (s *JsonGzipSerializer) Concurrent() bool

func (*JsonGzipSerializer) Encoding ¶

func (s *JsonGzipSerializer) Encoding() string

func (*JsonGzipSerializer) ToBytes ¶

func (s *JsonGzipSerializer) ToBytes(data interface{}) ([]byte, error)

type JsonSerializer ¶

type JsonSerializer struct {
}

func NewJsonSerializer ¶

func NewJsonSerializer() *JsonSerializer

func (*JsonSerializer) Concurrent ¶

func (s *JsonSerializer) Concurrent() bool

func (*JsonSerializer) Encoding ¶

func (s *JsonSerializer) Encoding() string

func (*JsonSerializer) ToBytes ¶

func (j *JsonSerializer) ToBytes(data interface{}) ([]byte, error)

type Manager ¶

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

func NewManager ¶

func NewManager(logger *pct.Logger, dataDir string, hostname string, client pct.WebsocketClient) *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) Sender ¶

func (m *Manager) Sender() *Sender

func (*Manager) Spooler ¶

func (m *Manager) Spooler() Spooler

func (*Manager) Start ¶

func (m *Manager) Start() error

@goroutine[0]

func (*Manager) Status ¶

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

@goroutine[0:1]

func (*Manager) Stop ¶

func (m *Manager) Stop() error

@goroutine[0]

type Sender ¶

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

func NewSender ¶

func NewSender(logger *pct.Logger, client pct.WebsocketClient) *Sender

func (*Sender) Start ¶

func (s *Sender) Start(spool Spooler, tickerChan <-chan time.Time, blackhole bool) error

func (*Sender) Status ¶

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

func (*Sender) Stop ¶

func (s *Sender) Stop() error

type Serializer ¶

type Serializer interface {
	ToBytes(data interface{}) ([]byte, error)
	Encoding() string
	Concurrent() bool
}

type Spooler ¶

type Spooler interface {
	Start(Serializer) error
	Stop() error
	Status() map[string]string
	Write(service string, data interface{}) error
	Files() <-chan string
	Read(key string) ([]byte, error)
	Remove(key string) error
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL