internal

package
v0.0.0-...-9545e54 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CreateOptions_RecorderType_name = map[int32]string{
		0: "UNKNOWN_RECORDER",
		1: "PERF",
		2: "PERF_SINGLE",
		3: "PERF_100MS",
		4: "PERF_1S",
		6: "HISTOGRAM_SINGLE",
		7: "HISTOGRAM_100MS",
		8: "HISTOGRAM_1S",
		9: "INTERVAL_SUMMARIZATION",
	}
	CreateOptions_RecorderType_value = map[string]int32{
		"UNKNOWN_RECORDER":       0,
		"PERF":                   1,
		"PERF_SINGLE":            2,
		"PERF_100MS":             3,
		"PERF_1S":                4,
		"HISTOGRAM_SINGLE":       6,
		"HISTOGRAM_100MS":        7,
		"HISTOGRAM_1S":           8,
		"INTERVAL_SUMMARIZATION": 9,
	}
)

Enum value maps for CreateOptions_RecorderType.

View Source 
var (
	CreateOptions_EventsCollectorType_name = map[int32]string{
		0:  "UNKNOWN_COLLECTOR",
		1:  "BASIC",
		2:  "PASSTHROUGH",
		3:  "SAMPLING_100",
		4:  "SAMPLING_1K",
		5:  "SAMPLING_10K",
		6:  "SAMPLING_100K",
		7:  "RAND_SAMPLING_50",
		8:  "RAND_SAMPLING_25",
		9:  "RAND_SAMPLING_10",
		10: "INTERVAL_100MS",
		11: "INTERVAL_1S",
	}
	CreateOptions_EventsCollectorType_value = map[string]int32{
		"UNKNOWN_COLLECTOR": 0,
		"BASIC":             1,
		"PASSTHROUGH":       2,
		"SAMPLING_100":      3,
		"SAMPLING_1K":       4,
		"SAMPLING_10K":      5,
		"SAMPLING_100K":     6,
		"RAND_SAMPLING_50":  7,
		"RAND_SAMPLING_25":  8,
		"RAND_SAMPLING_10":  9,
		"INTERVAL_100MS":    10,
		"INTERVAL_1S":       11,
	}
)

Enum value maps for CreateOptions_EventsCollectorType.

View Source 
var File_collector_proto protoreflect.FileDescriptor
View Source 
var File_metrics_proto protoreflect.FileDescriptor
View Source 
var File_poplar_proto protoreflect.FileDescriptor
View Source 
var File_recorder_proto protoreflect.FileDescriptor
View Source 
var PoplarEventCollector_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "poplar.PoplarEventCollector",
	HandlerType: (*PoplarEventCollectorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateCollector",
			Handler:    _PoplarEventCollector_CreateCollector_Handler,
		},
		{
			MethodName: "SendEvent",
			Handler:    _PoplarEventCollector_SendEvent_Handler,
		},
		{
			MethodName: "RegisterStream",
			Handler:    _PoplarEventCollector_RegisterStream_Handler,
		},
		{
			MethodName: "CloseCollector",
			Handler:    _PoplarEventCollector_CloseCollector_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamEvents",
			Handler:       _PoplarEventCollector_StreamEvents_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "collector.proto",
}

PoplarEventCollector_ServiceDesc is the grpc.ServiceDesc for PoplarEventCollector 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 PoplarMetricsCollector_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "poplar.PoplarMetricsCollector",
	HandlerType: (*PoplarMetricsCollectorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateCollector",
			Handler:    _PoplarMetricsCollector_CreateCollector_Handler,
		},
		{
			MethodName: "CloseCollector",
			Handler:    _PoplarMetricsCollector_CloseCollector_Handler,
		},
		{
			MethodName: "ResetSample",
			Handler:    _PoplarMetricsCollector_ResetSample_Handler,
		},
		{
			MethodName: "FlushSample",
			Handler:    _PoplarMetricsCollector_FlushSample_Handler,
		},
		{
			MethodName: "Add",
			Handler:    _PoplarMetricsCollector_Add_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "metrics.proto",
}

PoplarMetricsCollector_ServiceDesc is the grpc.ServiceDesc for PoplarMetricsCollector 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 PoplarMetricsRecorder_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "poplar.PoplarMetricsRecorder",
	HandlerType: (*PoplarMetricsRecorderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateRecorder",
			Handler:    _PoplarMetricsRecorder_CreateRecorder_Handler,
		},
		{
			MethodName: "CloseRecorder",
			Handler:    _PoplarMetricsRecorder_CloseRecorder_Handler,
		},
		{
			MethodName: "BeginEvent",
			Handler:    _PoplarMetricsRecorder_BeginEvent_Handler,
		},
		{
			MethodName: "ResetEvent",
			Handler:    _PoplarMetricsRecorder_ResetEvent_Handler,
		},
		{
			MethodName: "EndEvent",
			Handler:    _PoplarMetricsRecorder_EndEvent_Handler,
		},
		{
			MethodName: "SetID",
			Handler:    _PoplarMetricsRecorder_SetID_Handler,
		},
		{
			MethodName: "SetTime",
			Handler:    _PoplarMetricsRecorder_SetTime_Handler,
		},
		{
			MethodName: "SetDuration",
			Handler:    _PoplarMetricsRecorder_SetDuration_Handler,
		},
		{
			MethodName: "SetTotalDuration",
			Handler:    _PoplarMetricsRecorder_SetTotalDuration_Handler,
		},
		{
			MethodName: "SetState",
			Handler:    _PoplarMetricsRecorder_SetState_Handler,
		},
		{
			MethodName: "SetWorkers",
			Handler:    _PoplarMetricsRecorder_SetWorkers_Handler,
		},
		{
			MethodName: "SetFailed",
			Handler:    _PoplarMetricsRecorder_SetFailed_Handler,
		},
		{
			MethodName: "IncOps",
			Handler:    _PoplarMetricsRecorder_IncOps_Handler,
		},
		{
			MethodName: "IncSize",
			Handler:    _PoplarMetricsRecorder_IncSize_Handler,
		},
		{
			MethodName: "IncError",
			Handler:    _PoplarMetricsRecorder_IncError_Handler,
		},
		{
			MethodName: "IncIterations",
			Handler:    _PoplarMetricsRecorder_IncIterations_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "recorder.proto",
}

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

Functions

func AttachService 

func AttachService(registry *poplar.RecorderRegistry, s *grpc.Server) error

func ExportArtifactInfo 

func ExportArtifactInfo(in *poplar.TestArtifact) *gopb.ArtifactInfo

func ExportRollup 

func ExportRollup(in *poplar.TestMetrics) *gopb.RollupValue

func ExportTimestamp 

func ExportTimestamp(t time.Time) *timestamppb.Timestamp

func RegisterPoplarEventCollectorServer 

func RegisterPoplarEventCollectorServer(s grpc.ServiceRegistrar, srv PoplarEventCollectorServer)

func RegisterPoplarMetricsCollectorServer 

func RegisterPoplarMetricsCollectorServer(s grpc.ServiceRegistrar, srv PoplarMetricsCollectorServer)

func RegisterPoplarMetricsRecorderServer 

func RegisterPoplarMetricsRecorderServer(s grpc.ServiceRegistrar, srv PoplarMetricsRecorderServer)

Types

type CollectorName 

type CollectorName struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectorName) Descriptor deprecated 

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

Deprecated: Use CollectorName.ProtoReflect.Descriptor instead.

func (*CollectorName) GetName 

func (x *CollectorName) GetName() string

func (*CollectorName) ProtoMessage 

func (*CollectorName) ProtoMessage()

func (*CollectorName) ProtoReflect 

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

func (*CollectorName) Reset 

func (x *CollectorName) Reset()

func (*CollectorName) String 

func (x *CollectorName) String() string

type CreateOptions 

type CreateOptions struct {
	Name      string                            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Path      string                            `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	ChunkSize int32                             `protobuf:"varint,3,opt,name=chunkSize,proto3" json:"chunkSize,omitempty"`
	Streaming bool                              `protobuf:"varint,4,opt,name=streaming,proto3" json:"streaming,omitempty"`
	Dynamic   bool                              `protobuf:"varint,5,opt,name=dynamic,proto3" json:"dynamic,omitempty"`
	Recorder  CreateOptions_RecorderType        `protobuf:"varint,6,opt,name=recorder,proto3,enum=poplar.CreateOptions_RecorderType" json:"recorder,omitempty"`
	Events    CreateOptions_EventsCollectorType `protobuf:"varint,7,opt,name=events,proto3,enum=poplar.CreateOptions_EventsCollectorType" json:"events,omitempty"`
	Buffered  bool                              `protobuf:"varint,8,opt,name=buffered,proto3" json:"buffered,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateOptions) Descriptor deprecated 

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

Deprecated: Use CreateOptions.ProtoReflect.Descriptor instead.

func (*CreateOptions) Export 

func (opts *CreateOptions) Export() poplar.CreateOptions

func (*CreateOptions) GetBuffered 

func (x *CreateOptions) GetBuffered() bool

func (*CreateOptions) GetChunkSize 

func (x *CreateOptions) GetChunkSize() int32

func (*CreateOptions) GetDynamic 

func (x *CreateOptions) GetDynamic() bool

func (*CreateOptions) GetEvents 

func (x *CreateOptions) GetEvents() CreateOptions_EventsCollectorType

func (*CreateOptions) GetName 

func (x *CreateOptions) GetName() string

func (*CreateOptions) GetPath 

func (x *CreateOptions) GetPath() string

func (*CreateOptions) GetRecorder 

func (x *CreateOptions) GetRecorder() CreateOptions_RecorderType

func (*CreateOptions) GetStreaming 

func (x *CreateOptions) GetStreaming() bool

func (*CreateOptions) ProtoMessage 

func (*CreateOptions) ProtoMessage()

func (*CreateOptions) ProtoReflect 

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

func (*CreateOptions) Reset 

func (x *CreateOptions) Reset()

func (*CreateOptions) String 

func (x *CreateOptions) String() string

type CreateOptions_EventsCollectorType 

type CreateOptions_EventsCollectorType int32
const (
	CreateOptions_UNKNOWN_COLLECTOR CreateOptions_EventsCollectorType = 0
	CreateOptions_BASIC             CreateOptions_EventsCollectorType = 1
	CreateOptions_PASSTHROUGH       CreateOptions_EventsCollectorType = 2
	CreateOptions_SAMPLING_100      CreateOptions_EventsCollectorType = 3
	CreateOptions_SAMPLING_1K       CreateOptions_EventsCollectorType = 4
	CreateOptions_SAMPLING_10K      CreateOptions_EventsCollectorType = 5
	CreateOptions_SAMPLING_100K     CreateOptions_EventsCollectorType = 6
	CreateOptions_RAND_SAMPLING_50  CreateOptions_EventsCollectorType = 7
	CreateOptions_RAND_SAMPLING_25  CreateOptions_EventsCollectorType = 8
	CreateOptions_RAND_SAMPLING_10  CreateOptions_EventsCollectorType = 9
	CreateOptions_INTERVAL_100MS    CreateOptions_EventsCollectorType = 10
	CreateOptions_INTERVAL_1S       CreateOptions_EventsCollectorType = 11
)

func (CreateOptions_EventsCollectorType) Descriptor 

func (CreateOptions_EventsCollectorType) Descriptor() protoreflect.EnumDescriptor

func (CreateOptions_EventsCollectorType) Enum 

func (x CreateOptions_EventsCollectorType) Enum() *CreateOptions_EventsCollectorType

func (CreateOptions_EventsCollectorType) EnumDescriptor deprecated 

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

Deprecated: Use CreateOptions_EventsCollectorType.Descriptor instead.

func (CreateOptions_EventsCollectorType) Export 

func (ect CreateOptions_EventsCollectorType) Export() poplar.EventsCollectorType

func (CreateOptions_EventsCollectorType) Number 

func (x CreateOptions_EventsCollectorType) Number() protoreflect.EnumNumber

func (CreateOptions_EventsCollectorType) String 

func (x CreateOptions_EventsCollectorType) String() string

func (CreateOptions_EventsCollectorType) Type 

func (CreateOptions_EventsCollectorType) Type() protoreflect.EnumType

type CreateOptions_RecorderType 

type CreateOptions_RecorderType int32
const (
	CreateOptions_UNKNOWN_RECORDER       CreateOptions_RecorderType = 0
	CreateOptions_PERF                   CreateOptions_RecorderType = 1
	CreateOptions_PERF_SINGLE            CreateOptions_RecorderType = 2
	CreateOptions_PERF_100MS             CreateOptions_RecorderType = 3
	CreateOptions_PERF_1S                CreateOptions_RecorderType = 4
	CreateOptions_HISTOGRAM_SINGLE       CreateOptions_RecorderType = 6
	CreateOptions_HISTOGRAM_100MS        CreateOptions_RecorderType = 7
	CreateOptions_HISTOGRAM_1S           CreateOptions_RecorderType = 8
	CreateOptions_INTERVAL_SUMMARIZATION CreateOptions_RecorderType = 9
)

func (CreateOptions_RecorderType) Descriptor 

func (CreateOptions_RecorderType) Descriptor() protoreflect.EnumDescriptor

func (CreateOptions_RecorderType) Enum 

func (x CreateOptions_RecorderType) Enum() *CreateOptions_RecorderType

func (CreateOptions_RecorderType) EnumDescriptor deprecated 

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

Deprecated: Use CreateOptions_RecorderType.Descriptor instead.

func (CreateOptions_RecorderType) Export 

func (rt CreateOptions_RecorderType) Export() poplar.RecorderType

func (CreateOptions_RecorderType) Number 

func (x CreateOptions_RecorderType) Number() protoreflect.EnumNumber

func (CreateOptions_RecorderType) String 

func (x CreateOptions_RecorderType) String() string

func (CreateOptions_RecorderType) Type 

func (CreateOptions_RecorderType) Type() protoreflect.EnumType

type EventMetrics 

type EventMetrics struct {
	Name     string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Time     *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	Id       int64                  `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	Counters *EventMetricsCounters  `protobuf:"bytes,4,opt,name=counters,proto3" json:"counters,omitempty"`
	Timers   *EventMetricsTimers    `protobuf:"bytes,5,opt,name=timers,proto3" json:"timers,omitempty"`
	Gauges   *EventMetricsGauges    `protobuf:"bytes,6,opt,name=gauges,proto3" json:"gauges,omitempty"`
	// contains filtered or unexported fields
}

func (*EventMetrics) Descriptor deprecated 

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

Deprecated: Use EventMetrics.ProtoReflect.Descriptor instead.

func (*EventMetrics) Export 

func (m *EventMetrics) Export() *events.Performance

func (*EventMetrics) GetCounters 

func (x *EventMetrics) GetCounters() *EventMetricsCounters

func (*EventMetrics) GetGauges 

func (x *EventMetrics) GetGauges() *EventMetricsGauges

func (*EventMetrics) GetId 

func (x *EventMetrics) GetId() int64

func (*EventMetrics) GetName 

func (x *EventMetrics) GetName() string

func (*EventMetrics) GetTime 

func (x *EventMetrics) GetTime() *timestamppb.Timestamp

func (*EventMetrics) GetTimers 

func (x *EventMetrics) GetTimers() *EventMetricsTimers

func (*EventMetrics) ProtoMessage 

func (*EventMetrics) ProtoMessage()

func (*EventMetrics) ProtoReflect 

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

func (*EventMetrics) Reset 

func (x *EventMetrics) Reset()

func (*EventMetrics) String 

func (x *EventMetrics) String() string

type EventMetricsCounters 

type EventMetricsCounters struct {
	Number int64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	Ops    int64 `protobuf:"varint,2,opt,name=ops,proto3" json:"ops,omitempty"`
	Size   int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	Errors int64 `protobuf:"varint,4,opt,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*EventMetricsCounters) Descriptor deprecated 

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

Deprecated: Use EventMetricsCounters.ProtoReflect.Descriptor instead.

func (*EventMetricsCounters) GetErrors 

func (x *EventMetricsCounters) GetErrors() int64

func (*EventMetricsCounters) GetNumber 

func (x *EventMetricsCounters) GetNumber() int64

func (*EventMetricsCounters) GetOps 

func (x *EventMetricsCounters) GetOps() int64

func (*EventMetricsCounters) GetSize 

func (x *EventMetricsCounters) GetSize() int64

func (*EventMetricsCounters) ProtoMessage 

func (*EventMetricsCounters) ProtoMessage()

func (*EventMetricsCounters) ProtoReflect 

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

func (*EventMetricsCounters) Reset 

func (x *EventMetricsCounters) Reset()

func (*EventMetricsCounters) String 

func (x *EventMetricsCounters) String() string

type EventMetricsGauges 

type EventMetricsGauges struct {
	State   int64 `protobuf:"varint,1,opt,name=state,proto3" json:"state,omitempty"`
	Workers int64 `protobuf:"varint,2,opt,name=workers,proto3" json:"workers,omitempty"`
	Failed  bool  `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"`
	// contains filtered or unexported fields
}

func (*EventMetricsGauges) Descriptor deprecated 

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

Deprecated: Use EventMetricsGauges.ProtoReflect.Descriptor instead.

func (*EventMetricsGauges) GetFailed 

func (x *EventMetricsGauges) GetFailed() bool

func (*EventMetricsGauges) GetState 

func (x *EventMetricsGauges) GetState() int64

func (*EventMetricsGauges) GetWorkers 

func (x *EventMetricsGauges) GetWorkers() int64

func (*EventMetricsGauges) ProtoMessage 

func (*EventMetricsGauges) ProtoMessage()

func (*EventMetricsGauges) ProtoReflect 

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

func (*EventMetricsGauges) Reset 

func (x *EventMetricsGauges) Reset()

func (*EventMetricsGauges) String 

func (x *EventMetricsGauges) String() string

type EventMetricsTimers 

type EventMetricsTimers struct {
	Total    *durationpb.Duration `protobuf:"bytes,1,opt,name=total,proto3" json:"total,omitempty"`
	Duration *durationpb.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (*EventMetricsTimers) Descriptor deprecated 

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

Deprecated: Use EventMetricsTimers.ProtoReflect.Descriptor instead.

func (*EventMetricsTimers) GetDuration 

func (x *EventMetricsTimers) GetDuration() *durationpb.Duration

func (*EventMetricsTimers) GetTotal 

func (x *EventMetricsTimers) GetTotal() *durationpb.Duration

func (*EventMetricsTimers) ProtoMessage 

func (*EventMetricsTimers) ProtoMessage()

func (*EventMetricsTimers) ProtoReflect 

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

func (*EventMetricsTimers) Reset 

func (x *EventMetricsTimers) Reset()

func (*EventMetricsTimers) String 

func (x *EventMetricsTimers) String() string

type EventSendBool 

type EventSendBool struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value bool   `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*EventSendBool) Descriptor deprecated 

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

Deprecated: Use EventSendBool.ProtoReflect.Descriptor instead.

func (*EventSendBool) GetName 

func (x *EventSendBool) GetName() string

func (*EventSendBool) GetValue 

func (x *EventSendBool) GetValue() bool

func (*EventSendBool) ProtoMessage 

func (*EventSendBool) ProtoMessage()

func (*EventSendBool) ProtoReflect 

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

func (*EventSendBool) Reset 

func (x *EventSendBool) Reset()

func (*EventSendBool) String 

func (x *EventSendBool) String() string

type EventSendDuration 

type EventSendDuration struct {
	Name     string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Duration *durationpb.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (*EventSendDuration) Descriptor deprecated 

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

Deprecated: Use EventSendDuration.ProtoReflect.Descriptor instead.

func (*EventSendDuration) GetDuration 

func (x *EventSendDuration) GetDuration() *durationpb.Duration

func (*EventSendDuration) GetName 

func (x *EventSendDuration) GetName() string

func (*EventSendDuration) ProtoMessage 

func (*EventSendDuration) ProtoMessage()

func (*EventSendDuration) ProtoReflect 

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

func (*EventSendDuration) Reset 

func (x *EventSendDuration) Reset()

func (*EventSendDuration) String 

func (x *EventSendDuration) String() string

type EventSendInt 

type EventSendInt struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value int64  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*EventSendInt) Descriptor deprecated 

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

Deprecated: Use EventSendInt.ProtoReflect.Descriptor instead.

func (*EventSendInt) GetName 

func (x *EventSendInt) GetName() string

func (*EventSendInt) GetValue 

func (x *EventSendInt) GetValue() int64

func (*EventSendInt) ProtoMessage 

func (*EventSendInt) ProtoMessage()

func (*EventSendInt) ProtoReflect 

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

func (*EventSendInt) Reset 

func (x *EventSendInt) Reset()

func (*EventSendInt) String 

func (x *EventSendInt) String() string

type EventSendTime 

type EventSendTime struct {
	Name string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*EventSendTime) Descriptor deprecated 

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

Deprecated: Use EventSendTime.ProtoReflect.Descriptor instead.

func (*EventSendTime) GetName 

func (x *EventSendTime) GetName() string

func (*EventSendTime) GetTime 

func (x *EventSendTime) GetTime() *timestamppb.Timestamp

func (*EventSendTime) ProtoMessage 

func (*EventSendTime) ProtoMessage()

func (*EventSendTime) ProtoReflect 

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

func (*EventSendTime) Reset 

func (x *EventSendTime) Reset()

func (*EventSendTime) String 

func (x *EventSendTime) String() string

type IntervalSummary 

type IntervalSummary struct {
	Collector string `protobuf:"bytes,1,opt,name=collector,proto3" json:"collector,omitempty"`
	// Types that are assignable to Value:
	//	*IntervalSummary_Number
	//	*IntervalSummary_NumberValues
	//	*IntervalSummary_Point
	//	*IntervalSummary_PointValues
	Value isIntervalSummary_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*IntervalSummary) Descriptor deprecated 

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

Deprecated: Use IntervalSummary.ProtoReflect.Descriptor instead.

func (*IntervalSummary) GetCollector 

func (x *IntervalSummary) GetCollector() string

func (*IntervalSummary) GetNumber 

func (x *IntervalSummary) GetNumber() *SummaryInteger

func (*IntervalSummary) GetNumberValues 

func (x *IntervalSummary) GetNumberValues() *SummaryIntegerSlice

func (*IntervalSummary) GetPoint 

func (x *IntervalSummary) GetPoint() *SummaryDouble

func (*IntervalSummary) GetPointValues 

func (x *IntervalSummary) GetPointValues() *SummaryDoubleSlice

func (*IntervalSummary) GetValue 

func (m *IntervalSummary) GetValue() isIntervalSummary_Value

func (*IntervalSummary) ProtoMessage 

func (*IntervalSummary) ProtoMessage()

func (*IntervalSummary) ProtoReflect 

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

func (*IntervalSummary) Reset 

func (x *IntervalSummary) Reset()

func (*IntervalSummary) String 

func (x *IntervalSummary) String() string

type IntervalSummary_Number 

type IntervalSummary_Number struct {
	Number *SummaryInteger `protobuf:"bytes,2,opt,name=number,proto3,oneof"`
}

type IntervalSummary_NumberValues 

type IntervalSummary_NumberValues struct {
	NumberValues *SummaryIntegerSlice `protobuf:"bytes,3,opt,name=number_values,json=numberValues,proto3,oneof"`
}

type IntervalSummary_Point 

type IntervalSummary_Point struct {
	Point *SummaryDouble `protobuf:"bytes,4,opt,name=point,proto3,oneof"`
}

type IntervalSummary_PointValues 

type IntervalSummary_PointValues struct {
	PointValues *SummaryDoubleSlice `protobuf:"bytes,5,opt,name=point_values,json=pointValues,proto3,oneof"`
}

type PerfResult 

type PerfResult struct {
	Info        TestInformation `json:"info"`
	CreatedAt   time.Time       `json:"created_at"`
	CompletedAt time.Time       `json:"completed_at"`
	Metrics     []TestMetric    `json:"metrics"`
}

func GatherPerfResults 

func GatherPerfResults(report *poplar.Report) []PerfResult

type PerformanceHeap 

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

PerformanceHeap is a min heap of ftdc/events.Performance objects.

func (PerformanceHeap) Len 

func (h PerformanceHeap) Len() int

Len returns the size of the heap.

func (PerformanceHeap) Less 

func (h PerformanceHeap) Less(i, j int) bool

Less returns true if the object at index i is less than the object at index j in the heap, false otherwise.

func (*PerformanceHeap) Pop 

func (h *PerformanceHeap) Pop() interface{}

Pop returns the next object (as an empty interface) from the heap. Note that if the heap is empty this will panic.

func (*PerformanceHeap) Push 

func (h *PerformanceHeap) Push(x interface{})

Push appends a new object of type Performance to the heap. Note that if x is not a performanceHeapItem object nothing happens.

func (*PerformanceHeap) SafePop 

func (h *PerformanceHeap) SafePop() *performanceHeapItem

SafePop is a wrapper function around heap.Pop that converts the returned interface into a pointer to a performanceHeapItem object before returning it.

func (*PerformanceHeap) SafePush 

func (h *PerformanceHeap) SafePush(item *performanceHeapItem)

SafePush is a wrapper function around heap.Push that ensures, during compile time, that the correct type of object is put in the heap.

func (PerformanceHeap) Swap 

func (h PerformanceHeap) Swap(i, j int)

Swap swaps the objects at indexes i and j.

type PoplarEventCollectorClient 

type PoplarEventCollectorClient interface {
	CreateCollector(ctx context.Context, in *CreateOptions, opts ...grpc.CallOption) (*PoplarResponse, error)
	SendEvent(ctx context.Context, in *EventMetrics, opts ...grpc.CallOption) (*PoplarResponse, error)
	RegisterStream(ctx context.Context, in *CollectorName, opts ...grpc.CallOption) (*PoplarResponse, error)
	StreamEvents(ctx context.Context, opts ...grpc.CallOption) (PoplarEventCollector_StreamEventsClient, error)
	CloseCollector(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
}

PoplarEventCollectorClient is the client API for PoplarEventCollector 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 NewPoplarEventCollectorClient 

func NewPoplarEventCollectorClient(cc grpc.ClientConnInterface) PoplarEventCollectorClient

type PoplarEventCollectorServer 

type PoplarEventCollectorServer interface {
	CreateCollector(context.Context, *CreateOptions) (*PoplarResponse, error)
	SendEvent(context.Context, *EventMetrics) (*PoplarResponse, error)
	RegisterStream(context.Context, *CollectorName) (*PoplarResponse, error)
	StreamEvents(PoplarEventCollector_StreamEventsServer) error
	CloseCollector(context.Context, *PoplarID) (*PoplarResponse, error)
	// contains filtered or unexported methods
}

PoplarEventCollectorServer is the server API for PoplarEventCollector service. All implementations must embed UnimplementedPoplarEventCollectorServer for forward compatibility

type PoplarEventCollector_StreamEventsClient 

type PoplarEventCollector_StreamEventsClient interface {
	Send(*EventMetrics) error
	CloseAndRecv() (*PoplarResponse, error)
	grpc.ClientStream
}

type PoplarEventCollector_StreamEventsServer 

type PoplarEventCollector_StreamEventsServer interface {
	SendAndClose(*PoplarResponse) error
	Recv() (*EventMetrics, error)
	grpc.ServerStream
}

type PoplarID 

type PoplarID struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*PoplarID) Descriptor deprecated 

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

Deprecated: Use PoplarID.ProtoReflect.Descriptor instead.

func (*PoplarID) GetName 

func (x *PoplarID) GetName() string

func (*PoplarID) ProtoMessage 

func (*PoplarID) ProtoMessage()

func (*PoplarID) ProtoReflect 

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

func (*PoplarID) Reset 

func (x *PoplarID) Reset()

func (*PoplarID) String 

func (x *PoplarID) String() string

type PoplarMetricsCollectorClient 

type PoplarMetricsCollectorClient interface {
	CreateCollector(ctx context.Context, in *CreateOptions, opts ...grpc.CallOption) (*PoplarResponse, error)
	CloseCollector(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
	ResetSample(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
	FlushSample(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
	Add(ctx context.Context, in *IntervalSummary, opts ...grpc.CallOption) (*PoplarResponse, error)
}

PoplarMetricsCollectorClient is the client API for PoplarMetricsCollector 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 NewPoplarMetricsCollectorClient 

func NewPoplarMetricsCollectorClient(cc grpc.ClientConnInterface) PoplarMetricsCollectorClient

type PoplarMetricsCollectorServer 

type PoplarMetricsCollectorServer interface {
	CreateCollector(context.Context, *CreateOptions) (*PoplarResponse, error)
	CloseCollector(context.Context, *PoplarID) (*PoplarResponse, error)
	ResetSample(context.Context, *PoplarID) (*PoplarResponse, error)
	FlushSample(context.Context, *PoplarID) (*PoplarResponse, error)
	Add(context.Context, *IntervalSummary) (*PoplarResponse, error)
	// contains filtered or unexported methods
}

PoplarMetricsCollectorServer is the server API for PoplarMetricsCollector service. All implementations must embed UnimplementedPoplarMetricsCollectorServer for forward compatibility

type PoplarMetricsRecorderClient 

type PoplarMetricsRecorderClient interface {
	// Create builds a new recorder instance which creates a local file,
	// while the close recorder method flushes the contents of that
	// recorder and closes the file.
	CreateRecorder(ctx context.Context, in *CreateOptions, opts ...grpc.CallOption) (*PoplarResponse, error)
	CloseRecorder(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
	// Event Lifecycle methods
	BeginEvent(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
	ResetEvent(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
	EndEvent(ctx context.Context, in *EventSendDuration, opts ...grpc.CallOption) (*PoplarResponse, error)
	SetID(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
	// Timers
	SetTime(ctx context.Context, in *EventSendTime, opts ...grpc.CallOption) (*PoplarResponse, error)
	SetDuration(ctx context.Context, in *EventSendDuration, opts ...grpc.CallOption) (*PoplarResponse, error)
	SetTotalDuration(ctx context.Context, in *EventSendDuration, opts ...grpc.CallOption) (*PoplarResponse, error)
	// Guages
	SetState(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
	SetWorkers(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
	SetFailed(ctx context.Context, in *EventSendBool, opts ...grpc.CallOption) (*PoplarResponse, error)
	// Counters
	IncOps(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
	IncSize(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
	IncError(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
	IncIterations(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
}

PoplarMetricsRecorderClient is the client API for PoplarMetricsRecorder 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 NewPoplarMetricsRecorderClient 

func NewPoplarMetricsRecorderClient(cc grpc.ClientConnInterface) PoplarMetricsRecorderClient

type PoplarMetricsRecorderServer 

type PoplarMetricsRecorderServer interface {
	// Create builds a new recorder instance which creates a local file,
	// while the close recorder method flushes the contents of that
	// recorder and closes the file.
	CreateRecorder(context.Context, *CreateOptions) (*PoplarResponse, error)
	CloseRecorder(context.Context, *PoplarID) (*PoplarResponse, error)
	// Event Lifecycle methods
	BeginEvent(context.Context, *PoplarID) (*PoplarResponse, error)
	ResetEvent(context.Context, *PoplarID) (*PoplarResponse, error)
	EndEvent(context.Context, *EventSendDuration) (*PoplarResponse, error)
	SetID(context.Context, *EventSendInt) (*PoplarResponse, error)
	// Timers
	SetTime(context.Context, *EventSendTime) (*PoplarResponse, error)
	SetDuration(context.Context, *EventSendDuration) (*PoplarResponse, error)
	SetTotalDuration(context.Context, *EventSendDuration) (*PoplarResponse, error)
	// Guages
	SetState(context.Context, *EventSendInt) (*PoplarResponse, error)
	SetWorkers(context.Context, *EventSendInt) (*PoplarResponse, error)
	SetFailed(context.Context, *EventSendBool) (*PoplarResponse, error)
	// Counters
	IncOps(context.Context, *EventSendInt) (*PoplarResponse, error)
	IncSize(context.Context, *EventSendInt) (*PoplarResponse, error)
	IncError(context.Context, *EventSendInt) (*PoplarResponse, error)
	IncIterations(context.Context, *EventSendInt) (*PoplarResponse, error)
	// contains filtered or unexported methods
}

PoplarMetricsRecorderServer is the server API for PoplarMetricsRecorder service. All implementations must embed UnimplementedPoplarMetricsRecorderServer for forward compatibility

type PoplarResponse 

type PoplarResponse struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Status bool   `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*PoplarResponse) Descriptor deprecated 

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

Deprecated: Use PoplarResponse.ProtoReflect.Descriptor instead.

func (*PoplarResponse) GetName 

func (x *PoplarResponse) GetName() string

func (*PoplarResponse) GetStatus 

func (x *PoplarResponse) GetStatus() bool

func (*PoplarResponse) ProtoMessage 

func (*PoplarResponse) ProtoMessage()

func (*PoplarResponse) ProtoReflect 

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

func (*PoplarResponse) Reset 

func (x *PoplarResponse) Reset()

func (*PoplarResponse) String 

func (x *PoplarResponse) String() string

type SubmitPerfResultRequest 

type SubmitPerfResultRequest struct {
	Id      TaskInformation `json:"id"`
	Results []PerfResult    `json:"results"`
}

type SummaryDouble 

type SummaryDouble struct {
	Name  string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SummaryDouble) Descriptor deprecated 

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

Deprecated: Use SummaryDouble.ProtoReflect.Descriptor instead.

func (*SummaryDouble) GetName 

func (x *SummaryDouble) GetName() string

func (*SummaryDouble) GetValue 

func (x *SummaryDouble) GetValue() float64

func (*SummaryDouble) ProtoMessage 

func (*SummaryDouble) ProtoMessage()

func (*SummaryDouble) ProtoReflect 

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

func (*SummaryDouble) Reset 

func (x *SummaryDouble) Reset()

func (*SummaryDouble) String 

func (x *SummaryDouble) String() string

type SummaryDoubleSlice 

type SummaryDoubleSlice struct {
	Name  string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []float64 `protobuf:"fixed64,2,rep,packed,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SummaryDoubleSlice) Descriptor deprecated 

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

Deprecated: Use SummaryDoubleSlice.ProtoReflect.Descriptor instead.

func (*SummaryDoubleSlice) GetName 

func (x *SummaryDoubleSlice) GetName() string

func (*SummaryDoubleSlice) GetValue 

func (x *SummaryDoubleSlice) GetValue() []float64

func (*SummaryDoubleSlice) ProtoMessage 

func (*SummaryDoubleSlice) ProtoMessage()

func (*SummaryDoubleSlice) ProtoReflect 

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

func (*SummaryDoubleSlice) Reset 

func (x *SummaryDoubleSlice) Reset()

func (*SummaryDoubleSlice) String 

func (x *SummaryDoubleSlice) String() string

type SummaryInteger 

type SummaryInteger struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value int64  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SummaryInteger) Descriptor deprecated 

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

Deprecated: Use SummaryInteger.ProtoReflect.Descriptor instead.

func (*SummaryInteger) GetName 

func (x *SummaryInteger) GetName() string

func (*SummaryInteger) GetValue 

func (x *SummaryInteger) GetValue() int64

func (*SummaryInteger) ProtoMessage 

func (*SummaryInteger) ProtoMessage()

func (*SummaryInteger) ProtoReflect 

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

func (*SummaryInteger) Reset 

func (x *SummaryInteger) Reset()

func (*SummaryInteger) String 

func (x *SummaryInteger) String() string

type SummaryIntegerSlice 

type SummaryIntegerSlice struct {
	Name  string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []int64 `protobuf:"varint,2,rep,packed,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SummaryIntegerSlice) Descriptor deprecated 

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

Deprecated: Use SummaryIntegerSlice.ProtoReflect.Descriptor instead.

func (*SummaryIntegerSlice) GetName 

func (x *SummaryIntegerSlice) GetName() string

func (*SummaryIntegerSlice) GetValue 

func (x *SummaryIntegerSlice) GetValue() []int64

func (*SummaryIntegerSlice) ProtoMessage 

func (*SummaryIntegerSlice) ProtoMessage()

func (*SummaryIntegerSlice) ProtoReflect 

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

func (*SummaryIntegerSlice) Reset 

func (x *SummaryIntegerSlice) Reset()

func (*SummaryIntegerSlice) String 

func (x *SummaryIntegerSlice) String() string

type TaskInformation 

type TaskInformation struct {
	Project   string `json:"project"`
	Version   string `json:"version"`
	Variant   string `json:"variant"`
	Order     int    `json:"order"`
	TaskName  string `json:"task_name"`
	TaskId    string `json:"task_id"`
	Execution int    `json:"execution"`
	Mainline  bool   `json:"mainline"`
}

type TestInformation 

type TestInformation struct {
	TestName  string           `json:"test_name"`
	Arguments map[string]int32 `json:"arguments"`
}

type TestMetric 

type TestMetric struct {
	Name  string      `json:"name"`
	Value interface{} `json:"value"`
}

type UnimplementedPoplarEventCollectorServer 

type UnimplementedPoplarEventCollectorServer struct {
}

UnimplementedPoplarEventCollectorServer must be embedded to have forward compatible implementations.

func (UnimplementedPoplarEventCollectorServer) CloseCollector 

func (UnimplementedPoplarEventCollectorServer) CloseCollector(context.Context, *PoplarID) (*PoplarResponse, error)

func (UnimplementedPoplarEventCollectorServer) CreateCollector 

func (UnimplementedPoplarEventCollectorServer) CreateCollector(context.Context, *CreateOptions) (*PoplarResponse, error)

func (UnimplementedPoplarEventCollectorServer) RegisterStream 

func (UnimplementedPoplarEventCollectorServer) RegisterStream(context.Context, *CollectorName) (*PoplarResponse, error)

func (UnimplementedPoplarEventCollectorServer) SendEvent 

func (UnimplementedPoplarEventCollectorServer) SendEvent(context.Context, *EventMetrics) (*PoplarResponse, error)

func (UnimplementedPoplarEventCollectorServer) StreamEvents 

func (UnimplementedPoplarEventCollectorServer) StreamEvents(PoplarEventCollector_StreamEventsServer) error

type UnimplementedPoplarMetricsCollectorServer 

type UnimplementedPoplarMetricsCollectorServer struct {
}

UnimplementedPoplarMetricsCollectorServer must be embedded to have forward compatible implementations.

func (UnimplementedPoplarMetricsCollectorServer) Add 

func (UnimplementedPoplarMetricsCollectorServer) Add(context.Context, *IntervalSummary) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsCollectorServer) CloseCollector 

func (UnimplementedPoplarMetricsCollectorServer) CloseCollector(context.Context, *PoplarID) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsCollectorServer) CreateCollector 

func (UnimplementedPoplarMetricsCollectorServer) CreateCollector(context.Context, *CreateOptions) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsCollectorServer) FlushSample 

func (UnimplementedPoplarMetricsCollectorServer) FlushSample(context.Context, *PoplarID) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsCollectorServer) ResetSample 

func (UnimplementedPoplarMetricsCollectorServer) ResetSample(context.Context, *PoplarID) (*PoplarResponse, error)

type UnimplementedPoplarMetricsRecorderServer 

type UnimplementedPoplarMetricsRecorderServer struct {
}

UnimplementedPoplarMetricsRecorderServer must be embedded to have forward compatible implementations.

func (UnimplementedPoplarMetricsRecorderServer) BeginEvent 

func (UnimplementedPoplarMetricsRecorderServer) BeginEvent(context.Context, *PoplarID) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) CloseRecorder 

func (UnimplementedPoplarMetricsRecorderServer) CloseRecorder(context.Context, *PoplarID) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) CreateRecorder 

func (UnimplementedPoplarMetricsRecorderServer) CreateRecorder(context.Context, *CreateOptions) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) EndEvent 

func (UnimplementedPoplarMetricsRecorderServer) EndEvent(context.Context, *EventSendDuration) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) IncError 

func (UnimplementedPoplarMetricsRecorderServer) IncError(context.Context, *EventSendInt) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) IncIterations 

func (UnimplementedPoplarMetricsRecorderServer) IncIterations(context.Context, *EventSendInt) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) IncOps 

func (UnimplementedPoplarMetricsRecorderServer) IncOps(context.Context, *EventSendInt) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) IncSize 

func (UnimplementedPoplarMetricsRecorderServer) IncSize(context.Context, *EventSendInt) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) ResetEvent 

func (UnimplementedPoplarMetricsRecorderServer) ResetEvent(context.Context, *PoplarID) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) SetDuration 

func (UnimplementedPoplarMetricsRecorderServer) SetDuration(context.Context, *EventSendDuration) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) SetFailed 

func (UnimplementedPoplarMetricsRecorderServer) SetFailed(context.Context, *EventSendBool) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) SetID 

func (UnimplementedPoplarMetricsRecorderServer) SetID(context.Context, *EventSendInt) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) SetState 

func (UnimplementedPoplarMetricsRecorderServer) SetState(context.Context, *EventSendInt) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) SetTime 

func (UnimplementedPoplarMetricsRecorderServer) SetTime(context.Context, *EventSendTime) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) SetTotalDuration 

func (UnimplementedPoplarMetricsRecorderServer) SetTotalDuration(context.Context, *EventSendDuration) (*PoplarResponse, error)

func (UnimplementedPoplarMetricsRecorderServer) SetWorkers 

func (UnimplementedPoplarMetricsRecorderServer) SetWorkers(context.Context, *EventSendInt) (*PoplarResponse, error)

type UnsafePoplarEventCollectorServer 

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

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

type UnsafePoplarMetricsCollectorServer 

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

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

type UnsafePoplarMetricsRecorderServer 

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

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

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.