v2

Documentation

Index

• type DataSetter
• type FilteringSetter
  • func NewFilteringSetter(s setter) *FilteringSetter
  • func (fs *FilteringSetter) Set(e *loggregator_v2.Envelope)
• type MetricClient
• type Receiver
  • func NewReceiver(setter DataSetter, ingress metrics.Counter, egress metrics.Counter) *Receiver
  • func (s *Receiver) BatchSender(sender loggregator_v2.Ingress_BatchSenderServer) error
  • func (s *Receiver) Send(_ context.Context, b *loggregator_v2.EnvelopeBatch) (*loggregator_v2.SendResponse, error)
  • func (s *Receiver) Sender(sender loggregator_v2.Ingress_SenderServer) error
• type Server
  • func NewServer(addr string, rx *Receiver, opts ...grpc.ServerOption) *Server
  • func (s *Server) Start()
  • func (s *Server) Stop()

Types

type DataSetter

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

type FilteringSetter

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

func NewFilteringSetter

func NewFilteringSetter(s setter) *FilteringSetter

func (*FilteringSetter) Set

func (fs *FilteringSetter) Set(e *loggregator_v2.Envelope)

type MetricClient

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

MetricClient creates new CounterMetrics to be emitted periodically.

type Receiver

type Receiver struct {
	loggregator_v2.UnimplementedIngressServer
	// 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) Send

func (s *Receiver) Send(_ context.Context, b *loggregator_v2.EnvelopeBatch) (*loggregator_v2.SendResponse, error)

func (*Receiver) Sender

func (s *Receiver) Sender(sender loggregator_v2.Ingress_SenderServer) error

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()

func (*Server) Stop

func (s *Server) Stop()