Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DataSetter

type DataSetter interface {
	Set(e *loggregator_v2.Envelope)
}

type MetricClient

type MetricClient interface {
	NewCounter(name string, opts ...metrics.MetricOption) metrics.Counter
}

    MetricClient creates new CounterMetrics to be emitted periodically.

    type Receiver

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

    func NewReceiver

    func NewReceiver(setter DataSetter, ingress metrics.Counter, egress metrics.Counter) *Receiver

    func (*Receiver) BatchSender

    func (s *Receiver) BatchSender(sender loggregator_v2.Ingress_BatchSenderServer) error

    func (*Receiver) Sender

    type Server

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

    func NewServer

    func NewServer(addr string, rx *Receiver, opts ...grpc.ServerOption) *Server

    func (*Server) Start

    func (s *Server) Start()