internal

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

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
}

type CreateOptions_EventsCollectorType int32

type CreateOptions_RecorderType int32

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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

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

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

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

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

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

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
}

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

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

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

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

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
}

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

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
}

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
}

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
}

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
}

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
}

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
}

type UnimplementedPoplarEventCollectorServer struct {
}

type UnimplementedPoplarMetricsCollectorServer struct {
}

type UnimplementedPoplarMetricsRecorderServer struct {
}

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

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

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