loggregator_v2

package
v9.2.1 Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 8 Imported by: 32

Documentation

Index

Constants

View Source 
const (
	Egress_Receiver_FullMethodName        = "/loggregator.v2.Egress/Receiver"
	Egress_BatchedReceiver_FullMethodName = "/loggregator.v2.Egress/BatchedReceiver"
)
View Source 
const (
	Ingress_Sender_FullMethodName      = "/loggregator.v2.Ingress/Sender"
	Ingress_BatchSender_FullMethodName = "/loggregator.v2.Ingress/BatchSender"
	Ingress_Send_FullMethodName        = "/loggregator.v2.Ingress/Send"
)

Variables

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

Enum value maps for Log_Type.

View Source 
var Egress_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loggregator.v2.Egress",
	HandlerType: (*EgressServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Receiver",
			Handler:       _Egress_Receiver_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "BatchedReceiver",
			Handler:       _Egress_BatchedReceiver_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "loggregator-api/v2/egress.proto",
}

Egress_ServiceDesc is the grpc.ServiceDesc for Egress service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_loggregator_api_v2_egress_proto protoreflect.FileDescriptor
View Source 
var File_loggregator_api_v2_envelope_proto protoreflect.FileDescriptor
View Source 
var File_loggregator_api_v2_ingress_proto protoreflect.FileDescriptor
View Source 
var Ingress_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loggregator.v2.Ingress",
	HandlerType: (*IngressServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Send",
			Handler:    _Ingress_Send_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Sender",
			Handler:       _Ingress_Sender_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "BatchSender",
			Handler:       _Ingress_BatchSender_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "loggregator-api/v2/ingress.proto",
}

Ingress_ServiceDesc is the grpc.ServiceDesc for Ingress service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterEgressServer 

func RegisterEgressServer(s grpc.ServiceRegistrar, srv EgressServer)

func RegisterIngressServer 

func RegisterIngressServer(s grpc.ServiceRegistrar, srv IngressServer)

Types

type BatchSenderResponse 

type BatchSenderResponse struct {
	// contains filtered or unexported fields
}

func (*BatchSenderResponse) Descriptor deprecated 

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

Deprecated: Use BatchSenderResponse.ProtoReflect.Descriptor instead.

func (*BatchSenderResponse) ProtoMessage 

func (*BatchSenderResponse) ProtoMessage()

func (*BatchSenderResponse) ProtoReflect 

func (x *BatchSenderResponse) ProtoReflect() protoreflect.Message

func (*BatchSenderResponse) Reset 

func (x *BatchSenderResponse) Reset()

func (*BatchSenderResponse) String 

func (x *BatchSenderResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*Counter) Descriptor deprecated 

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

Deprecated: Use Counter.ProtoReflect.Descriptor instead.

func (*Counter) GetDelta 

func (x *Counter) GetDelta() uint64

func (*Counter) GetName 

func (x *Counter) GetName() string

func (*Counter) GetTotal 

func (x *Counter) GetTotal() uint64

func (*Counter) ProtoMessage 

func (*Counter) ProtoMessage()

func (*Counter) ProtoReflect 

func (x *Counter) ProtoReflect() protoreflect.Message

func (*Counter) Reset 

func (x *Counter) Reset()

func (*Counter) String 

func (x *Counter) String() string

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"`
	// contains filtered or unexported fields
}

CounterSelector instructs Loggregator to egress Counter envelopes to the given subscription

func (*CounterSelector) Descriptor deprecated 

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

Deprecated: Use CounterSelector.ProtoReflect.Descriptor instead.

func (*CounterSelector) GetName 

func (x *CounterSelector) GetName() string

func (*CounterSelector) ProtoMessage 

func (*CounterSelector) ProtoMessage()

func (*CounterSelector) ProtoReflect 

func (x *CounterSelector) ProtoReflect() protoreflect.Message

func (*CounterSelector) Reset 

func (x *CounterSelector) Reset()

func (*CounterSelector) String 

func (x *CounterSelector) String() string

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"`
	// contains filtered or unexported fields
}

func (*EgressBatchRequest) Descriptor deprecated 

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

Deprecated: Use EgressBatchRequest.ProtoReflect.Descriptor instead.

func (*EgressBatchRequest) GetDeterministicName 

func (x *EgressBatchRequest) GetDeterministicName() string

func (*EgressBatchRequest) GetLegacySelector 

func (x *EgressBatchRequest) GetLegacySelector() *Selector

func (*EgressBatchRequest) GetSelectors 

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

func (*EgressBatchRequest) GetShardId 

func (x *EgressBatchRequest) GetShardId() string

func (*EgressBatchRequest) GetUsePreferredTags 

func (x *EgressBatchRequest) GetUsePreferredTags() bool

func (*EgressBatchRequest) ProtoMessage 

func (*EgressBatchRequest) ProtoMessage()

func (*EgressBatchRequest) ProtoReflect 

func (x *EgressBatchRequest) ProtoReflect() protoreflect.Message

func (*EgressBatchRequest) Reset 

func (x *EgressBatchRequest) Reset()

func (*EgressBatchRequest) String 

func (x *EgressBatchRequest) String() string

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewEgressClient 

func NewEgressClient(cc grpc.ClientConnInterface) 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"`
	// contains filtered or unexported fields
}

func (*EgressRequest) Descriptor deprecated 

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

Deprecated: Use EgressRequest.ProtoReflect.Descriptor instead.

func (*EgressRequest) GetDeterministicName 

func (x *EgressRequest) GetDeterministicName() string

func (*EgressRequest) GetLegacySelector 

func (x *EgressRequest) GetLegacySelector() *Selector

func (*EgressRequest) GetSelectors 

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

func (*EgressRequest) GetShardId 

func (x *EgressRequest) GetShardId() string

func (*EgressRequest) GetUsePreferredTags 

func (x *EgressRequest) GetUsePreferredTags() bool

func (*EgressRequest) ProtoMessage 

func (*EgressRequest) ProtoMessage()

func (*EgressRequest) ProtoReflect 

func (x *EgressRequest) ProtoReflect() protoreflect.Message

func (*EgressRequest) Reset 

func (x *EgressRequest) Reset()

func (*EgressRequest) String 

func (x *EgressRequest) String() string

type EgressServer 

type EgressServer interface {
	Receiver(*EgressRequest, Egress_ReceiverServer) error
	BatchedReceiver(*EgressBatchRequest, Egress_BatchedReceiverServer) error
	// contains filtered or unexported methods
}

EgressServer is the server API for Egress service. All implementations must embed UnimplementedEgressServer for forward compatibility

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 assignable to Message:
	//
	//	*Envelope_Log
	//	*Envelope_Counter
	//	*Envelope_Gauge
	//	*Envelope_Timer
	//	*Envelope_Event
	Message isEnvelope_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*Envelope) Descriptor deprecated 

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

Deprecated: Use Envelope.ProtoReflect.Descriptor instead.

func (*Envelope) GetCounter 

func (x *Envelope) GetCounter() *Counter

func (*Envelope) GetDeprecatedTags 

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

func (*Envelope) GetEvent 

func (x *Envelope) GetEvent() *Event

func (*Envelope) GetGauge 

func (x *Envelope) GetGauge() *Gauge

func (*Envelope) GetInstanceId 

func (x *Envelope) GetInstanceId() string

func (*Envelope) GetLog 

func (x *Envelope) GetLog() *Log

func (*Envelope) GetMessage 

func (m *Envelope) GetMessage() isEnvelope_Message

func (*Envelope) GetSourceId 

func (x *Envelope) GetSourceId() string

func (*Envelope) GetTags 

func (x *Envelope) GetTags() map[string]string

func (*Envelope) GetTimer 

func (x *Envelope) GetTimer() *Timer

func (*Envelope) GetTimestamp 

func (x *Envelope) GetTimestamp() int64

func (*Envelope) ProtoMessage 

func (*Envelope) ProtoMessage()

func (*Envelope) ProtoReflect 

func (x *Envelope) ProtoReflect() protoreflect.Message

func (*Envelope) Reset 

func (x *Envelope) Reset()

func (*Envelope) String 

func (x *Envelope) String() string

type EnvelopeBatch 

type EnvelopeBatch struct {
	Batch []*Envelope `protobuf:"bytes,1,rep,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvelopeBatch) Descriptor deprecated 

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

Deprecated: Use EnvelopeBatch.ProtoReflect.Descriptor instead.

func (*EnvelopeBatch) GetBatch 

func (x *EnvelopeBatch) GetBatch() []*Envelope

func (*EnvelopeBatch) ProtoMessage 

func (*EnvelopeBatch) ProtoMessage()

func (*EnvelopeBatch) ProtoReflect 

func (x *EnvelopeBatch) ProtoReflect() protoreflect.Message

func (*EnvelopeBatch) Reset 

func (x *EnvelopeBatch) Reset()

func (*EnvelopeBatch) String 

func (x *EnvelopeBatch) String() string

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"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetBody 

func (x *Event) GetBody() string

func (*Event) GetTitle 

func (x *Event) GetTitle() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventSelector 

type EventSelector struct {
	// contains filtered or unexported fields
}

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

func (*EventSelector) Descriptor deprecated 

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

Deprecated: Use EventSelector.ProtoReflect.Descriptor instead.

func (*EventSelector) ProtoMessage 

func (*EventSelector) ProtoMessage()

func (*EventSelector) ProtoReflect 

func (x *EventSelector) ProtoReflect() protoreflect.Message

func (*EventSelector) Reset 

func (x *EventSelector) Reset()

func (*EventSelector) String 

func (x *EventSelector) String() string

type Gauge 

type Gauge struct {
	Metrics map[string]*GaugeValue `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Gauge) Descriptor deprecated 

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

Deprecated: Use Gauge.ProtoReflect.Descriptor instead.

func (*Gauge) GetMetrics 

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

func (*Gauge) ProtoMessage 

func (*Gauge) ProtoMessage()

func (*Gauge) ProtoReflect 

func (x *Gauge) ProtoReflect() protoreflect.Message

func (*Gauge) Reset 

func (x *Gauge) Reset()

func (*Gauge) String 

func (x *Gauge) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*GaugeSelector) Descriptor deprecated 

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

Deprecated: Use GaugeSelector.ProtoReflect.Descriptor instead.

func (*GaugeSelector) GetNames 

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

func (*GaugeSelector) ProtoMessage 

func (*GaugeSelector) ProtoMessage()

func (*GaugeSelector) ProtoReflect 

func (x *GaugeSelector) ProtoReflect() protoreflect.Message

func (*GaugeSelector) Reset 

func (x *GaugeSelector) Reset()

func (*GaugeSelector) String 

func (x *GaugeSelector) String() string

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"`
	// contains filtered or unexported fields
}

func (*GaugeValue) Descriptor deprecated 

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

Deprecated: Use GaugeValue.ProtoReflect.Descriptor instead.

func (*GaugeValue) GetUnit 

func (x *GaugeValue) GetUnit() string

func (*GaugeValue) GetValue 

func (x *GaugeValue) GetValue() float64

func (*GaugeValue) ProtoMessage 

func (*GaugeValue) ProtoMessage()

func (*GaugeValue) ProtoReflect 

func (x *GaugeValue) ProtoReflect() protoreflect.Message

func (*GaugeValue) Reset 

func (x *GaugeValue) Reset()

func (*GaugeValue) String 

func (x *GaugeValue) String() string

type IngressClient 

type IngressClient interface {
	Sender(ctx context.Context, opts ...grpc.CallOption) (Ingress_SenderClient, error)
	BatchSender(ctx context.Context, opts ...grpc.CallOption) (Ingress_BatchSenderClient, error)
	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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewIngressClient 

func NewIngressClient(cc grpc.ClientConnInterface) IngressClient

type IngressResponse 

type IngressResponse struct {
	// contains filtered or unexported fields
}

func (*IngressResponse) Descriptor deprecated 

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

Deprecated: Use IngressResponse.ProtoReflect.Descriptor instead.

func (*IngressResponse) ProtoMessage 

func (*IngressResponse) ProtoMessage()

func (*IngressResponse) ProtoReflect 

func (x *IngressResponse) ProtoReflect() protoreflect.Message

func (*IngressResponse) Reset 

func (x *IngressResponse) Reset()

func (*IngressResponse) String 

func (x *IngressResponse) String() string

type IngressServer 

type IngressServer interface {
	Sender(Ingress_SenderServer) error
	BatchSender(Ingress_BatchSenderServer) error
	Send(context.Context, *EnvelopeBatch) (*SendResponse, error)
	// contains filtered or unexported methods
}

IngressServer is the server API for Ingress service. All implementations must embed UnimplementedIngressServer for forward compatibility

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"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetPayload 

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

func (*Log) GetType 

func (x *Log) GetType() Log_Type

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect 

func (x *Log) ProtoReflect() protoreflect.Message

func (*Log) Reset 

func (x *Log) Reset()

func (*Log) String 

func (x *Log) String() string

type LogSelector 

type LogSelector struct {
	// contains filtered or unexported fields
}

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

func (*LogSelector) Descriptor deprecated 

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

Deprecated: Use LogSelector.ProtoReflect.Descriptor instead.

func (*LogSelector) ProtoMessage 

func (*LogSelector) ProtoMessage()

func (*LogSelector) ProtoReflect 

func (x *LogSelector) ProtoReflect() protoreflect.Message

func (*LogSelector) Reset 

func (x *LogSelector) Reset()

func (*LogSelector) String 

func (x *LogSelector) String() string

type Log_Type 

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

func (Log_Type) Descriptor 

func (Log_Type) Descriptor() protoreflect.EnumDescriptor

func (Log_Type) Enum 

func (x Log_Type) Enum() *Log_Type

func (Log_Type) EnumDescriptor deprecated 

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

Deprecated: Use Log_Type.Descriptor instead.

func (Log_Type) Number 

func (x Log_Type) Number() protoreflect.EnumNumber

func (Log_Type) String 

func (x Log_Type) String() string

func (Log_Type) Type 

func (Log_Type) Type() protoreflect.EnumType

type Selector 

type Selector struct {
	SourceId string `protobuf:"bytes,1,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	// Types that are assignable to Message:
	//
	//	*Selector_Log
	//	*Selector_Counter
	//	*Selector_Gauge
	//	*Selector_Timer
	//	*Selector_Event
	Message isSelector_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

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

func (*Selector) Descriptor deprecated 

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

Deprecated: Use Selector.ProtoReflect.Descriptor instead.

func (*Selector) GetCounter 

func (x *Selector) GetCounter() *CounterSelector

func (*Selector) GetEvent 

func (x *Selector) GetEvent() *EventSelector

func (*Selector) GetGauge 

func (x *Selector) GetGauge() *GaugeSelector

func (*Selector) GetLog 

func (x *Selector) GetLog() *LogSelector

func (*Selector) GetMessage 

func (m *Selector) GetMessage() isSelector_Message

func (*Selector) GetSourceId 

func (x *Selector) GetSourceId() string

func (*Selector) GetTimer 

func (x *Selector) GetTimer() *TimerSelector

func (*Selector) ProtoMessage 

func (*Selector) ProtoMessage()

func (*Selector) ProtoReflect 

func (x *Selector) ProtoReflect() protoreflect.Message

func (*Selector) Reset 

func (x *Selector) Reset()

func (*Selector) String 

func (x *Selector) String() string

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 {
	// contains filtered or unexported fields
}

func (*SendResponse) Descriptor deprecated 

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

Deprecated: Use SendResponse.ProtoReflect.Descriptor instead.

func (*SendResponse) ProtoMessage 

func (*SendResponse) ProtoMessage()

func (*SendResponse) ProtoReflect 

func (x *SendResponse) ProtoReflect() protoreflect.Message

func (*SendResponse) Reset 

func (x *SendResponse) Reset()

func (*SendResponse) String 

func (x *SendResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*Timer) Descriptor deprecated 

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

Deprecated: Use Timer.ProtoReflect.Descriptor instead.

func (*Timer) GetName 

func (x *Timer) GetName() string

func (*Timer) GetStart 

func (x *Timer) GetStart() int64

func (*Timer) GetStop 

func (x *Timer) GetStop() int64

func (*Timer) ProtoMessage 

func (*Timer) ProtoMessage()

func (*Timer) ProtoReflect 

func (x *Timer) ProtoReflect() protoreflect.Message

func (*Timer) Reset 

func (x *Timer) Reset()

func (*Timer) String 

func (x *Timer) String() string

type TimerSelector 

type TimerSelector struct {
	// contains filtered or unexported fields
}

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

func (*TimerSelector) Descriptor deprecated 

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

Deprecated: Use TimerSelector.ProtoReflect.Descriptor instead.

func (*TimerSelector) ProtoMessage 

func (*TimerSelector) ProtoMessage()

func (*TimerSelector) ProtoReflect 

func (x *TimerSelector) ProtoReflect() protoreflect.Message

func (*TimerSelector) Reset 

func (x *TimerSelector) Reset()

func (*TimerSelector) String 

func (x *TimerSelector) String() string

type UnimplementedEgressServer 

type UnimplementedEgressServer struct {
}

UnimplementedEgressServer must be embedded to have forward compatible implementations.

func (UnimplementedEgressServer) BatchedReceiver 

func (UnimplementedEgressServer) BatchedReceiver(*EgressBatchRequest, Egress_BatchedReceiverServer) error

func (UnimplementedEgressServer) Receiver 

func (UnimplementedEgressServer) Receiver(*EgressRequest, Egress_ReceiverServer) error

type UnimplementedIngressServer 

type UnimplementedIngressServer struct {
}

UnimplementedIngressServer must be embedded to have forward compatible implementations.

func (UnimplementedIngressServer) BatchSender 

func (UnimplementedIngressServer) BatchSender(Ingress_BatchSenderServer) error

func (UnimplementedIngressServer) Send 

func (UnimplementedIngressServer) Send(context.Context, *EnvelopeBatch) (*SendResponse, error)

func (UnimplementedIngressServer) Sender 

func (UnimplementedIngressServer) Sender(Ingress_SenderServer) error

type UnsafeEgressServer 

type UnsafeEgressServer interface {
	// contains filtered or unexported methods
}

UnsafeEgressServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EgressServer will result in compilation errors.

type UnsafeIngressServer 

type UnsafeIngressServer interface {
	// contains filtered or unexported methods
}

UnsafeIngressServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IngressServer will result in compilation errors.

type Value 

type Value struct {

	// Types that are assignable to Data:
	//
	//	*Value_Text
	//	*Value_Integer
	//	*Value_Decimal
	Data isValue_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetData 

func (m *Value) GetData() isValue_Data

func (*Value) GetDecimal 

func (x *Value) GetDecimal() float64

func (*Value) GetInteger 

func (x *Value) GetInteger() int64

func (*Value) GetText 

func (x *Value) GetText() string

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

func (x *Value) ProtoReflect() protoreflect.Message

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

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.