Documentation
¶
Overview ¶
Package loggregator_v2 is a generated protocol buffer package.
It is generated from these files:
ingress.proto envelope.proto
It has these top-level messages:
IngressResponse EnvelopeBatch BatchSenderResponse Envelope Value Log Counter Gauge GaugeValue Timer
Index ¶
- Variables
- func RegisterIngressServer(s *grpc.Server, srv IngressServer)
- type BatchSenderResponse
- type Counter
- func (*Counter) Descriptor() ([]byte, []int)
- func (m *Counter) GetDelta() uint64
- func (m *Counter) GetName() string
- func (m *Counter) GetTotal() uint64
- func (m *Counter) GetValue() isCounter_Value
- func (*Counter) ProtoMessage()
- func (m *Counter) Reset()
- func (m *Counter) String() string
- func (*Counter) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type Counter_Delta
- type Counter_Total
- type Envelope
- func (*Envelope) Descriptor() ([]byte, []int)
- func (m *Envelope) GetCounter() *Counter
- 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]*Value
- func (m *Envelope) GetTimer() *Timer
- func (m *Envelope) GetTimestamp() int64
- func (*Envelope) ProtoMessage()
- func (m *Envelope) Reset()
- func (m *Envelope) String() string
- func (*Envelope) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type EnvelopeBatch
- type Envelope_Counter
- type Envelope_Gauge
- type Envelope_Log
- type Envelope_Timer
- type Gauge
- type GaugeValue
- type IngressClient
- type IngressResponse
- type IngressServer
- type Ingress_BatchSenderClient
- type Ingress_BatchSenderServer
- type Ingress_SenderClient
- type Ingress_SenderServer
- type Log
- type Log_Type
- type Timer
- type Value
- func (*Value) Descriptor() ([]byte, []int)
- func (m *Value) GetData() isValue_Data
- func (m *Value) GetDecimal() float64
- func (m *Value) GetInteger() int64
- func (m *Value) GetText() string
- func (*Value) ProtoMessage()
- func (m *Value) Reset()
- func (m *Value) String() string
- func (*Value) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type Value_Decimal
- type Value_Integer
- type Value_Text
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 RegisterIngressServer ¶
func RegisterIngressServer(s *grpc.Server, srv IngressServer)
Types ¶
type BatchSenderResponse ¶
type BatchSenderResponse struct { }
func (*BatchSenderResponse) Descriptor ¶
func (*BatchSenderResponse) Descriptor() ([]byte, []int)
func (*BatchSenderResponse) ProtoMessage ¶
func (*BatchSenderResponse) ProtoMessage()
func (*BatchSenderResponse) Reset ¶
func (m *BatchSenderResponse) Reset()
func (*BatchSenderResponse) String ¶
func (m *BatchSenderResponse) String() string
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) ProtoMessage ¶
func (*Counter) ProtoMessage()
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 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"` InstanceId string `protobuf:"bytes,8,opt,name=instance_id,json=instanceId" json:"instance_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) GetCounter ¶
func (*Envelope) GetInstanceId ¶
func (*Envelope) GetMessage ¶
func (m *Envelope) GetMessage() isEnvelope_Message
func (*Envelope) GetSourceId ¶
func (*Envelope) GetTimestamp ¶
func (*Envelope) ProtoMessage ¶
func (*Envelope) ProtoMessage()
type EnvelopeBatch ¶
type EnvelopeBatch struct {
Batch []*Envelope `protobuf:"bytes,1,rep,name=batch" json:"batch,omitempty"`
}
func (*EnvelopeBatch) Descriptor ¶
func (*EnvelopeBatch) Descriptor() ([]byte, []int)
func (*EnvelopeBatch) GetBatch ¶
func (m *EnvelopeBatch) GetBatch() []*Envelope
func (*EnvelopeBatch) ProtoMessage ¶
func (*EnvelopeBatch) ProtoMessage()
func (*EnvelopeBatch) Reset ¶
func (m *EnvelopeBatch) Reset()
func (*EnvelopeBatch) String ¶
func (m *EnvelopeBatch) String() string
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 Gauge ¶
type Gauge struct {
Metrics map[string]*GaugeValue `` /* 134-byte string literal not displayed */
}
func (*Gauge) Descriptor ¶
func (*Gauge) GetMetrics ¶
func (m *Gauge) GetMetrics() map[string]*GaugeValue
func (*Gauge) ProtoMessage ¶
func (*Gauge) ProtoMessage()
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) BatchSender(ctx context.Context, opts ...grpc.CallOption) (Ingress_BatchSenderClient, 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 BatchSender(Ingress_BatchSenderServer) error }
type Ingress_BatchSenderClient ¶
type Ingress_BatchSenderClient interface { Send(*EnvelopeBatch) error CloseAndRecv() (*BatchSenderResponse, error) grpc.ClientStream }
type Ingress_BatchSenderServer ¶
type Ingress_BatchSenderServer interface { SendAndClose(*BatchSenderResponse) error Recv() (*EnvelopeBatch, error) grpc.ServerStream }
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) GetPayload ¶
func (*Log) ProtoMessage ¶
func (*Log) ProtoMessage()
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) ProtoMessage ¶
func (*Timer) ProtoMessage()
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) GetDecimal ¶
func (*Value) GetInteger ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
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"`
}
Click to show internal directories.
Click to hide internal directories.