loggregator_v2

package
v1.10.0 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2017 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package loggregator_v2 is a generated protocol buffer package.

It is generated from these files: 

egress.proto
envelope.proto
ingress.proto

It has these top-level messages: 

EgressRequest
Filter
Envelope
Value
Log
Counter
Gauge
GaugeValue
Timer
IngressResponse

Index

Constants

This section is empty.

Variables

View Source 
var Log_Type_name = map[int32]string{
	0: "OUT",
	1: "ERR",
}
View Source 
var Log_Type_value = map[string]int32{
	"OUT": 0,
	"ERR": 1,
}

Functions

func NewGrpcClient 

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

func RegisterEgressServer 

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

func RegisterIngressServer 

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

Types

type Client 

type Client interface {
	SendAppLog(appID, message, sourceType, sourceInstance string) error
	SendAppErrorLog(appID, message, sourceType, sourceInstance string) error
	SendAppMetrics(metrics *events.ContainerMetric) error
}

func NewClient 

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

type Connector 

type Connector func() (IngressClient, error)

type Counter 

type Counter struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*Counter_Delta
	//	*Counter_Total
	Value isCounter_Value `protobuf_oneof:"value"`
}

func (*Counter) Descriptor 

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

func (*Counter) GetDelta 

func (m *Counter) GetDelta() uint64

func (*Counter) GetName 

func (m *Counter) GetName() string

func (*Counter) GetTotal 

func (m *Counter) GetTotal() uint64

func (*Counter) GetValue 

func (m *Counter) GetValue() isCounter_Value

func (*Counter) ProtoMessage 

func (*Counter) ProtoMessage()

func (*Counter) Reset 

func (m *Counter) Reset()

func (*Counter) String 

func (m *Counter) String() string

func (*Counter) XXX_OneofFuncs 

func (*Counter) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Counter_Delta 

type Counter_Delta struct {
	Delta uint64 `protobuf:"varint,2,opt,name=delta,oneof"`
}

type Counter_Total 

type Counter_Total struct {
	Total uint64 `protobuf:"varint,3,opt,name=total,oneof"`
}

type EgressClient 

type EgressClient interface {
	Receiver(ctx context.Context, in *EgressRequest, opts ...grpc.CallOption) (Egress_ReceiverClient, error)
}

func NewEgressClient 

func NewEgressClient(cc *grpc.ClientConn) EgressClient

type EgressRequest 

type EgressRequest struct {
	ShardId string  `protobuf:"bytes,1,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"`
	Filter  *Filter `protobuf:"bytes,2,opt,name=filter" json:"filter,omitempty"`
}

func (*EgressRequest) Descriptor 

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

func (*EgressRequest) GetFilter 

func (m *EgressRequest) GetFilter() *Filter

func (*EgressRequest) GetShardId 

func (m *EgressRequest) GetShardId() string

func (*EgressRequest) ProtoMessage 

func (*EgressRequest) ProtoMessage()

func (*EgressRequest) Reset 

func (m *EgressRequest) Reset()

func (*EgressRequest) String 

func (m *EgressRequest) String() string

type EgressServer 

type EgressServer interface {
	Receiver(*EgressRequest, Egress_ReceiverServer) error
}

type Egress_ReceiverClient 

type Egress_ReceiverClient interface {
	Recv() (*Envelope, error)
	grpc.ClientStream
}

type Egress_ReceiverServer 

type Egress_ReceiverServer interface {
	Send(*Envelope) error
	grpc.ServerStream
}

type Envelope 

type Envelope struct {
	Timestamp int64             `protobuf:"varint,1,opt,name=timestamp" json:"timestamp,omitempty"`
	SourceId  string            `protobuf:"bytes,2,opt,name=source_id,json=sourceId" json:"source_id,omitempty"`
	Tags      map[string]*Value `` /* 128-byte string literal not displayed */
	// Types that are valid to be assigned to Message:
	//	*Envelope_Log
	//	*Envelope_Counter
	//	*Envelope_Gauge
	//	*Envelope_Timer
	Message isEnvelope_Message `protobuf_oneof:"message"`
}

func (*Envelope) Descriptor 

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

func (*Envelope) GetCounter 

func (m *Envelope) GetCounter() *Counter

func (*Envelope) GetGauge 

func (m *Envelope) GetGauge() *Gauge

func (*Envelope) GetLog 

func (m *Envelope) GetLog() *Log

func (*Envelope) GetMessage 

func (m *Envelope) GetMessage() isEnvelope_Message

func (*Envelope) GetSourceId 

func (m *Envelope) GetSourceId() string

func (*Envelope) GetTags 

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

func (*Envelope) GetTimer 

func (m *Envelope) GetTimer() *Timer

func (*Envelope) GetTimestamp 

func (m *Envelope) GetTimestamp() int64

func (*Envelope) ProtoMessage 

func (*Envelope) ProtoMessage()

func (*Envelope) Reset 

func (m *Envelope) Reset()

func (*Envelope) String 

func (m *Envelope) String() string

func (*Envelope) XXX_OneofFuncs 

func (*Envelope) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Envelope_Counter 

type Envelope_Counter struct {
	Counter *Counter `protobuf:"bytes,5,opt,name=counter,oneof"`
}

type Envelope_Gauge 

type Envelope_Gauge struct {
	Gauge *Gauge `protobuf:"bytes,6,opt,name=gauge,oneof"`
}

type Envelope_Log 

type Envelope_Log struct {
	Log *Log `protobuf:"bytes,4,opt,name=log,oneof"`
}

type Envelope_Timer 

type Envelope_Timer struct {
	Timer *Timer `protobuf:"bytes,7,opt,name=timer,oneof"`
}

type Filter 

type Filter struct {
	SourceId string `protobuf:"bytes,1,opt,name=source_id,json=sourceId" json:"source_id,omitempty"`
}

func (*Filter) Descriptor 

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

func (*Filter) GetSourceId 

func (m *Filter) GetSourceId() string

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) String 

func (m *Filter) String() string

type Gauge 

type Gauge struct {
	Metrics map[string]*GaugeValue `` /* 134-byte string literal not displayed */
}

func (*Gauge) Descriptor 

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

func (*Gauge) GetMetrics 

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

func (*Gauge) ProtoMessage 

func (*Gauge) ProtoMessage()

func (*Gauge) Reset 

func (m *Gauge) Reset()

func (*Gauge) String 

func (m *Gauge) String() string

type GaugeValue 

type GaugeValue struct {
	Unit  string  `protobuf:"bytes,1,opt,name=unit" json:"unit,omitempty"`
	Value float64 `protobuf:"fixed64,2,opt,name=value" json:"value,omitempty"`
}

func (*GaugeValue) Descriptor 

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

func (*GaugeValue) GetUnit 

func (m *GaugeValue) GetUnit() string

func (*GaugeValue) GetValue 

func (m *GaugeValue) GetValue() float64

func (*GaugeValue) ProtoMessage 

func (*GaugeValue) ProtoMessage()

func (*GaugeValue) Reset 

func (m *GaugeValue) Reset()

func (*GaugeValue) String 

func (m *GaugeValue) String() string

type IngressClient 

type IngressClient interface {
	Sender(ctx context.Context, opts ...grpc.CallOption) (Ingress_SenderClient, error)
}

func NewIngressClient 

func NewIngressClient(cc *grpc.ClientConn) IngressClient

type IngressResponse 

type IngressResponse struct {
}

func (*IngressResponse) Descriptor 

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

func (*IngressResponse) ProtoMessage 

func (*IngressResponse) ProtoMessage()

func (*IngressResponse) Reset 

func (m *IngressResponse) Reset()

func (*IngressResponse) String 

func (m *IngressResponse) String() string

type IngressServer 

type IngressServer interface {
	Sender(Ingress_SenderServer) error
}

type Ingress_SenderClient 

type Ingress_SenderClient interface {
	Send(*Envelope) error
	CloseAndRecv() (*IngressResponse, error)
	grpc.ClientStream
}

type Ingress_SenderServer 

type Ingress_SenderServer interface {
	SendAndClose(*IngressResponse) error
	Recv() (*Envelope, error)
	grpc.ServerStream
}

type Log 

type Log struct {
	Payload []byte   `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Type    Log_Type `protobuf:"varint,2,opt,name=type,enum=loggregator.v2.Log_Type" json:"type,omitempty"`
}

func (*Log) Descriptor 

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

func (*Log) GetPayload 

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

func (*Log) GetType 

func (m *Log) GetType() Log_Type

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) Reset 

func (m *Log) Reset()

func (*Log) String 

func (m *Log) String() string

type Log_Type 

type Log_Type int32
const (
	Log_OUT Log_Type = 0
	Log_ERR Log_Type = 1
)

func (Log_Type) EnumDescriptor 

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

func (Log_Type) String 

func (x Log_Type) String() string

type MetronConfig 

type MetronConfig struct {
	UseV2API      bool   `json:"loggregator_use_v2_api"`
	APIPort       int    `json:"loggregator_api_port"`
	CACertPath    string `json:"loggregator_ca_path"`
	CertPath      string `json:"loggregator_cert_path"`
	KeyPath       string `json:"loggregator_key_path"`
	JobDeployment string `json:"loggregator_job_deployment"`
	JobName       string `json:"loggregator_job_name"`
	JobIndex      string `json:"loggregator_job_index"`
	JobIP         string `json:"loggregator_job_ip"`
	JobOrigin     string `json:"loggregator_job_origin"`
	DropsondePort int    `json:"dropsonde_port"`
}

type Timer 

type Timer struct {
	Name  string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Start int64  `protobuf:"varint,2,opt,name=start" json:"start,omitempty"`
	Stop  int64  `protobuf:"varint,3,opt,name=stop" json:"stop,omitempty"`
}

func (*Timer) Descriptor 

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

func (*Timer) GetName 

func (m *Timer) GetName() string

func (*Timer) GetStart 

func (m *Timer) GetStart() int64

func (*Timer) GetStop 

func (m *Timer) GetStop() int64

func (*Timer) ProtoMessage 

func (*Timer) ProtoMessage()

func (*Timer) Reset 

func (m *Timer) Reset()

func (*Timer) String 

func (m *Timer) String() string

type Value 

type Value struct {
	// Types that are valid to be assigned to Data:
	//	*Value_Text
	//	*Value_Integer
	//	*Value_Decimal
	Data isValue_Data `protobuf_oneof:"data"`
}

func (*Value) Descriptor 

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

func (*Value) GetData 

func (m *Value) GetData() isValue_Data

func (*Value) GetDecimal 

func (m *Value) GetDecimal() float64

func (*Value) GetInteger 

func (m *Value) GetInteger() int64

func (*Value) GetText 

func (m *Value) GetText() string

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) String 

func (m *Value) String() string

func (*Value) XXX_OneofFuncs 

func (*Value) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Value_Decimal 

type Value_Decimal struct {
	Decimal float64 `protobuf:"fixed64,3,opt,name=decimal,oneof"`
}

type Value_Integer 

type Value_Integer struct {
	Integer int64 `protobuf:"varint,2,opt,name=integer,oneof"`
}

type Value_Text 

type Value_Text struct {
	Text string `protobuf:"bytes,1,opt,name=text,oneof"`
}

Source Files

View all Source files

Directories

Path Synopsis
This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter
 This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.