core

type Local ¶

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

func NewLocal(s string) (*Local, error)

func (l *Local) Serve()

type LocalCmd ¶

type LocalCmd struct {
	Sync    bool            `json:"sync"`
	Content json.RawMessage `json:"content"`
}

type LocalResult ¶

type LocalResult struct {
	State  string          `json:"state"`
	Error  string          `json:"error,omitempty"`
	Result *core.JobResult `json:"result,omitempty"`
}

type Sink ¶

type Sink interface {
	Run()
}

func NewSink(key string, mgr *pm.PM, client SinkClient) Sink

type SinkClient ¶

type SinkClient interface {
	GetNext(command *core.Command) error
	Respond(result *core.JobResult) error
}

func NewSinkClient(cfg *settings.SinkConfig, id string, responseQueue ...string) (SinkClient, error)

type StatsFlusher ¶

type StatsFlusher interface {
	Handler(stats *stats.Stats)
}

StatsBuffer implements a buffering and flushing mechanism to buffer statsd messages that are collected via the process manager. Flush happens when buffer is full or a certain time passes since last flush.

The StatsBuffer.Handler should be registers as StatsFlushHandler on the process manager object.

func NewRedisStatsBuffer(address string, password string, capacity int, flushInt time.Duration) StatsFlusher