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: 0

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"`
}

Jump to

Keyboard shortcuts

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