loggregator_v2

package

Go to main page

Versions in this module

v1

v1.14.0

Apr 21, 2017

v1.13.0

Apr 17, 2017

v1.12.0

Apr 6, 2017

Changes in this version

+ var ErrIntOverflowEgress = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowEnvelope = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowIngress = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthEgress = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthEnvelope = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthIngress = fmt.Errorf("proto: negative length found during unmarshaling")

+ type Batcher interface

+ Send func() error

+ type ComponentClient interface

+ Batcher func() Batcher

+ IncrementCounter func(name string) error

+ type ComponentMetricsClient interface

+ SendBytesPerSecond func(name string, value float64) error

+ SendDuration func(name string, value time.Duration) error

+ SendMebiBytes func(name string, value int) error

+ SendMetric func(name string, value int) error

+ SendRequestsPerSecond func(name string, value float64) error

type Counter

+ func (m *Counter) Marshal() (dAtA []byte, err error)

+ func (m *Counter) MarshalTo(dAtA []byte) (int, error)

+ func (m *Counter) Size() (n int)

+ func (m *Counter) Unmarshal(dAtA []byte) error

+ func (this *Counter) Equal(that interface{}) bool

+ func (this *Counter) GoString() string

type Counter_Delta

+ func (m *Counter_Delta) MarshalTo(dAtA []byte) (int, error)

+ func (m *Counter_Delta) Size() (n int)

+ func (this *Counter_Delta) Equal(that interface{}) bool

+ func (this *Counter_Delta) GoString() string

+ func (this *Counter_Delta) String() string

type Counter_Total

+ func (m *Counter_Total) MarshalTo(dAtA []byte) (int, error)

+ func (m *Counter_Total) Size() (n int)

+ func (this *Counter_Total) Equal(that interface{}) bool

+ func (this *Counter_Total) GoString() string

+ func (this *Counter_Total) String() string

type EgressRequest

+ func (m *EgressRequest) Marshal() (dAtA []byte, err error)

+ func (m *EgressRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *EgressRequest) Size() (n int)

+ func (m *EgressRequest) Unmarshal(dAtA []byte) error

+ func (this *EgressRequest) Equal(that interface{}) bool

+ func (this *EgressRequest) GoString() string

type Envelope

+ InstanceId string

+ func (m *Envelope) GetInstanceId() string

+ func (m *Envelope) Marshal() (dAtA []byte, err error)

+ func (m *Envelope) MarshalTo(dAtA []byte) (int, error)

+ func (m *Envelope) Size() (n int)

+ func (m *Envelope) Unmarshal(dAtA []byte) error

+ func (this *Envelope) Equal(that interface{}) bool

+ func (this *Envelope) GoString() string

type Envelope_Counter

+ func (m *Envelope_Counter) MarshalTo(dAtA []byte) (int, error)

+ func (m *Envelope_Counter) Size() (n int)

+ func (this *Envelope_Counter) Equal(that interface{}) bool

+ func (this *Envelope_Counter) GoString() string

+ func (this *Envelope_Counter) String() string

type Envelope_Gauge

+ func (m *Envelope_Gauge) MarshalTo(dAtA []byte) (int, error)

+ func (m *Envelope_Gauge) Size() (n int)

+ func (this *Envelope_Gauge) Equal(that interface{}) bool

+ func (this *Envelope_Gauge) GoString() string

+ func (this *Envelope_Gauge) String() string

type Envelope_Log

+ func (m *Envelope_Log) MarshalTo(dAtA []byte) (int, error)

+ func (m *Envelope_Log) Size() (n int)

+ func (this *Envelope_Log) Equal(that interface{}) bool

+ func (this *Envelope_Log) GoString() string

+ func (this *Envelope_Log) String() string

type Envelope_Timer

+ func (m *Envelope_Timer) MarshalTo(dAtA []byte) (int, error)

+ func (m *Envelope_Timer) Size() (n int)

+ func (this *Envelope_Timer) Equal(that interface{}) bool

+ func (this *Envelope_Timer) GoString() string

+ func (this *Envelope_Timer) String() string

type Filter

+ Message isFilter_Message

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

+ func (m *Filter) GetLog() *LogFilter

+ func (m *Filter) GetMessage() isFilter_Message

+ func (m *Filter) Marshal() (dAtA []byte, err error)

+ func (m *Filter) MarshalTo(dAtA []byte) (int, error)

+ func (m *Filter) Size() (n int)

+ func (m *Filter) Unmarshal(dAtA []byte) error

+ func (this *Filter) Equal(that interface{}) bool

+ func (this *Filter) GoString() string

+ type Filter_Log struct

+ Log *LogFilter

+ func (m *Filter_Log) MarshalTo(dAtA []byte) (int, error)

+ func (m *Filter_Log) Size() (n int)

+ func (this *Filter_Log) Equal(that interface{}) bool

+ func (this *Filter_Log) GoString() string

+ func (this *Filter_Log) String() string

type Gauge

+ func (m *Gauge) Marshal() (dAtA []byte, err error)

+ func (m *Gauge) MarshalTo(dAtA []byte) (int, error)

+ func (m *Gauge) Size() (n int)

+ func (m *Gauge) Unmarshal(dAtA []byte) error

+ func (this *Gauge) Equal(that interface{}) bool

+ func (this *Gauge) GoString() string

type GaugeValue

+ func (m *GaugeValue) Marshal() (dAtA []byte, err error)

+ func (m *GaugeValue) MarshalTo(dAtA []byte) (int, error)

+ func (m *GaugeValue) Size() (n int)

+ func (m *GaugeValue) Unmarshal(dAtA []byte) error

+ func (this *GaugeValue) Equal(that interface{}) bool

+ func (this *GaugeValue) GoString() string

type IngressResponse

+ func (m *IngressResponse) Marshal() (dAtA []byte, err error)

+ func (m *IngressResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *IngressResponse) Size() (n int)

+ func (m *IngressResponse) Unmarshal(dAtA []byte) error

+ func (this *IngressResponse) Equal(that interface{}) bool

+ func (this *IngressResponse) GoString() string

type Log

+ func (m *Log) Marshal() (dAtA []byte, err error)

+ func (m *Log) MarshalTo(dAtA []byte) (int, error)

+ func (m *Log) Size() (n int)

+ func (m *Log) Unmarshal(dAtA []byte) error

+ func (this *Log) Equal(that interface{}) bool

+ func (this *Log) GoString() string

+ type LogFilter struct

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

+ func (*LogFilter) ProtoMessage()

+ func (m *LogFilter) Marshal() (dAtA []byte, err error)

+ func (m *LogFilter) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogFilter) Reset()

+ func (m *LogFilter) Size() (n int)

+ func (m *LogFilter) Unmarshal(dAtA []byte) error

+ func (this *LogFilter) Equal(that interface{}) bool

+ func (this *LogFilter) GoString() string

+ func (this *LogFilter) String() string

type Log_Type

+ const ERR

+ const OUT

type Timer

+ func (m *Timer) Marshal() (dAtA []byte, err error)

+ func (m *Timer) MarshalTo(dAtA []byte) (int, error)

+ func (m *Timer) Size() (n int)

+ func (m *Timer) Unmarshal(dAtA []byte) error

+ func (this *Timer) Equal(that interface{}) bool

+ func (this *Timer) GoString() string

type Value

+ func (m *Value) Marshal() (dAtA []byte, err error)

+ func (m *Value) MarshalTo(dAtA []byte) (int, error)

+ func (m *Value) Size() (n int)

+ func (m *Value) Unmarshal(dAtA []byte) error

+ func (this *Value) Equal(that interface{}) bool

+ func (this *Value) GoString() string

type Value_Decimal

+ func (m *Value_Decimal) MarshalTo(dAtA []byte) (int, error)

+ func (m *Value_Decimal) Size() (n int)

+ func (this *Value_Decimal) Equal(that interface{}) bool

+ func (this *Value_Decimal) GoString() string

+ func (this *Value_Decimal) String() string

type Value_Integer

+ func (m *Value_Integer) MarshalTo(dAtA []byte) (int, error)

+ func (m *Value_Integer) Size() (n int)

+ func (this *Value_Integer) Equal(that interface{}) bool

+ func (this *Value_Integer) GoString() string

+ func (this *Value_Integer) String() string

type Value_Text

+ func (m *Value_Text) MarshalTo(dAtA []byte) (int, error)

+ func (m *Value_Text) Size() (n int)

+ func (this *Value_Text) Equal(that interface{}) bool

+ func (this *Value_Text) GoString() string

+ func (this *Value_Text) String() string

v1.11.0

Mar 28, 2017

v1.10.1

Mar 14, 2017

v1.10.0

Mar 9, 2017

Changes in this version

+ var Log_Type_name = map[int32]string

+ var Log_Type_value = map[string]int32

+ func NewGrpcClient(logger lager.Logger, config *MetronConfig, ingressClient IngressClient) *grpcClient

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

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

+ type Client interface

+ SendAppErrorLog func(appID, message, sourceType, sourceInstance string) error

+ SendAppLog func(appID, message, sourceType, sourceInstance string) error

+ SendAppMetrics func(metrics *events.ContainerMetric) error

+ func NewClient(logger lager.Logger, config MetronConfig) (Client, error)

+ type Connector func() (IngressClient, error)

+ type Counter struct

+ Name string

+ Value isCounter_Value

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

+ func (*Counter) ProtoMessage()

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

+ func (m *Counter) GetDelta() uint64

+ func (m *Counter) GetName() string

+ func (m *Counter) GetTotal() uint64

+ func (m *Counter) GetValue() isCounter_Value

+ func (m *Counter) Reset()

+ func (m *Counter) String() string

+ type Counter_Delta struct

+ Delta uint64

+ type Counter_Total struct

+ Total uint64

+ type EgressClient interface

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

+ func NewEgressClient(cc *grpc.ClientConn) EgressClient

+ type EgressRequest struct

+ Filter *Filter

+ ShardId string

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

+ func (*EgressRequest) ProtoMessage()

+ func (m *EgressRequest) GetFilter() *Filter

+ func (m *EgressRequest) GetShardId() string

+ func (m *EgressRequest) Reset()

+ func (m *EgressRequest) String() string

+ type EgressServer interface

+ Receiver func(*EgressRequest, Egress_ReceiverServer) error

+ type Egress_ReceiverClient interface

+ Recv func() (*Envelope, error)

+ type Egress_ReceiverServer interface

+ Send func(*Envelope) error

+ type Envelope struct

+ Message isEnvelope_Message

+ SourceId string

+ Tags map[string]*Value

+ Timestamp int64

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

+ func (*Envelope) ProtoMessage()

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

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

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

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

+ func (m *Envelope) GetMessage() isEnvelope_Message

+ func (m *Envelope) GetSourceId() string

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

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

+ func (m *Envelope) GetTimestamp() int64

+ func (m *Envelope) Reset()

+ func (m *Envelope) String() string

+ type Envelope_Counter struct

+ Counter *Counter

+ type Envelope_Gauge struct

+ Gauge *Gauge

+ type Envelope_Log struct

+ Log *Log

+ type Envelope_Timer struct

+ Timer *Timer

+ type Filter struct

+ SourceId string

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

+ func (*Filter) ProtoMessage()

+ func (m *Filter) GetSourceId() string

+ func (m *Filter) Reset()

+ func (m *Filter) String() string

+ type Gauge struct

+ Metrics map[string]*GaugeValue

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

+ func (*Gauge) ProtoMessage()

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

+ func (m *Gauge) Reset()

+ func (m *Gauge) String() string

+ type GaugeValue struct

+ Unit string

+ Value float64

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

+ func (*GaugeValue) ProtoMessage()

+ func (m *GaugeValue) GetUnit() string

+ func (m *GaugeValue) GetValue() float64

+ func (m *GaugeValue) Reset()

+ func (m *GaugeValue) String() string

+ type IngressClient interface

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

+ func NewIngressClient(cc *grpc.ClientConn) IngressClient

+ type IngressResponse struct

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

+ func (*IngressResponse) ProtoMessage()

+ func (m *IngressResponse) Reset()

+ func (m *IngressResponse) String() string

+ type IngressServer interface

+ Sender func(Ingress_SenderServer) 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

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

+ func (*Log) ProtoMessage()

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

+ func (m *Log) GetType() Log_Type

+ func (m *Log) Reset()

+ func (m *Log) String() string

+ type Log_Type int32

+ const Log_ERR

+ const Log_OUT

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

+ func (x Log_Type) String() string

+ type MetronConfig struct

+ APIPort int

+ CACertPath string

+ CertPath string

+ DropsondePort int

+ JobDeployment string

+ JobIP string

+ JobIndex string

+ JobName string

+ JobOrigin string

+ KeyPath string

+ UseV2API bool

+ type Timer struct

+ Name string

+ Start int64

+ Stop int64

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

+ func (*Timer) ProtoMessage()

+ func (m *Timer) GetName() string

+ func (m *Timer) GetStart() int64

+ func (m *Timer) GetStop() int64

+ func (m *Timer) Reset()

+ func (m *Timer) String() string

+ type Value struct

+ Data isValue_Data

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

+ func (*Value) ProtoMessage()

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

+ 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

+ type Value_Decimal struct

+ Decimal float64

+ type Value_Integer struct

+ Integer int64

+ type Value_Text struct

+ Text string

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