cache

Documentation

Index

• type Cache
  • func New() *Cache
  • func (c *Cache) Add(p *points.Points)
  • func (c *Cache) Confirm() chan *points.Points
  • func (c *Cache) Dump(w io.Writer) error
  • func (c *Cache) Get() *points.Points
  • func (c *Cache) In() chan *points.Points
  • func (c *Cache) Out() chan *points.Points
  • func (c *Cache) Pop() *points.Points
  • func (c *Cache) Query() chan *Query
  • func (c *Cache) Remove(key string, size int)
  • func (c *Cache) SetInputCapacity(size int)
  • func (c *Cache) SetMaxSize(maxSize uint32)
  • func (c *Cache) SetOutputChanSize(size int)
  • func (c *Cache) SetWriteStrategy(s string) (err error)
  • func (c *Cache) Size() uint32
  • func (c *Cache) Start() error
  • func (c *Cache) Stat(send helper.StatCallback)
• type CarbonlinkListener
  • func NewCarbonlinkListener(queryChan chan *Query) *CarbonlinkListener
  • func (listener *CarbonlinkListener) Addr() net.Addr
  • func (listener *CarbonlinkListener) HandleConnection(conn framing.Conn)
  • func (listener *CarbonlinkListener) Listen(addr *net.TCPAddr) error
  • func (listener *CarbonlinkListener) SetQueryTimeout(timeout time.Duration)
  • func (listener *CarbonlinkListener) SetReadTimeout(timeout time.Duration)
• type CarbonlinkRequest
  • func NewCarbonlinkRequest() *CarbonlinkRequest
  • func ParseCarbonlinkRequest(d []byte) (*CarbonlinkRequest, error)
• type Query
  • func NewQuery(metric string) *Query
• type WriteStrategy

Types

type Cache

type Cache struct {
	helper.Stoppable
	// contains filtered or unexported fields
}

Cache stores and aggregate metrics in memory

func New

func New() *Cache

New create Cache instance and run in/out goroutine

func (*Cache) Add

func (c *Cache) Add(p *points.Points)

Add points to cache

func (*Cache) Confirm

func (c *Cache) Confirm() chan *points.Points

Confirm returns confirmation channel for persister

func (*Cache) Dump

func (c *Cache) Dump(w io.Writer) error

Dump all cache to writer

func (*Cache) Get

func (c *Cache) Get() *points.Points

Get any key/values pair from Cache

func (*Cache) In

func (c *Cache) In() chan *points.Points

In returns input channel

func (*Cache) Out

func (c *Cache) Out() chan *points.Points

Out returns output channel

func (*Cache) Pop

func (c *Cache) Pop() *points.Points

Pop return and remove next for save point from cache

func (*Cache) Query

func (c *Cache) Query() chan *Query

Query returns carbonlink query channel

func (*Cache) Remove

func (c *Cache) Remove(key string, size int)

Remove key from cache

func (*Cache) SetInputCapacity

func (c *Cache) SetInputCapacity(size int)

SetInputCapacity set buffer size of input channel. Call before In() getter

func (*Cache) SetMaxSize

func (c *Cache) SetMaxSize(maxSize uint32)

SetMaxSize of cache

func (*Cache) SetOutputChanSize

func (c *Cache) SetOutputChanSize(size int)

SetOutputChanSize ...

func (*Cache) SetWriteStrategy

func (c *Cache) SetWriteStrategy(s string) (err error)

SetWriteStrategy ...

func (*Cache) Size

func (c *Cache) Size() uint32

Size returns size

func (*Cache) Start

func (c *Cache) Start() error

Start worker

func (*Cache) Stat

func (c *Cache) Stat(send helper.StatCallback)

Collect cache metrics

type CarbonlinkListener

type CarbonlinkListener struct {
	helper.Stoppable
	// contains filtered or unexported fields
}

CarbonlinkListener receive cache Carbonlinkrequests from graphite-web

func NewCarbonlinkListener

func NewCarbonlinkListener(queryChan chan *Query) *CarbonlinkListener

NewCarbonlinkListener create new instance of CarbonlinkListener

func (*CarbonlinkListener) Addr

func (listener *CarbonlinkListener) Addr() net.Addr

Addr returns binded socket address. For bind port 0 in tests

func (*CarbonlinkListener) HandleConnection

func (listener *CarbonlinkListener) HandleConnection(conn framing.Conn)

func (*CarbonlinkListener) Listen

func (listener *CarbonlinkListener) Listen(addr *net.TCPAddr) error

Listen bind port. Receive messages and send to out channel

func (*CarbonlinkListener) SetQueryTimeout

func (listener *CarbonlinkListener) SetQueryTimeout(timeout time.Duration)

SetQueryTimeout for queries to cache

func (*CarbonlinkListener) SetReadTimeout

func (listener *CarbonlinkListener) SetReadTimeout(timeout time.Duration)

SetReadTimeout for read request from client

type CarbonlinkRequest

type CarbonlinkRequest struct {
	Type   string
	Metric string
	Key    string
	Value  string
}

CarbonlinkRequest ...

func NewCarbonlinkRequest

func NewCarbonlinkRequest() *CarbonlinkRequest

NewCarbonlinkRequest creates instance of CarbonlinkRequest

func ParseCarbonlinkRequest

func ParseCarbonlinkRequest(d []byte) (*CarbonlinkRequest, error)

ParseCarbonlinkRequest from pickle encoded data

type Query

type Query struct {
	Metric       string
	Wait         chan bool        // close after finish collect reply
	CacheData    *points.Points   // from cache
	InFlightData []*points.Points // from confirm tracker
}

Query request from carbonlink

func NewQuery

func NewQuery(metric string) *Query

NewQuery create Query instance

type WriteStrategy

type WriteStrategy int

const (
	MaximumLength WriteStrategy = iota
	TimestampOrder
	Noop
)