loggregator_v2

package
v1.14.0 Latest Latest
Warning

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

 Go to latest Published: Apr 21, 2017 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package loggregator_v2 is a generated protocol buffer package.

It is generated from these files: 

egress.proto
envelope.proto
ingress.proto

It has these top-level messages: 

EgressRequest
Filter
LogFilter
Envelope
Value
Log
Counter
Gauge
GaugeValue
Timer
IngressResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthEgress = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEgress   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthEnvelope = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEnvelope   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthIngress = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIngress   = fmt.Errorf("proto: integer overflow")
)
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 NewGrpcClient 

func NewGrpcClient(logger lager.Logger, config *MetronConfig, ingressClient IngressClient) *grpcClient

func RegisterEgressServer 

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

func RegisterIngressServer 

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

Types

type Batcher added in v1.12.0 

type Batcher interface {
	ComponentMetricsClient
	Send() error
}

type Client 

type Client interface {
	ComponentClient
	SendAppLog(appID, message, sourceType, sourceInstance string) error
	SendAppErrorLog(appID, message, sourceType, sourceInstance string) error
	SendAppMetrics(metrics *events.ContainerMetric) error
}

func NewClient 

func NewClient(logger lager.Logger, config MetronConfig) (Client, error)

type ComponentClient added in v1.12.0 

type ComponentClient interface {
	ComponentMetricsClient
	Batcher() Batcher
	IncrementCounter(name string) error
}

type ComponentMetricsClient added in v1.12.0 

type ComponentMetricsClient interface {
	SendDuration(name string, value time.Duration) error
	SendMebiBytes(name string, value int) error
	SendMetric(name string, value int) error
	SendBytesPerSecond(name string, value float64) error
	SendRequestsPerSecond(name string, value float64) error
}

type Connector 

type Connector func() (IngressClient, error)

type Counter 

type Counter struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*Counter_Delta
	//	*Counter_Total
	Value isCounter_Value `protobuf_oneof:"value"`
}

func (*Counter) Descriptor 

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

func (*Counter) Equal added in v1.12.0 

func (this *Counter) Equal(that interface{}) bool

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

func (m *Counter) GetValue() isCounter_Value

func (*Counter) GoString added in v1.12.0 

func (this *Counter) GoString() string

func (*Counter) Marshal added in v1.12.0 

func (m *Counter) Marshal() (dAtA []byte, err error)

func (*Counter) MarshalTo added in v1.12.0 

func (m *Counter) MarshalTo(dAtA []byte) (int, error)

func (*Counter) ProtoMessage 

func (*Counter) ProtoMessage()

func (*Counter) Reset 

func (m *Counter) Reset()

func (*Counter) Size added in v1.12.0 

func (m *Counter) Size() (n int)

func (*Counter) String 

func (this *Counter) String() string

func (*Counter) Unmarshal added in v1.12.0 

func (m *Counter) Unmarshal(dAtA []byte) error

func (*Counter) XXX_OneofFuncs 

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

type Counter_Delta 

type Counter_Delta struct {
	Delta uint64 `protobuf:"varint,2,opt,name=delta,proto3,oneof"`
}

func (*Counter_Delta) Equal added in v1.12.0 

func (this *Counter_Delta) Equal(that interface{}) bool

func (*Counter_Delta) GoString added in v1.12.0 

func (this *Counter_Delta) GoString() string

func (*Counter_Delta) MarshalTo added in v1.12.0 

func (m *Counter_Delta) MarshalTo(dAtA []byte) (int, error)

func (*Counter_Delta) Size added in v1.12.0 

func (m *Counter_Delta) Size() (n int)

func (*Counter_Delta) String added in v1.12.0 

func (this *Counter_Delta) String() string

type Counter_Total 

type Counter_Total struct {
	Total uint64 `protobuf:"varint,3,opt,name=total,proto3,oneof"`
}

func (*Counter_Total) Equal added in v1.12.0 

func (this *Counter_Total) Equal(that interface{}) bool

func (*Counter_Total) GoString added in v1.12.0 

func (this *Counter_Total) GoString() string

func (*Counter_Total) MarshalTo added in v1.12.0 

func (m *Counter_Total) MarshalTo(dAtA []byte) (int, error)

func (*Counter_Total) Size added in v1.12.0 

func (m *Counter_Total) Size() (n int)

func (*Counter_Total) String added in v1.12.0 

func (this *Counter_Total) String() string

type EgressClient 

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

func NewEgressClient 

func NewEgressClient(cc *grpc.ClientConn) EgressClient

type EgressRequest 

type EgressRequest struct {
	ShardId string  `protobuf:"bytes,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Filter  *Filter `protobuf:"bytes,2,opt,name=filter" json:"filter,omitempty"`
}

func (*EgressRequest) Descriptor 

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

func (*EgressRequest) Equal added in v1.12.0 

func (this *EgressRequest) Equal(that interface{}) bool

func (*EgressRequest) GetFilter 

func (m *EgressRequest) GetFilter() *Filter

func (*EgressRequest) GetShardId 

func (m *EgressRequest) GetShardId() string

func (*EgressRequest) GoString added in v1.12.0 

func (this *EgressRequest) GoString() string

func (*EgressRequest) Marshal added in v1.12.0 

func (m *EgressRequest) Marshal() (dAtA []byte, err error)

func (*EgressRequest) MarshalTo added in v1.12.0 

func (m *EgressRequest) MarshalTo(dAtA []byte) (int, error)

func (*EgressRequest) ProtoMessage 

func (*EgressRequest) ProtoMessage()

func (*EgressRequest) Reset 

func (m *EgressRequest) Reset()

func (*EgressRequest) Size added in v1.12.0 

func (m *EgressRequest) Size() (n int)

func (*EgressRequest) String 

func (this *EgressRequest) String() string

func (*EgressRequest) Unmarshal added in v1.12.0 

func (m *EgressRequest) Unmarshal(dAtA []byte) error

type EgressServer 

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

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,json=sourceId,proto3" json:"source_id,omitempty"`
	InstanceId string            `protobuf:"bytes,8,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Tags       map[string]*Value `` /* 135-byte string literal not displayed */
	// Types that are valid to be assigned to Message:
	//	*Envelope_Log
	//	*Envelope_Counter
	//	*Envelope_Gauge
	//	*Envelope_Timer
	Message isEnvelope_Message `protobuf_oneof:"message"`
}

func (*Envelope) Descriptor 

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

func (*Envelope) Equal added in v1.12.0 

func (this *Envelope) Equal(that interface{}) bool

func (*Envelope) GetCounter 

func (m *Envelope) GetCounter() *Counter

func (*Envelope) GetGauge 

func (m *Envelope) GetGauge() *Gauge

func (*Envelope) GetInstanceId added in v1.12.0 

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]*Value

func (*Envelope) GetTimer 

func (m *Envelope) GetTimer() *Timer

func (*Envelope) GetTimestamp 

func (m *Envelope) GetTimestamp() int64

func (*Envelope) GoString added in v1.12.0 

func (this *Envelope) GoString() string

func (*Envelope) Marshal added in v1.12.0 

func (m *Envelope) Marshal() (dAtA []byte, err error)

func (*Envelope) MarshalTo added in v1.12.0 

func (m *Envelope) MarshalTo(dAtA []byte) (int, error)

func (*Envelope) ProtoMessage 

func (*Envelope) ProtoMessage()

func (*Envelope) Reset 

func (m *Envelope) Reset()

func (*Envelope) Size added in v1.12.0 

func (m *Envelope) Size() (n int)

func (*Envelope) String 

func (this *Envelope) String() string

func (*Envelope) Unmarshal added in v1.12.0 

func (m *Envelope) Unmarshal(dAtA []byte) error

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.

type Envelope_Counter 

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

func (*Envelope_Counter) Equal added in v1.12.0 

func (this *Envelope_Counter) Equal(that interface{}) bool

func (*Envelope_Counter) GoString added in v1.12.0 

func (this *Envelope_Counter) GoString() string

func (*Envelope_Counter) MarshalTo added in v1.12.0 

func (m *Envelope_Counter) MarshalTo(dAtA []byte) (int, error)

func (*Envelope_Counter) Size added in v1.12.0 

func (m *Envelope_Counter) Size() (n int)

func (*Envelope_Counter) String added in v1.12.0 

func (this *Envelope_Counter) String() string

type Envelope_Gauge 

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

func (*Envelope_Gauge) Equal added in v1.12.0 

func (this *Envelope_Gauge) Equal(that interface{}) bool

func (*Envelope_Gauge) GoString added in v1.12.0 

func (this *Envelope_Gauge) GoString() string

func (*Envelope_Gauge) MarshalTo added in v1.12.0 

func (m *Envelope_Gauge) MarshalTo(dAtA []byte) (int, error)

func (*Envelope_Gauge) Size added in v1.12.0 

func (m *Envelope_Gauge) Size() (n int)

func (*Envelope_Gauge) String added in v1.12.0 

func (this *Envelope_Gauge) String() string

type Envelope_Log 

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

func (*Envelope_Log) Equal added in v1.12.0 

func (this *Envelope_Log) Equal(that interface{}) bool

func (*Envelope_Log) GoString added in v1.12.0 

func (this *Envelope_Log) GoString() string

func (*Envelope_Log) MarshalTo added in v1.12.0 

func (m *Envelope_Log) MarshalTo(dAtA []byte) (int, error)

func (*Envelope_Log) Size added in v1.12.0 

func (m *Envelope_Log) Size() (n int)

func (*Envelope_Log) String added in v1.12.0 

func (this *Envelope_Log) String() string

type Envelope_Timer 

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

func (*Envelope_Timer) Equal added in v1.12.0 

func (this *Envelope_Timer) Equal(that interface{}) bool

func (*Envelope_Timer) GoString added in v1.12.0 

func (this *Envelope_Timer) GoString() string

func (*Envelope_Timer) MarshalTo added in v1.12.0 

func (m *Envelope_Timer) MarshalTo(dAtA []byte) (int, error)

func (*Envelope_Timer) Size added in v1.12.0 

func (m *Envelope_Timer) Size() (n int)

func (*Envelope_Timer) String added in v1.12.0 

func (this *Envelope_Timer) String() string

type Filter 

type Filter 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:
	//	*Filter_Log
	Message isFilter_Message `protobuf_oneof:"Message"`
}

func (*Filter) Descriptor 

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

func (*Filter) Equal added in v1.12.0 

func (this *Filter) Equal(that interface{}) bool

func (*Filter) GetLog added in v1.12.0 

func (m *Filter) GetLog() *LogFilter

func (*Filter) GetMessage added in v1.12.0 

func (m *Filter) GetMessage() isFilter_Message

func (*Filter) GetSourceId 

func (m *Filter) GetSourceId() string

func (*Filter) GoString added in v1.12.0 

func (this *Filter) GoString() string

func (*Filter) Marshal added in v1.12.0 

func (m *Filter) Marshal() (dAtA []byte, err error)

func (*Filter) MarshalTo added in v1.12.0 

func (m *Filter) MarshalTo(dAtA []byte) (int, error)

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) Size added in v1.12.0 

func (m *Filter) Size() (n int)

func (*Filter) String 

func (this *Filter) String() string

func (*Filter) Unmarshal added in v1.12.0 

func (m *Filter) Unmarshal(dAtA []byte) error

func (*Filter) XXX_OneofFuncs added in v1.12.0 

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

type Filter_Log added in v1.12.0 

type Filter_Log struct {
	Log *LogFilter `protobuf:"bytes,2,opt,name=log,oneof"`
}

func (*Filter_Log) Equal added in v1.12.0 

func (this *Filter_Log) Equal(that interface{}) bool

func (*Filter_Log) GoString added in v1.12.0 

func (this *Filter_Log) GoString() string

func (*Filter_Log) MarshalTo added in v1.12.0 

func (m *Filter_Log) MarshalTo(dAtA []byte) (int, error)

func (*Filter_Log) Size added in v1.12.0 

func (m *Filter_Log) Size() (n int)

func (*Filter_Log) String added in v1.12.0 

func (this *Filter_Log) String() string

type Gauge 

type Gauge struct {
	Metrics map[string]*GaugeValue `` /* 141-byte string literal not displayed */
}

func (*Gauge) Descriptor 

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

func (*Gauge) Equal added in v1.12.0 

func (this *Gauge) Equal(that interface{}) bool

func (*Gauge) GetMetrics 

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

func (*Gauge) GoString added in v1.12.0 

func (this *Gauge) GoString() string

func (*Gauge) Marshal added in v1.12.0 

func (m *Gauge) Marshal() (dAtA []byte, err error)

func (*Gauge) MarshalTo added in v1.12.0 

func (m *Gauge) MarshalTo(dAtA []byte) (int, error)

func (*Gauge) ProtoMessage 

func (*Gauge) ProtoMessage()

func (*Gauge) Reset 

func (m *Gauge) Reset()

func (*Gauge) Size added in v1.12.0 

func (m *Gauge) Size() (n int)

func (*Gauge) String 

func (this *Gauge) String() string

func (*Gauge) Unmarshal added in v1.12.0 

func (m *Gauge) Unmarshal(dAtA []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"`
}

func (*GaugeValue) Descriptor 

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

func (*GaugeValue) Equal added in v1.12.0 

func (this *GaugeValue) Equal(that interface{}) bool

func (*GaugeValue) GetUnit 

func (m *GaugeValue) GetUnit() string

func (*GaugeValue) GetValue 

func (m *GaugeValue) GetValue() float64

func (*GaugeValue) GoString added in v1.12.0 

func (this *GaugeValue) GoString() string

func (*GaugeValue) Marshal added in v1.12.0 

func (m *GaugeValue) Marshal() (dAtA []byte, err error)

func (*GaugeValue) MarshalTo added in v1.12.0 

func (m *GaugeValue) MarshalTo(dAtA []byte) (int, error)

func (*GaugeValue) ProtoMessage 

func (*GaugeValue) ProtoMessage()

func (*GaugeValue) Reset 

func (m *GaugeValue) Reset()

func (*GaugeValue) Size added in v1.12.0 

func (m *GaugeValue) Size() (n int)

func (*GaugeValue) String 

func (this *GaugeValue) String() string

func (*GaugeValue) Unmarshal added in v1.12.0 

func (m *GaugeValue) Unmarshal(dAtA []byte) error

type IngressClient 

type IngressClient interface {
	Sender(ctx context.Context, opts ...grpc.CallOption) (Ingress_SenderClient, error)
}

func NewIngressClient 

func NewIngressClient(cc *grpc.ClientConn) IngressClient

type IngressResponse 

type IngressResponse struct {
}

func (*IngressResponse) Descriptor 

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

func (*IngressResponse) Equal added in v1.12.0 

func (this *IngressResponse) Equal(that interface{}) bool

func (*IngressResponse) GoString added in v1.12.0 

func (this *IngressResponse) GoString() string

func (*IngressResponse) Marshal added in v1.12.0 

func (m *IngressResponse) Marshal() (dAtA []byte, err error)

func (*IngressResponse) MarshalTo added in v1.12.0 

func (m *IngressResponse) MarshalTo(dAtA []byte) (int, error)

func (*IngressResponse) ProtoMessage 

func (*IngressResponse) ProtoMessage()

func (*IngressResponse) Reset 

func (m *IngressResponse) Reset()

func (*IngressResponse) Size added in v1.12.0 

func (m *IngressResponse) Size() (n int)

func (*IngressResponse) String 

func (this *IngressResponse) String() string

func (*IngressResponse) Unmarshal added in v1.12.0 

func (m *IngressResponse) Unmarshal(dAtA []byte) error

type IngressServer 

type IngressServer interface {
	Sender(Ingress_SenderServer) error
}

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

func (*Log) Descriptor 

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

func (*Log) Equal added in v1.12.0 

func (this *Log) Equal(that interface{}) bool

func (*Log) GetPayload 

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

func (*Log) GetType 

func (m *Log) GetType() Log_Type

func (*Log) GoString added in v1.12.0 

func (this *Log) GoString() string

func (*Log) Marshal added in v1.12.0 

func (m *Log) Marshal() (dAtA []byte, err error)

func (*Log) MarshalTo added in v1.12.0 

func (m *Log) MarshalTo(dAtA []byte) (int, error)

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) Reset 

func (m *Log) Reset()

func (*Log) Size added in v1.12.0 

func (m *Log) Size() (n int)

func (*Log) String 

func (this *Log) String() string

func (*Log) Unmarshal added in v1.12.0 

func (m *Log) Unmarshal(dAtA []byte) error

type LogFilter added in v1.12.0 

type LogFilter struct {
}

func (*LogFilter) Descriptor added in v1.12.0 

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

func (*LogFilter) Equal added in v1.12.0 

func (this *LogFilter) Equal(that interface{}) bool

func (*LogFilter) GoString added in v1.12.0 

func (this *LogFilter) GoString() string

func (*LogFilter) Marshal added in v1.12.0 

func (m *LogFilter) Marshal() (dAtA []byte, err error)

func (*LogFilter) MarshalTo added in v1.12.0 

func (m *LogFilter) MarshalTo(dAtA []byte) (int, error)

func (*LogFilter) ProtoMessage added in v1.12.0 

func (*LogFilter) ProtoMessage()

func (*LogFilter) Reset added in v1.12.0 

func (m *LogFilter) Reset()

func (*LogFilter) Size added in v1.12.0 

func (m *LogFilter) Size() (n int)

func (*LogFilter) String added in v1.12.0 

func (this *LogFilter) String() string

func (*LogFilter) Unmarshal added in v1.12.0 

func (m *LogFilter) Unmarshal(dAtA []byte) error

type Log_Type 

type Log_Type int32
const (
	OUT Log_Type = 0
	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 MetronConfig 

type MetronConfig struct {
	UseV2API      bool   `json:"loggregator_use_v2_api"`
	APIPort       int    `json:"loggregator_api_port"`
	CACertPath    string `json:"loggregator_ca_path"`
	CertPath      string `json:"loggregator_cert_path"`
	KeyPath       string `json:"loggregator_key_path"`
	JobDeployment string `json:"loggregator_job_deployment"`
	JobName       string `json:"loggregator_job_name"`
	JobIndex      string `json:"loggregator_job_index"`
	JobIP         string `json:"loggregator_job_ip"`
	JobOrigin     string `json:"loggregator_job_origin"`
	DropsondePort int    `json:"dropsonde_port"`
}

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

func (*Timer) Descriptor 

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

func (*Timer) Equal added in v1.12.0 

func (this *Timer) Equal(that interface{}) bool

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) GoString added in v1.12.0 

func (this *Timer) GoString() string

func (*Timer) Marshal added in v1.12.0 

func (m *Timer) Marshal() (dAtA []byte, err error)

func (*Timer) MarshalTo added in v1.12.0 

func (m *Timer) MarshalTo(dAtA []byte) (int, error)

func (*Timer) ProtoMessage 

func (*Timer) ProtoMessage()

func (*Timer) Reset 

func (m *Timer) Reset()

func (*Timer) Size added in v1.12.0 

func (m *Timer) Size() (n int)

func (*Timer) String 

func (this *Timer) String() string

func (*Timer) Unmarshal added in v1.12.0 

func (m *Timer) Unmarshal(dAtA []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"`
}

func (*Value) Descriptor 

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

func (*Value) Equal added in v1.12.0 

func (this *Value) Equal(that interface{}) bool

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) GoString added in v1.12.0 

func (this *Value) GoString() string

func (*Value) Marshal added in v1.12.0 

func (m *Value) Marshal() (dAtA []byte, err error)

func (*Value) MarshalTo added in v1.12.0 

func (m *Value) MarshalTo(dAtA []byte) (int, error)

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) Size added in v1.12.0 

func (m *Value) Size() (n int)

func (*Value) String 

func (this *Value) String() string

func (*Value) Unmarshal added in v1.12.0 

func (m *Value) Unmarshal(dAtA []byte) error

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.

type Value_Decimal 

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

func (*Value_Decimal) Equal added in v1.12.0 

func (this *Value_Decimal) Equal(that interface{}) bool

func (*Value_Decimal) GoString added in v1.12.0 

func (this *Value_Decimal) GoString() string

func (*Value_Decimal) MarshalTo added in v1.12.0 

func (m *Value_Decimal) MarshalTo(dAtA []byte) (int, error)

func (*Value_Decimal) Size added in v1.12.0 

func (m *Value_Decimal) Size() (n int)

func (*Value_Decimal) String added in v1.12.0 

func (this *Value_Decimal) String() string

type Value_Integer 

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

func (*Value_Integer) Equal added in v1.12.0 

func (this *Value_Integer) Equal(that interface{}) bool

func (*Value_Integer) GoString added in v1.12.0 

func (this *Value_Integer) GoString() string

func (*Value_Integer) MarshalTo added in v1.12.0 

func (m *Value_Integer) MarshalTo(dAtA []byte) (int, error)

func (*Value_Integer) Size added in v1.12.0 

func (m *Value_Integer) Size() (n int)

func (*Value_Integer) String added in v1.12.0 

func (this *Value_Integer) String() string

type Value_Text 

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

func (*Value_Text) Equal added in v1.12.0 

func (this *Value_Text) Equal(that interface{}) bool

func (*Value_Text) GoString added in v1.12.0 

func (this *Value_Text) GoString() string

func (*Value_Text) MarshalTo added in v1.12.0 

func (m *Value_Text) MarshalTo(dAtA []byte) (int, error)

func (*Value_Text) Size added in v1.12.0 

func (m *Value_Text) Size() (n int)

func (*Value_Text) String added in v1.12.0 

func (this *Value_Text) String() string

Source Files

View all Source files

Directories

Path Synopsis
This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter
 This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter

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.