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