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_v2

package

Go to main page

Versions in this module

v8

v8.0.5

Jun 17, 2021

v8.0.3

Aug 4, 2020

v8.0.2

Jul 22, 2020

v8.0.1

Jun 3, 2020

v8.0.0

Mar 30, 2020

Changes in this version

+ var Log_Type_name = map[int32]string

+ var Log_Type_value = map[string]int32

+ func RegisterEgressServer(s *grpc.Server, srv EgressServer)

+ func RegisterIngressServer(s *grpc.Server, srv IngressServer)

+ type BatchSenderResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BatchSenderResponse) Descriptor() ([]byte, []int)

+ func (*BatchSenderResponse) ProtoMessage()

+ func (dst *BatchSenderResponse) XXX_Merge(src proto.Message)

+ func (m *BatchSenderResponse) Reset()

+ func (m *BatchSenderResponse) String() string

+ func (m *BatchSenderResponse) XXX_DiscardUnknown()

+ func (m *BatchSenderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BatchSenderResponse) XXX_Size() int

+ func (m *BatchSenderResponse) XXX_Unmarshal(b []byte) error

+ type Counter struct

+ Delta uint64

+ Name string

+ Total uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Counter) Descriptor() ([]byte, []int)

+ func (*Counter) ProtoMessage()

+ func (dst *Counter) XXX_Merge(src proto.Message)

+ func (m *Counter) GetDelta() uint64

+ func (m *Counter) GetName() string

+ func (m *Counter) GetTotal() uint64

+ func (m *Counter) Reset()

+ func (m *Counter) String() string

+ func (m *Counter) XXX_DiscardUnknown()

+ func (m *Counter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Counter) XXX_Size() int

+ func (m *Counter) XXX_Unmarshal(b []byte) error

+ type CounterSelector struct

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CounterSelector) Descriptor() ([]byte, []int)

+ func (*CounterSelector) ProtoMessage()

+ func (dst *CounterSelector) XXX_Merge(src proto.Message)

+ func (m *CounterSelector) GetName() string

+ func (m *CounterSelector) Reset()

+ func (m *CounterSelector) String() string

+ func (m *CounterSelector) XXX_DiscardUnknown()

+ func (m *CounterSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CounterSelector) XXX_Size() int

+ func (m *CounterSelector) XXX_Unmarshal(b []byte) error

+ type EgressBatchRequest struct

+ DeterministicName string

+ LegacySelector *Selector

+ Selectors []*Selector

+ ShardId string

+ UsePreferredTags bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EgressBatchRequest) Descriptor() ([]byte, []int)

+ func (*EgressBatchRequest) ProtoMessage()

+ func (dst *EgressBatchRequest) XXX_Merge(src proto.Message)

+ func (m *EgressBatchRequest) GetDeterministicName() string

+ func (m *EgressBatchRequest) GetLegacySelector() *Selector

+ func (m *EgressBatchRequest) GetSelectors() []*Selector

+ func (m *EgressBatchRequest) GetShardId() string

+ func (m *EgressBatchRequest) GetUsePreferredTags() bool

+ func (m *EgressBatchRequest) Reset()

+ func (m *EgressBatchRequest) String() string

+ func (m *EgressBatchRequest) XXX_DiscardUnknown()

+ func (m *EgressBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EgressBatchRequest) XXX_Size() int

+ func (m *EgressBatchRequest) XXX_Unmarshal(b []byte) error

+ type EgressClient interface

+ BatchedReceiver func(ctx context.Context, in *EgressBatchRequest, opts ...grpc.CallOption) (Egress_BatchedReceiverClient, error)

+ Receiver func(ctx context.Context, in *EgressRequest, opts ...grpc.CallOption) (Egress_ReceiverClient, error)

+ func NewEgressClient(cc *grpc.ClientConn) EgressClient

+ type EgressRequest struct

+ DeterministicName string

+ LegacySelector *Selector

+ Selectors []*Selector

+ ShardId string

+ UsePreferredTags bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EgressRequest) Descriptor() ([]byte, []int)

+ func (*EgressRequest) ProtoMessage()

+ func (dst *EgressRequest) XXX_Merge(src proto.Message)

+ func (m *EgressRequest) GetDeterministicName() string

+ func (m *EgressRequest) GetLegacySelector() *Selector

+ func (m *EgressRequest) GetSelectors() []*Selector

+ func (m *EgressRequest) GetShardId() string

+ func (m *EgressRequest) GetUsePreferredTags() bool

+ func (m *EgressRequest) Reset()

+ func (m *EgressRequest) String() string

+ func (m *EgressRequest) XXX_DiscardUnknown()

+ func (m *EgressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EgressRequest) XXX_Size() int

+ func (m *EgressRequest) XXX_Unmarshal(b []byte) error

+ type EgressServer interface

+ BatchedReceiver func(*EgressBatchRequest, Egress_BatchedReceiverServer) error

+ Receiver func(*EgressRequest, Egress_ReceiverServer) error

+ type Egress_BatchedReceiverClient interface

+ Recv func() (*EnvelopeBatch, error)

+ type Egress_BatchedReceiverServer interface

+ Send func(*EnvelopeBatch) error

+ type Egress_ReceiverClient interface

+ Recv func() (*Envelope, error)

+ type Egress_ReceiverServer interface

+ Send func(*Envelope) error

+ type Envelope struct

+ DeprecatedTags map[string]*Value

+ InstanceId string

+ Message isEnvelope_Message

+ SourceId string

+ Tags map[string]string

+ Timestamp int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Envelope) Descriptor() ([]byte, []int)

+ func (*Envelope) ProtoMessage()

+ func (*Envelope) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *Envelope) XXX_Merge(src proto.Message)

+ func (m *Envelope) GetCounter() *Counter

+ func (m *Envelope) GetDeprecatedTags() map[string]*Value

+ func (m *Envelope) GetEvent() *Event

+ func (m *Envelope) GetGauge() *Gauge

+ func (m *Envelope) GetInstanceId() string

+ func (m *Envelope) GetLog() *Log

+ func (m *Envelope) GetMessage() isEnvelope_Message

+ func (m *Envelope) GetSourceId() string

+ func (m *Envelope) GetTags() map[string]string

+ func (m *Envelope) GetTimer() *Timer

+ func (m *Envelope) GetTimestamp() int64

+ func (m *Envelope) Reset()

+ func (m *Envelope) String() string

+ func (m *Envelope) Syslog(opts ...SyslogOption) ([][]byte, error)

+ func (m *Envelope) XXX_DiscardUnknown()

+ func (m *Envelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Envelope) XXX_Size() int

+ func (m *Envelope) XXX_Unmarshal(b []byte) error

+ type EnvelopeBatch struct

+ Batch []*Envelope

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EnvelopeBatch) Descriptor() ([]byte, []int)

+ func (*EnvelopeBatch) ProtoMessage()

+ func (dst *EnvelopeBatch) XXX_Merge(src proto.Message)

+ func (m *EnvelopeBatch) GetBatch() []*Envelope

+ func (m *EnvelopeBatch) Reset()

+ func (m *EnvelopeBatch) String() string

+ func (m *EnvelopeBatch) XXX_DiscardUnknown()

+ func (m *EnvelopeBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EnvelopeBatch) XXX_Size() int

+ func (m *EnvelopeBatch) XXX_Unmarshal(b []byte) error

+ type Envelope_Counter struct

+ Counter *Counter

+ type Envelope_Event struct

+ Event *Event

+ type Envelope_Gauge struct

+ Gauge *Gauge

+ type Envelope_Log struct

+ Log *Log

+ type Envelope_Timer struct

+ Timer *Timer

+ type Event struct

+ Body string

+ Title string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Event) Descriptor() ([]byte, []int)

+ func (*Event) ProtoMessage()

+ func (dst *Event) XXX_Merge(src proto.Message)

+ func (m *Event) GetBody() string

+ func (m *Event) GetTitle() string

+ func (m *Event) Reset()

+ func (m *Event) String() string

+ func (m *Event) XXX_DiscardUnknown()

+ func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Event) XXX_Size() int

+ func (m *Event) XXX_Unmarshal(b []byte) error

+ type EventSelector struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EventSelector) Descriptor() ([]byte, []int)

+ func (*EventSelector) ProtoMessage()

+ func (dst *EventSelector) XXX_Merge(src proto.Message)

+ func (m *EventSelector) Reset()

+ func (m *EventSelector) String() string

+ func (m *EventSelector) XXX_DiscardUnknown()

+ func (m *EventSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventSelector) XXX_Size() int

+ func (m *EventSelector) XXX_Unmarshal(b []byte) error

+ type Gauge struct

+ Metrics map[string]*GaugeValue

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Gauge) Descriptor() ([]byte, []int)

+ func (*Gauge) ProtoMessage()

+ func (dst *Gauge) XXX_Merge(src proto.Message)

+ func (m *Gauge) GetMetrics() map[string]*GaugeValue

+ func (m *Gauge) Reset()

+ func (m *Gauge) String() string

+ func (m *Gauge) XXX_DiscardUnknown()

+ func (m *Gauge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Gauge) XXX_Size() int

+ func (m *Gauge) XXX_Unmarshal(b []byte) error

+ type GaugeSelector struct

+ Names []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GaugeSelector) Descriptor() ([]byte, []int)

+ func (*GaugeSelector) ProtoMessage()

+ func (dst *GaugeSelector) XXX_Merge(src proto.Message)

+ func (m *GaugeSelector) GetNames() []string

+ func (m *GaugeSelector) Reset()

+ func (m *GaugeSelector) String() string

+ func (m *GaugeSelector) XXX_DiscardUnknown()

+ func (m *GaugeSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GaugeSelector) XXX_Size() int

+ func (m *GaugeSelector) XXX_Unmarshal(b []byte) error

+ type GaugeValue struct

+ Unit string

+ Value float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GaugeValue) Descriptor() ([]byte, []int)

+ func (*GaugeValue) ProtoMessage()

+ func (dst *GaugeValue) XXX_Merge(src proto.Message)

+ func (m *GaugeValue) GetUnit() string

+ func (m *GaugeValue) GetValue() float64

+ func (m *GaugeValue) Reset()

+ func (m *GaugeValue) String() string

+ func (m *GaugeValue) XXX_DiscardUnknown()

+ func (m *GaugeValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GaugeValue) XXX_Size() int

+ func (m *GaugeValue) XXX_Unmarshal(b []byte) error

+ type IngressClient interface

+ BatchSender func(ctx context.Context, opts ...grpc.CallOption) (Ingress_BatchSenderClient, error)

+ Send func(ctx context.Context, in *EnvelopeBatch, opts ...grpc.CallOption) (*SendResponse, error)

+ Sender func(ctx context.Context, opts ...grpc.CallOption) (Ingress_SenderClient, error)

+ func NewIngressClient(cc *grpc.ClientConn) IngressClient

+ type IngressResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IngressResponse) Descriptor() ([]byte, []int)

+ func (*IngressResponse) ProtoMessage()

+ func (dst *IngressResponse) XXX_Merge(src proto.Message)

+ func (m *IngressResponse) Reset()

+ func (m *IngressResponse) String() string

+ func (m *IngressResponse) XXX_DiscardUnknown()

+ func (m *IngressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IngressResponse) XXX_Size() int

+ func (m *IngressResponse) XXX_Unmarshal(b []byte) error

+ type IngressServer interface

+ BatchSender func(Ingress_BatchSenderServer) error

+ Send func(context.Context, *EnvelopeBatch) (*SendResponse, error)

+ Sender func(Ingress_SenderServer) error

+ type Ingress_BatchSenderClient interface

+ CloseAndRecv func() (*BatchSenderResponse, error)

+ Send func(*EnvelopeBatch) error

+ type Ingress_BatchSenderServer interface

+ Recv func() (*EnvelopeBatch, error)

+ SendAndClose func(*BatchSenderResponse) error

+ type Ingress_SenderClient interface

+ CloseAndRecv func() (*IngressResponse, error)

+ Send func(*Envelope) error

+ type Ingress_SenderServer interface

+ Recv func() (*Envelope, error)

+ SendAndClose func(*IngressResponse) error

+ type Log struct

+ Payload []byte

+ Type Log_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Log) Descriptor() ([]byte, []int)

+ func (*Log) ProtoMessage()

+ func (dst *Log) XXX_Merge(src proto.Message)

+ func (m *Log) GetPayload() []byte

+ func (m *Log) GetType() Log_Type

+ func (m *Log) Reset()

+ func (m *Log) String() string

+ func (m *Log) XXX_DiscardUnknown()

+ func (m *Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Log) XXX_Size() int

+ func (m *Log) XXX_Unmarshal(b []byte) error

+ type LogSelector struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogSelector) Descriptor() ([]byte, []int)

+ func (*LogSelector) ProtoMessage()

+ func (dst *LogSelector) XXX_Merge(src proto.Message)

+ func (m *LogSelector) Reset()

+ func (m *LogSelector) String() string

+ func (m *LogSelector) XXX_DiscardUnknown()

+ func (m *LogSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogSelector) XXX_Size() int

+ func (m *LogSelector) XXX_Unmarshal(b []byte) error

+ type Log_Type int32

+ const Log_ERR

+ const Log_OUT

+ func (Log_Type) EnumDescriptor() ([]byte, []int)

+ func (x Log_Type) String() string

+ type Selector struct

+ Message isSelector_Message

+ SourceId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Selector) Descriptor() ([]byte, []int)

+ func (*Selector) ProtoMessage()

+ func (*Selector) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *Selector) XXX_Merge(src proto.Message)

+ func (m *Selector) GetCounter() *CounterSelector

+ func (m *Selector) GetEvent() *EventSelector

+ func (m *Selector) GetGauge() *GaugeSelector

+ func (m *Selector) GetLog() *LogSelector

+ func (m *Selector) GetMessage() isSelector_Message

+ func (m *Selector) GetSourceId() string

+ func (m *Selector) GetTimer() *TimerSelector

+ func (m *Selector) Reset()

+ func (m *Selector) String() string

+ func (m *Selector) XXX_DiscardUnknown()

+ func (m *Selector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Selector) XXX_Size() int

+ func (m *Selector) XXX_Unmarshal(b []byte) error

+ type Selector_Counter struct

+ Counter *CounterSelector

+ type Selector_Event struct

+ Event *EventSelector

+ type Selector_Gauge struct

+ Gauge *GaugeSelector

+ type Selector_Log struct

+ Log *LogSelector

+ type Selector_Timer struct

+ Timer *TimerSelector

+ type SendResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SendResponse) Descriptor() ([]byte, []int)

+ func (*SendResponse) ProtoMessage()

+ func (dst *SendResponse) XXX_Merge(src proto.Message)

+ func (m *SendResponse) Reset()

+ func (m *SendResponse) String() string

+ func (m *SendResponse) XXX_DiscardUnknown()

+ func (m *SendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SendResponse) XXX_Size() int

+ func (m *SendResponse) XXX_Unmarshal(b []byte) error

+ type SyslogOption func(*syslogConfig)

+ func WithSyslogAppName(appName string) SyslogOption

+ func WithSyslogHostname(hostname string) SyslogOption

+ func WithSyslogProcessID(processID string) SyslogOption

+ type Timer struct

+ Name string

+ Start int64

+ Stop int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Timer) Descriptor() ([]byte, []int)

+ func (*Timer) ProtoMessage()

+ func (dst *Timer) XXX_Merge(src proto.Message)

+ func (m *Timer) GetName() string

+ func (m *Timer) GetStart() int64

+ func (m *Timer) GetStop() int64

+ func (m *Timer) Reset()

+ func (m *Timer) String() string

+ func (m *Timer) XXX_DiscardUnknown()

+ func (m *Timer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Timer) XXX_Size() int

+ func (m *Timer) XXX_Unmarshal(b []byte) error

+ type TimerSelector struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TimerSelector) Descriptor() ([]byte, []int)

+ func (*TimerSelector) ProtoMessage()

+ func (dst *TimerSelector) XXX_Merge(src proto.Message)

+ func (m *TimerSelector) Reset()

+ func (m *TimerSelector) String() string

+ func (m *TimerSelector) XXX_DiscardUnknown()

+ func (m *TimerSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TimerSelector) XXX_Size() int

+ func (m *TimerSelector) XXX_Unmarshal(b []byte) error

+ type Value struct

+ Data isValue_Data

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Value) Descriptor() ([]byte, []int)

+ func (*Value) ProtoMessage()

+ func (*Value) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *Value) XXX_Merge(src proto.Message)

+ func (m *Value) GetData() isValue_Data

+ func (m *Value) GetDecimal() float64

+ func (m *Value) GetInteger() int64

+ func (m *Value) GetText() string

+ func (m *Value) Reset()

+ func (m *Value) String() string

+ func (m *Value) XXX_DiscardUnknown()

+ func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Value) XXX_Size() int

+ func (m *Value) XXX_Unmarshal(b []byte) error

+ type Value_Decimal struct

+ Decimal float64

+ type Value_Integer struct

+ Integer int64

+ type Value_Text struct

+ Text string

Other modules containing this package

code.cloudfoundry.org/go-loggregator

code.cloudfoundry.org/go-loggregator/v10

code.cloudfoundry.org/go-loggregator/v9