loggregator_v2

package
v7.4.0+incompatible Latest Latest
Warning

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

 Go to latest Published: May 7, 2019 License: Apache-2.0 Imports: 9 Imported by: 183

Documentation

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 RegisterEgressServer 

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

func RegisterIngressServer 

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

Types

type BatchSenderResponse 

type BatchSenderResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*BatchSenderResponse) XXX_DiscardUnknown 

func (m *BatchSenderResponse) XXX_DiscardUnknown()

func (*BatchSenderResponse) XXX_Marshal 

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

func (*BatchSenderResponse) XXX_Merge 

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

func (*BatchSenderResponse) XXX_Size 

func (m *BatchSenderResponse) XXX_Size() int

func (*BatchSenderResponse) XXX_Unmarshal 

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

type Counter 

type Counter struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Delta                uint64   `protobuf:"varint,2,opt,name=delta,proto3" json:"delta,omitempty"`
	Total                uint64   `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) ProtoMessage 

func (*Counter) ProtoMessage()

func (*Counter) Reset 

func (m *Counter) Reset()

func (*Counter) String 

func (m *Counter) String() string

func (*Counter) XXX_DiscardUnknown 

func (m *Counter) XXX_DiscardUnknown()

func (*Counter) XXX_Marshal 

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

func (*Counter) XXX_Merge 

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

func (*Counter) XXX_Size 

func (m *Counter) XXX_Size() int

func (*Counter) XXX_Unmarshal 

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

type CounterSelector 

type CounterSelector struct {
	// Any egress Counter envelope must have the given name.
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CounterSelector instructs Loggregator to egress Counter envelopes to the given subscription

func (*CounterSelector) Descriptor 

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

func (*CounterSelector) GetName 

func (m *CounterSelector) GetName() string

func (*CounterSelector) ProtoMessage 

func (*CounterSelector) ProtoMessage()

func (*CounterSelector) Reset 

func (m *CounterSelector) Reset()

func (*CounterSelector) String 

func (m *CounterSelector) String() string

func (*CounterSelector) XXX_DiscardUnknown 

func (m *CounterSelector) XXX_DiscardUnknown()

func (*CounterSelector) XXX_Marshal 

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

func (*CounterSelector) XXX_Merge 

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

func (*CounterSelector) XXX_Size 

func (m *CounterSelector) XXX_Size() int

func (*CounterSelector) XXX_Unmarshal 

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

type EgressBatchRequest 

type EgressBatchRequest struct {
	// shard_id instructs Loggregator to shard envelopes between other
	// subscriptions with the same shard_id. Loggregator will do its best to
	// split the load evenly between subscriptions with the same shard_id
	// (unless deterministic_name is set).
	ShardId string `protobuf:"bytes,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	// deterministic_name is used to enable deterministic routing. This implies
	// that gauges and counters are routed based on name. If this is excluded,
	// then they are routed to split load evenly.
	DeterministicName string `protobuf:"bytes,5,opt,name=deterministic_name,json=deterministicName,proto3" json:"deterministic_name,omitempty"`
	// TODO: This can be removed once selector has been around long enough.
	LegacySelector *Selector `protobuf:"bytes,2,opt,name=legacy_selector,json=legacySelector,proto3" json:"legacy_selector,omitempty"`
	// selector is the preferred (over legacy_selector) mechanism to select
	// what envelope types the subscription wants. If there are no selectors
	// given, no data will be sent.
	Selectors []*Selector `protobuf:"bytes,4,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// TODO: This can be removed once the envelope.deprecated_tags is removed.
	UsePreferredTags     bool     `protobuf:"varint,3,opt,name=use_preferred_tags,json=usePreferredTags,proto3" json:"use_preferred_tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EgressBatchRequest) Descriptor 

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

func (*EgressBatchRequest) GetDeterministicName 

func (m *EgressBatchRequest) GetDeterministicName() string

func (*EgressBatchRequest) GetLegacySelector 

func (m *EgressBatchRequest) GetLegacySelector() *Selector

func (*EgressBatchRequest) GetSelectors 

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

func (*EgressBatchRequest) GetShardId 

func (m *EgressBatchRequest) GetShardId() string

func (*EgressBatchRequest) GetUsePreferredTags 

func (m *EgressBatchRequest) GetUsePreferredTags() bool

func (*EgressBatchRequest) ProtoMessage 

func (*EgressBatchRequest) ProtoMessage()

func (*EgressBatchRequest) Reset 

func (m *EgressBatchRequest) Reset()

func (*EgressBatchRequest) String 

func (m *EgressBatchRequest) String() string

func (*EgressBatchRequest) XXX_DiscardUnknown 

func (m *EgressBatchRequest) XXX_DiscardUnknown()

func (*EgressBatchRequest) XXX_Marshal 

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

func (*EgressBatchRequest) XXX_Merge 

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

func (*EgressBatchRequest) XXX_Size 

func (m *EgressBatchRequest) XXX_Size() int

func (*EgressBatchRequest) XXX_Unmarshal 

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

type EgressClient 

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

EgressClient is the client API for Egress service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEgressClient 

func NewEgressClient(cc *grpc.ClientConn) EgressClient

type EgressRequest 

type EgressRequest struct {
	// shard_id instructs Loggregator to shard envelopes between other
	// subscriptions with the same shard_id. Loggregator will do its best to
	// split the load evenly between subscriptions with the same shard_id
	// (unless deterministic_name is set).
	ShardId string `protobuf:"bytes,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	// deterministic_name is used to enable deterministic routing. This implies
	// that gauges and counters are routed based on name. If this is excluded,
	// then they are routed to split load evenly.
	DeterministicName string `protobuf:"bytes,5,opt,name=deterministic_name,json=deterministicName,proto3" json:"deterministic_name,omitempty"`
	// TODO: This can be removed once selector has been around long enough.
	LegacySelector *Selector `protobuf:"bytes,2,opt,name=legacy_selector,json=legacySelector,proto3" json:"legacy_selector,omitempty"`
	// selector is the preferred (over legacy_selector) mechanism to select
	// what envelope types the subscription wants. If there are no selectors
	// given, no data will be sent.
	Selectors []*Selector `protobuf:"bytes,4,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// TODO: This can be removed once the envelope.deprecated_tags is removed.
	UsePreferredTags     bool     `protobuf:"varint,3,opt,name=use_preferred_tags,json=usePreferredTags,proto3" json:"use_preferred_tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EgressRequest) Descriptor 

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

func (*EgressRequest) GetDeterministicName 

func (m *EgressRequest) GetDeterministicName() string

func (*EgressRequest) GetLegacySelector 

func (m *EgressRequest) GetLegacySelector() *Selector

func (*EgressRequest) GetSelectors 

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

func (*EgressRequest) GetShardId 

func (m *EgressRequest) GetShardId() string

func (*EgressRequest) GetUsePreferredTags 

func (m *EgressRequest) GetUsePreferredTags() bool

func (*EgressRequest) ProtoMessage 

func (*EgressRequest) ProtoMessage()

func (*EgressRequest) Reset 

func (m *EgressRequest) Reset()

func (*EgressRequest) String 

func (m *EgressRequest) String() string

func (*EgressRequest) XXX_DiscardUnknown 

func (m *EgressRequest) XXX_DiscardUnknown()

func (*EgressRequest) XXX_Marshal 

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

func (*EgressRequest) XXX_Merge 

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

func (*EgressRequest) XXX_Size 

func (m *EgressRequest) XXX_Size() int

func (*EgressRequest) XXX_Unmarshal 

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

type EgressServer 

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

EgressServer is the server API for Egress service.

type Egress_BatchedReceiverClient 

type Egress_BatchedReceiverClient interface {
	Recv() (*EnvelopeBatch, error)
	grpc.ClientStream
}

type Egress_BatchedReceiverServer 

type Egress_BatchedReceiverServer interface {
	Send(*EnvelopeBatch) error
	grpc.ServerStream
}

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,proto3" json:"timestamp,omitempty"`
	SourceId       string            `protobuf:"bytes,2,opt,name=source_id,proto3" json:"source_id,omitempty"`
	InstanceId     string            `protobuf:"bytes,8,opt,name=instance_id,proto3" json:"instance_id,omitempty"`
	DeprecatedTags map[string]*Value `` /* 171-byte string literal not displayed */
	Tags           map[string]string `` /* 149-byte string literal not displayed */
	// Types that are valid to be assigned to Message:
	//	*Envelope_Log
	//	*Envelope_Counter
	//	*Envelope_Gauge
	//	*Envelope_Timer
	//	*Envelope_Event
	Message              isEnvelope_Message `protobuf_oneof:"message"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Envelope) Descriptor 

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

func (*Envelope) GetCounter 

func (m *Envelope) GetCounter() *Counter

func (*Envelope) GetDeprecatedTags 

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

func (*Envelope) GetEvent 

func (m *Envelope) GetEvent() *Event

func (*Envelope) GetGauge 

func (m *Envelope) GetGauge() *Gauge

func (*Envelope) GetInstanceId 

func (m *Envelope) GetInstanceId() string

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]string

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) Syslog 

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

Syslog converts an envelope into RFC 5424 compliant syslog messages. Typically, this will be a one to one (envelope to syslog) but for certain envelope type such as gauges a single envelope maps to multiple syslog messages (one per gauge metric).

func (*Envelope) XXX_DiscardUnknown 

func (m *Envelope) XXX_DiscardUnknown()

func (*Envelope) XXX_Marshal 

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

func (*Envelope) XXX_Merge 

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

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.

func (*Envelope) XXX_Size 

func (m *Envelope) XXX_Size() int

func (*Envelope) XXX_Unmarshal 

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

type EnvelopeBatch 

type EnvelopeBatch struct {
	Batch                []*Envelope `protobuf:"bytes,1,rep,name=batch,proto3" json:"batch,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

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

func (*EnvelopeBatch) XXX_DiscardUnknown 

func (m *EnvelopeBatch) XXX_DiscardUnknown()

func (*EnvelopeBatch) XXX_Marshal 

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

func (*EnvelopeBatch) XXX_Merge 

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

func (*EnvelopeBatch) XXX_Size 

func (m *EnvelopeBatch) XXX_Size() int

func (*EnvelopeBatch) XXX_Unmarshal 

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

type Envelope_Counter 

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

type Envelope_Event 

type Envelope_Event struct {
	Event *Event `protobuf:"bytes,10,opt,name=event,proto3,oneof"`
}

type Envelope_Gauge 

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

type Envelope_Log 

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

type Envelope_Timer 

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

type Event 

type Event struct {
	Title                string   `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Body                 string   `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Event) Descriptor 

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

func (*Event) GetBody 

func (m *Event) GetBody() string

func (*Event) GetTitle 

func (m *Event) GetTitle() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type EventSelector 

type EventSelector struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

EventSelector instructs Loggregator to egress Event envelopes to the given subscription.

func (*EventSelector) Descriptor 

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

func (*EventSelector) ProtoMessage 

func (*EventSelector) ProtoMessage()

func (*EventSelector) Reset 

func (m *EventSelector) Reset()

func (*EventSelector) String 

func (m *EventSelector) String() string

func (*EventSelector) XXX_DiscardUnknown 

func (m *EventSelector) XXX_DiscardUnknown()

func (*EventSelector) XXX_Marshal 

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

func (*EventSelector) XXX_Merge 

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

func (*EventSelector) XXX_Size 

func (m *EventSelector) XXX_Size() int

func (*EventSelector) XXX_Unmarshal 

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

type Gauge 

type Gauge struct {
	Metrics              map[string]*GaugeValue `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

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

func (*Gauge) XXX_DiscardUnknown 

func (m *Gauge) XXX_DiscardUnknown()

func (*Gauge) XXX_Marshal 

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

func (*Gauge) XXX_Merge 

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

func (*Gauge) XXX_Size 

func (m *Gauge) XXX_Size() int

func (*Gauge) XXX_Unmarshal 

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

type GaugeSelector 

type GaugeSelector struct {
	// Any egress Gauge envelope must consist of the given names.
	Names                []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GaugeSelector instructs Loggregator to egress Gauge envelopes to the given subscription.

func (*GaugeSelector) Descriptor 

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

func (*GaugeSelector) GetNames 

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

func (*GaugeSelector) ProtoMessage 

func (*GaugeSelector) ProtoMessage()

func (*GaugeSelector) Reset 

func (m *GaugeSelector) Reset()

func (*GaugeSelector) String 

func (m *GaugeSelector) String() string

func (*GaugeSelector) XXX_DiscardUnknown 

func (m *GaugeSelector) XXX_DiscardUnknown()

func (*GaugeSelector) XXX_Marshal 

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

func (*GaugeSelector) XXX_Merge 

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

func (*GaugeSelector) XXX_Size 

func (m *GaugeSelector) XXX_Size() int

func (*GaugeSelector) XXX_Unmarshal 

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

type GaugeValue 

type GaugeValue struct {
	Unit                 string   `protobuf:"bytes,1,opt,name=unit,proto3" json:"unit,omitempty"`
	Value                float64  `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*GaugeValue) XXX_DiscardUnknown 

func (m *GaugeValue) XXX_DiscardUnknown()

func (*GaugeValue) XXX_Marshal 

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

func (*GaugeValue) XXX_Merge 

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

func (*GaugeValue) XXX_Size 

func (m *GaugeValue) XXX_Size() int

func (*GaugeValue) XXX_Unmarshal 

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

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)
	Send(ctx context.Context, in *EnvelopeBatch, opts ...grpc.CallOption) (*SendResponse, error)
}

IngressClient is the client API for Ingress service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewIngressClient 

func NewIngressClient(cc *grpc.ClientConn) IngressClient

type IngressResponse 

type IngressResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*IngressResponse) XXX_DiscardUnknown 

func (m *IngressResponse) XXX_DiscardUnknown()

func (*IngressResponse) XXX_Marshal 

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

func (*IngressResponse) XXX_Merge 

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

func (*IngressResponse) XXX_Size 

func (m *IngressResponse) XXX_Size() int

func (*IngressResponse) XXX_Unmarshal 

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

type IngressServer 

type IngressServer interface {
	Sender(Ingress_SenderServer) error
	BatchSender(Ingress_BatchSenderServer) error
	Send(context.Context, *EnvelopeBatch) (*SendResponse, error)
}

IngressServer is the server API for Ingress service.

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,proto3,enum=loggregator.v2.Log_Type" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*Log) XXX_DiscardUnknown 

func (m *Log) XXX_DiscardUnknown()

func (*Log) XXX_Marshal 

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

func (*Log) XXX_Merge 

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

func (*Log) XXX_Size 

func (m *Log) XXX_Size() int

func (*Log) XXX_Unmarshal 

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

type LogSelector 

type LogSelector struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

LogSelector instructs Loggregator to egress Log envelopes to the given subscription.

func (*LogSelector) Descriptor 

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

func (*LogSelector) ProtoMessage 

func (*LogSelector) ProtoMessage()

func (*LogSelector) Reset 

func (m *LogSelector) Reset()

func (*LogSelector) String 

func (m *LogSelector) String() string

func (*LogSelector) XXX_DiscardUnknown 

func (m *LogSelector) XXX_DiscardUnknown()

func (*LogSelector) XXX_Marshal 

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

func (*LogSelector) XXX_Merge 

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

func (*LogSelector) XXX_Size 

func (m *LogSelector) XXX_Size() int

func (*LogSelector) XXX_Unmarshal 

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

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 Selector 

type Selector struct {
	SourceId string `protobuf:"bytes,1,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	// Types that are valid to be assigned to Message:
	//	*Selector_Log
	//	*Selector_Counter
	//	*Selector_Gauge
	//	*Selector_Timer
	//	*Selector_Event
	Message              isSelector_Message `protobuf_oneof:"Message"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Selector instructs Loggregator to only send envelopes that match the given criteria.

func (*Selector) Descriptor 

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

func (*Selector) GetCounter 

func (m *Selector) GetCounter() *CounterSelector

func (*Selector) GetEvent 

func (m *Selector) GetEvent() *EventSelector

func (*Selector) GetGauge 

func (m *Selector) GetGauge() *GaugeSelector

func (*Selector) GetLog 

func (m *Selector) GetLog() *LogSelector

func (*Selector) GetMessage 

func (m *Selector) GetMessage() isSelector_Message

func (*Selector) GetSourceId 

func (m *Selector) GetSourceId() string

func (*Selector) GetTimer 

func (m *Selector) GetTimer() *TimerSelector

func (*Selector) ProtoMessage 

func (*Selector) ProtoMessage()

func (*Selector) Reset 

func (m *Selector) Reset()

func (*Selector) String 

func (m *Selector) String() string

func (*Selector) XXX_DiscardUnknown 

func (m *Selector) XXX_DiscardUnknown()

func (*Selector) XXX_Marshal 

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

func (*Selector) XXX_Merge 

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

func (*Selector) XXX_OneofFuncs 

func (*Selector) 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.

func (*Selector) XXX_Size 

func (m *Selector) XXX_Size() int

func (*Selector) XXX_Unmarshal 

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

type Selector_Counter 

type Selector_Counter struct {
	Counter *CounterSelector `protobuf:"bytes,3,opt,name=counter,proto3,oneof"`
}

type Selector_Event 

type Selector_Event struct {
	Event *EventSelector `protobuf:"bytes,6,opt,name=event,proto3,oneof"`
}

type Selector_Gauge 

type Selector_Gauge struct {
	Gauge *GaugeSelector `protobuf:"bytes,4,opt,name=gauge,proto3,oneof"`
}

type Selector_Log 

type Selector_Log struct {
	Log *LogSelector `protobuf:"bytes,2,opt,name=log,proto3,oneof"`
}

type Selector_Timer 

type Selector_Timer struct {
	Timer *TimerSelector `protobuf:"bytes,5,opt,name=timer,proto3,oneof"`
}

type SendResponse 

type SendResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendResponse) Descriptor 

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

func (*SendResponse) ProtoMessage 

func (*SendResponse) ProtoMessage()

func (*SendResponse) Reset 

func (m *SendResponse) Reset()

func (*SendResponse) String 

func (m *SendResponse) String() string

func (*SendResponse) XXX_DiscardUnknown 

func (m *SendResponse) XXX_DiscardUnknown()

func (*SendResponse) XXX_Marshal 

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

func (*SendResponse) XXX_Merge 

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

func (*SendResponse) XXX_Size 

func (m *SendResponse) XXX_Size() int

func (*SendResponse) XXX_Unmarshal 

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

type SyslogOption 

type SyslogOption func(*syslogConfig)

SyslogOption configures the behavior of Envelope.Syslog.

func WithSyslogAppName 

func WithSyslogAppName(appName string) SyslogOption

WithSyslogAppName changes the app name of the resulting syslog messages.

func WithSyslogHostname 

func WithSyslogHostname(hostname string) SyslogOption

WithSyslogHostname changes the hostname of the resulting syslog messages.

func WithSyslogProcessID 

func WithSyslogProcessID(processID string) SyslogOption

WithSyslogProcessID changes the process id of the resulting syslog messages.

type Timer 

type Timer struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Start                int64    `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	Stop                 int64    `protobuf:"varint,3,opt,name=stop,proto3" json:"stop,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*Timer) XXX_DiscardUnknown 

func (m *Timer) XXX_DiscardUnknown()

func (*Timer) XXX_Marshal 

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

func (*Timer) XXX_Merge 

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

func (*Timer) XXX_Size 

func (m *Timer) XXX_Size() int

func (*Timer) XXX_Unmarshal 

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

type TimerSelector 

type TimerSelector struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TimerSelector instructs Loggregator to egress Timer envelopes to the given subscription.

func (*TimerSelector) Descriptor 

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

func (*TimerSelector) ProtoMessage 

func (*TimerSelector) ProtoMessage()

func (*TimerSelector) Reset 

func (m *TimerSelector) Reset()

func (*TimerSelector) String 

func (m *TimerSelector) String() string

func (*TimerSelector) XXX_DiscardUnknown 

func (m *TimerSelector) XXX_DiscardUnknown()

func (*TimerSelector) XXX_Marshal 

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

func (*TimerSelector) XXX_Merge 

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

func (*TimerSelector) XXX_Size 

func (m *TimerSelector) XXX_Size() int

func (*TimerSelector) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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_DiscardUnknown 

func (m *Value) XXX_DiscardUnknown()

func (*Value) XXX_Marshal 

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

func (*Value) XXX_Merge 

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

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.

func (*Value) XXX_Size 

func (m *Value) XXX_Size() int

func (*Value) XXX_Unmarshal 

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

type Value_Decimal 

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

type Value_Integer 

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

type Value_Text 

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

Source Files

View all Source files

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.