Documentation ¶
Index ¶
- Variables
- func AttachService(registry *poplar.RecorderRegistry, s *grpc.Server) error
- func ExportArtifactInfo(in *poplar.TestArtifact) *gopb.ArtifactInfo
- func ExportRollup(in *poplar.TestMetrics) *gopb.RollupValue
- func ExportTimestamp(t time.Time) *timestamppb.Timestamp
- func RegisterPoplarEventCollectorServer(s grpc.ServiceRegistrar, srv PoplarEventCollectorServer)
- func RegisterPoplarMetricsCollectorServer(s grpc.ServiceRegistrar, srv PoplarMetricsCollectorServer)
- func RegisterPoplarMetricsRecorderServer(s grpc.ServiceRegistrar, srv PoplarMetricsRecorderServer)
- type CollectorName
- type CreateOptions
- func (*CreateOptions) Descriptor() ([]byte, []int)deprecated
- func (opts *CreateOptions) Export() poplar.CreateOptions
- func (x *CreateOptions) GetBuffered() bool
- func (x *CreateOptions) GetChunkSize() int32
- func (x *CreateOptions) GetDynamic() bool
- func (x *CreateOptions) GetEvents() CreateOptions_EventsCollectorType
- func (x *CreateOptions) GetName() string
- func (x *CreateOptions) GetPath() string
- func (x *CreateOptions) GetRecorder() CreateOptions_RecorderType
- func (x *CreateOptions) GetStreaming() bool
- func (*CreateOptions) ProtoMessage()
- func (x *CreateOptions) ProtoReflect() protoreflect.Message
- func (x *CreateOptions) Reset()
- func (x *CreateOptions) String() string
- type CreateOptions_EventsCollectorType
- func (CreateOptions_EventsCollectorType) Descriptor() protoreflect.EnumDescriptor
- func (x CreateOptions_EventsCollectorType) Enum() *CreateOptions_EventsCollectorType
- func (CreateOptions_EventsCollectorType) EnumDescriptor() ([]byte, []int)deprecated
- func (ect CreateOptions_EventsCollectorType) Export() poplar.EventsCollectorType
- func (x CreateOptions_EventsCollectorType) Number() protoreflect.EnumNumber
- func (x CreateOptions_EventsCollectorType) String() string
- func (CreateOptions_EventsCollectorType) Type() protoreflect.EnumType
- type CreateOptions_RecorderType
- func (CreateOptions_RecorderType) Descriptor() protoreflect.EnumDescriptor
- func (x CreateOptions_RecorderType) Enum() *CreateOptions_RecorderType
- func (CreateOptions_RecorderType) EnumDescriptor() ([]byte, []int)deprecated
- func (rt CreateOptions_RecorderType) Export() poplar.RecorderType
- func (x CreateOptions_RecorderType) Number() protoreflect.EnumNumber
- func (x CreateOptions_RecorderType) String() string
- func (CreateOptions_RecorderType) Type() protoreflect.EnumType
- type EventMetrics
- func (*EventMetrics) Descriptor() ([]byte, []int)deprecated
- func (m *EventMetrics) Export() *events.Performance
- func (x *EventMetrics) GetCounters() *EventMetricsCounters
- func (x *EventMetrics) GetGauges() *EventMetricsGauges
- func (x *EventMetrics) GetId() int64
- func (x *EventMetrics) GetName() string
- func (x *EventMetrics) GetTime() *timestamppb.Timestamp
- func (x *EventMetrics) GetTimers() *EventMetricsTimers
- func (*EventMetrics) ProtoMessage()
- func (x *EventMetrics) ProtoReflect() protoreflect.Message
- func (x *EventMetrics) Reset()
- func (x *EventMetrics) String() string
- type EventMetricsCounters
- func (*EventMetricsCounters) Descriptor() ([]byte, []int)deprecated
- func (x *EventMetricsCounters) GetErrors() int64
- func (x *EventMetricsCounters) GetNumber() int64
- func (x *EventMetricsCounters) GetOps() int64
- func (x *EventMetricsCounters) GetSize() int64
- func (*EventMetricsCounters) ProtoMessage()
- func (x *EventMetricsCounters) ProtoReflect() protoreflect.Message
- func (x *EventMetricsCounters) Reset()
- func (x *EventMetricsCounters) String() string
- type EventMetricsGauges
- func (*EventMetricsGauges) Descriptor() ([]byte, []int)deprecated
- func (x *EventMetricsGauges) GetFailed() bool
- func (x *EventMetricsGauges) GetState() int64
- func (x *EventMetricsGauges) GetWorkers() int64
- func (*EventMetricsGauges) ProtoMessage()
- func (x *EventMetricsGauges) ProtoReflect() protoreflect.Message
- func (x *EventMetricsGauges) Reset()
- func (x *EventMetricsGauges) String() string
- type EventMetricsTimers
- func (*EventMetricsTimers) Descriptor() ([]byte, []int)deprecated
- func (x *EventMetricsTimers) GetDuration() *durationpb.Duration
- func (x *EventMetricsTimers) GetTotal() *durationpb.Duration
- func (*EventMetricsTimers) ProtoMessage()
- func (x *EventMetricsTimers) ProtoReflect() protoreflect.Message
- func (x *EventMetricsTimers) Reset()
- func (x *EventMetricsTimers) String() string
- type EventSendBool
- func (*EventSendBool) Descriptor() ([]byte, []int)deprecated
- func (x *EventSendBool) GetName() string
- func (x *EventSendBool) GetValue() bool
- func (*EventSendBool) ProtoMessage()
- func (x *EventSendBool) ProtoReflect() protoreflect.Message
- func (x *EventSendBool) Reset()
- func (x *EventSendBool) String() string
- type EventSendDuration
- func (*EventSendDuration) Descriptor() ([]byte, []int)deprecated
- func (x *EventSendDuration) GetDuration() *durationpb.Duration
- func (x *EventSendDuration) GetName() string
- func (*EventSendDuration) ProtoMessage()
- func (x *EventSendDuration) ProtoReflect() protoreflect.Message
- func (x *EventSendDuration) Reset()
- func (x *EventSendDuration) String() string
- type EventSendInt
- func (*EventSendInt) Descriptor() ([]byte, []int)deprecated
- func (x *EventSendInt) GetName() string
- func (x *EventSendInt) GetValue() int64
- func (*EventSendInt) ProtoMessage()
- func (x *EventSendInt) ProtoReflect() protoreflect.Message
- func (x *EventSendInt) Reset()
- func (x *EventSendInt) String() string
- type EventSendTime
- func (*EventSendTime) Descriptor() ([]byte, []int)deprecated
- func (x *EventSendTime) GetName() string
- func (x *EventSendTime) GetTime() *timestamppb.Timestamp
- func (*EventSendTime) ProtoMessage()
- func (x *EventSendTime) ProtoReflect() protoreflect.Message
- func (x *EventSendTime) Reset()
- func (x *EventSendTime) String() string
- type IntervalSummary
- func (*IntervalSummary) Descriptor() ([]byte, []int)deprecated
- func (x *IntervalSummary) GetCollector() string
- func (x *IntervalSummary) GetNumber() *SummaryInteger
- func (x *IntervalSummary) GetNumberValues() *SummaryIntegerSlice
- func (x *IntervalSummary) GetPoint() *SummaryDouble
- func (x *IntervalSummary) GetPointValues() *SummaryDoubleSlice
- func (m *IntervalSummary) GetValue() isIntervalSummary_Value
- func (*IntervalSummary) ProtoMessage()
- func (x *IntervalSummary) ProtoReflect() protoreflect.Message
- func (x *IntervalSummary) Reset()
- func (x *IntervalSummary) String() string
- type IntervalSummary_Number
- type IntervalSummary_NumberValues
- type IntervalSummary_Point
- type IntervalSummary_PointValues
- type PerfResult
- type PerformanceHeap
- func (h PerformanceHeap) Len() int
- func (h PerformanceHeap) Less(i, j int) bool
- func (h *PerformanceHeap) Pop() interface{}
- func (h *PerformanceHeap) Push(x interface{})
- func (h *PerformanceHeap) SafePop() *performanceHeapItem
- func (h *PerformanceHeap) SafePush(item *performanceHeapItem)
- func (h PerformanceHeap) Swap(i, j int)
- type PoplarEventCollectorClient
- type PoplarEventCollectorServer
- type PoplarEventCollector_StreamEventsClient
- type PoplarEventCollector_StreamEventsServer
- type PoplarID
- type PoplarMetricsCollectorClient
- type PoplarMetricsCollectorServer
- type PoplarMetricsRecorderClient
- type PoplarMetricsRecorderServer
- type PoplarResponse
- func (*PoplarResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PoplarResponse) GetName() string
- func (x *PoplarResponse) GetStatus() bool
- func (*PoplarResponse) ProtoMessage()
- func (x *PoplarResponse) ProtoReflect() protoreflect.Message
- func (x *PoplarResponse) Reset()
- func (x *PoplarResponse) String() string
- type SubmitPerfResultRequest
- type SummaryDouble
- func (*SummaryDouble) Descriptor() ([]byte, []int)deprecated
- func (x *SummaryDouble) GetName() string
- func (x *SummaryDouble) GetValue() float64
- func (*SummaryDouble) ProtoMessage()
- func (x *SummaryDouble) ProtoReflect() protoreflect.Message
- func (x *SummaryDouble) Reset()
- func (x *SummaryDouble) String() string
- type SummaryDoubleSlice
- func (*SummaryDoubleSlice) Descriptor() ([]byte, []int)deprecated
- func (x *SummaryDoubleSlice) GetName() string
- func (x *SummaryDoubleSlice) GetValue() []float64
- func (*SummaryDoubleSlice) ProtoMessage()
- func (x *SummaryDoubleSlice) ProtoReflect() protoreflect.Message
- func (x *SummaryDoubleSlice) Reset()
- func (x *SummaryDoubleSlice) String() string
- type SummaryInteger
- func (*SummaryInteger) Descriptor() ([]byte, []int)deprecated
- func (x *SummaryInteger) GetName() string
- func (x *SummaryInteger) GetValue() int64
- func (*SummaryInteger) ProtoMessage()
- func (x *SummaryInteger) ProtoReflect() protoreflect.Message
- func (x *SummaryInteger) Reset()
- func (x *SummaryInteger) String() string
- type SummaryIntegerSlice
- func (*SummaryIntegerSlice) Descriptor() ([]byte, []int)deprecated
- func (x *SummaryIntegerSlice) GetName() string
- func (x *SummaryIntegerSlice) GetValue() []int64
- func (*SummaryIntegerSlice) ProtoMessage()
- func (x *SummaryIntegerSlice) ProtoReflect() protoreflect.Message
- func (x *SummaryIntegerSlice) Reset()
- func (x *SummaryIntegerSlice) String() string
- type TaskInformation
- type TestInformation
- type TestMetric
- type UnimplementedPoplarEventCollectorServer
- func (UnimplementedPoplarEventCollectorServer) CloseCollector(context.Context, *PoplarID) (*PoplarResponse, error)
- func (UnimplementedPoplarEventCollectorServer) CreateCollector(context.Context, *CreateOptions) (*PoplarResponse, error)
- func (UnimplementedPoplarEventCollectorServer) RegisterStream(context.Context, *CollectorName) (*PoplarResponse, error)
- func (UnimplementedPoplarEventCollectorServer) SendEvent(context.Context, *EventMetrics) (*PoplarResponse, error)
- func (UnimplementedPoplarEventCollectorServer) StreamEvents(PoplarEventCollector_StreamEventsServer) error
- type UnimplementedPoplarMetricsCollectorServer
- func (UnimplementedPoplarMetricsCollectorServer) Add(context.Context, *IntervalSummary) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsCollectorServer) CloseCollector(context.Context, *PoplarID) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsCollectorServer) CreateCollector(context.Context, *CreateOptions) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsCollectorServer) FlushSample(context.Context, *PoplarID) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsCollectorServer) ResetSample(context.Context, *PoplarID) (*PoplarResponse, error)
- type UnimplementedPoplarMetricsRecorderServer
- func (UnimplementedPoplarMetricsRecorderServer) BeginEvent(context.Context, *PoplarID) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) CloseRecorder(context.Context, *PoplarID) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) CreateRecorder(context.Context, *CreateOptions) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) EndEvent(context.Context, *EventSendDuration) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) IncError(context.Context, *EventSendInt) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) IncIterations(context.Context, *EventSendInt) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) IncOps(context.Context, *EventSendInt) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) IncSize(context.Context, *EventSendInt) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) ResetEvent(context.Context, *PoplarID) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) SetDuration(context.Context, *EventSendDuration) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) SetFailed(context.Context, *EventSendBool) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) SetID(context.Context, *EventSendInt) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) SetState(context.Context, *EventSendInt) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) SetTime(context.Context, *EventSendTime) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) SetTotalDuration(context.Context, *EventSendDuration) (*PoplarResponse, error)
- func (UnimplementedPoplarMetricsRecorderServer) SetWorkers(context.Context, *EventSendInt) (*PoplarResponse, error)
- type UnsafePoplarEventCollectorServer
- type UnsafePoplarMetricsCollectorServer
- type UnsafePoplarMetricsRecorderServer
Constants ¶
This section is empty.
Variables ¶
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.
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.
var File_collector_proto protoreflect.FileDescriptor
var File_metrics_proto protoreflect.FileDescriptor
var File_poplar_proto protoreflect.FileDescriptor
var File_recorder_proto protoreflect.FileDescriptor
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)
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)
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) 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) ProtoMessage ¶
func (*PoplarID) ProtoMessage()
func (*PoplarID) ProtoReflect ¶
func (x *PoplarID) ProtoReflect() protoreflect.Message
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 TestInformation ¶
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.