v2

package
v0.0.0-...-ba3aa93 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 15, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

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 FilteringSetter

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

func NewFilteringSetter

func NewFilteringSetter(s setter) *FilteringSetter

func (*FilteringSetter) Set

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

func (*Server) Stop

func (s *Server) Stop()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL