api

Documentation

Index

• type Api
  • func New(c *cache.Cache) *Api
  • func (api *Api) Addr() net.Addr
  • func (api *Api) CacheQuery(ctx context.Context, req *carbonpb.CacheRequest) (*carbonpb.Payload, error)
  • func (api *Api) Listen(addr *net.TCPAddr) error
  • func (api *Api) Stat(send helper.StatCallback)

Types

type Api

type Api struct {
	stop.Struct
	// contains filtered or unexported fields
}

Api receive metrics from GRPC connections

func New

func New(c *cache.Cache) *Api

func (*Api) Addr

func (api *Api) Addr() net.Addr

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

func (*Api) CacheQuery

func (api *Api) CacheQuery(ctx context.Context, req *carbonpb.CacheRequest) (*carbonpb.Payload, error)

func (*Api) Listen

func (api *Api) Listen(addr *net.TCPAddr) error

Listen bind port. Receive messages and send to out channel

func (*Api) Stat

func (api *Api) Stat(send helper.StatCallback)

Collect cache metrics