v2

Documentation

Index

• func EmitAppLog(logClient LogClient, message string, appID string)
• type DataSetter
• type FilteringSetter
  • func NewFilteringSetter(s setter) *FilteringSetter
  • func (fs *FilteringSetter) Set(e *loggregator_v2.Envelope)
• type LogClient
• 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()

Functions

func EmitAppLog

func EmitAppLog(logClient LogClient, message string, appID string)

EmitAppLog writes a message in the application log stream using a LogClient.

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 LogClient

type LogClient interface {
	EmitLog(message string, opts ...loggregator.EmitLogOption)
}

LogClient is used to emit logs - i.e. Ingress Client.

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