Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

loggregator

package module

Go to main page

Versions in this module

v9

v9.2.1

Apr 19, 2024

v9.2.0

Jan 24, 2024

v9.1.0

Dec 26, 2023

v9.0.8

Sep 18, 2023

v9.0.7

Jul 10, 2023

v9.0.6

Jun 16, 2023

v9.0.5

May 9, 2023

v9.0.4

Feb 24, 2023

v9.0.3

Oct 17, 2022

v9.0.2

Jun 30, 2022

v9.0.1

Jun 29, 2022

v9.0.0

Jun 28, 2022

Changes in this version

+ func NewEgressTLSConfig(caPath, certPath, keyPath string) (*tls.Config, error)

+ func NewIngressTLSConfig(caPath, certPath, keyPath string) (*tls.Config, error)

+ func WithEnvelopeTag(name, value string) func(proto.Message)

+ func WithEnvelopeTags(tags map[string]string) func(proto.Message)

+ type Doer interface

+ Do func(*http.Request) (*http.Response, error)

+ type EmitCounterOption func(proto.Message)

+ func WithCounterAppInfo(appID string, index int) EmitCounterOption

+ func WithCounterSourceInfo(sourceID, instanceID string) EmitCounterOption

+ func WithDelta(d uint64) EmitCounterOption

+ func WithTotal(t uint64) EmitCounterOption

+ type EmitEventOption func(proto.Message)

+ func WithEventSourceInfo(sourceID, instanceID string) EmitEventOption

+ type EmitGaugeOption func(proto.Message)

+ func WithGaugeAppInfo(appID string, index int) EmitGaugeOption

+ func WithGaugeSourceInfo(sourceID, instanceID string) EmitGaugeOption

+ func WithGaugeValue(name string, value float64, unit string) EmitGaugeOption

+ type EmitLogOption func(proto.Message)

+ func WithAppInfo(appID, sourceType, sourceInstance string) EmitLogOption

+ func WithSourceInfo(sourceID, sourceType, sourceInstance string) EmitLogOption

+ func WithStdout() EmitLogOption

+ type EmitTimerOption func(proto.Message)

+ func WithTimerSourceInfo(sourceID, instanceID string) EmitTimerOption

+ type EnvelopeStream func() []*loggregator_v2.Envelope

+ type EnvelopeStreamConnector struct

+ func NewEnvelopeStreamConnector(addr string, t *tls.Config, opts ...EnvelopeStreamOption) *EnvelopeStreamConnector

+ func (c *EnvelopeStreamConnector) Stream(ctx context.Context, req *loggregator_v2.EgressBatchRequest) EnvelopeStream

+ type EnvelopeStreamOption func(*EnvelopeStreamConnector)

+ func WithEnvelopeStreamBuffer(size int, alerter func(missed int)) EnvelopeStreamOption

+ func WithEnvelopeStreamConnectorDialOptions(opts ...grpc.DialOption) EnvelopeStreamOption

+ func WithEnvelopeStreamLogger(l Logger) EnvelopeStreamOption

+ type GatewayLogger interface

+ Panicf func(format string, v ...interface{})

+ Printf func(format string, v ...interface{})

+ type IngressClient struct

+ func NewIngressClient(tlsConfig *tls.Config, opts ...IngressOption) (*IngressClient, error)

+ func (c *IngressClient) CloseSend() error

+ func (c *IngressClient) Emit(e *loggregator_v2.Envelope)

+ func (c *IngressClient) EmitCounter(name string, opts ...EmitCounterOption)

+ func (c *IngressClient) EmitEvent(ctx context.Context, title, body string, opts ...EmitEventOption) error

+ func (c *IngressClient) EmitGauge(opts ...EmitGaugeOption)

+ func (c *IngressClient) EmitLog(message string, opts ...EmitLogOption)

+ func (c *IngressClient) EmitTimer(name string, start, stop time.Time, opts ...EmitTimerOption)

+ type IngressOption func(*IngressClient)

+ func WithAddr(addr string) IngressOption

+ func WithBatchFlushInterval(d time.Duration) IngressOption

+ func WithBatchMaxSize(maxSize uint) IngressOption

+ func WithContext(ctx context.Context) IngressOption

+ func WithDialOptions(opts ...grpc.DialOption) IngressOption

+ func WithLogger(l Logger) IngressOption

+ func WithTag(name, value string) IngressOption

+ type Logger interface

+ Panicf func(string, ...interface{})

+ Printf func(string, ...interface{})

+ type OneToOneEnvelopeBatch struct

+ func NewOneToOneEnvelopeBatch(size int, alerter gendiodes.Alerter, opts ...gendiodes.PollerConfigOption) *OneToOneEnvelopeBatch

+ func (d *OneToOneEnvelopeBatch) Next() []*loggregator_v2.Envelope

+ func (d *OneToOneEnvelopeBatch) Set(data []*loggregator_v2.Envelope)

+ func (d *OneToOneEnvelopeBatch) TryNext() ([]*loggregator_v2.Envelope, bool)

+ type RLPGatewayClient struct

+ func NewRLPGatewayClient(addr string, opts ...RLPGatewayClientOption) *RLPGatewayClient

+ func (c *RLPGatewayClient) Stream(ctx context.Context, req *loggregator_v2.EgressBatchRequest) EnvelopeStream

+ type RLPGatewayClientOption func(*RLPGatewayClient)

+ func WithRLPGatewayClientLogger(log GatewayLogger) RLPGatewayClientOption

+ func WithRLPGatewayErrChan(errChan chan error) RLPGatewayClientOption

+ func WithRLPGatewayHTTPClient(d Doer) RLPGatewayClientOption

+ func WithRLPGatewayMaxRetries(r int) RLPGatewayClientOption

Other modules containing this package

code.cloudfoundry.org/go-loggregator

code.cloudfoundry.org/go-loggregator/v10

code.cloudfoundry.org/go-loggregator/v8