data_receiver

package
v1.5.1 Latest Latest
Warning

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

Go to latest
Published: May 10, 2024 License: Apache-2.0 Imports: 19 Imported by: 10

Documentation

Overview

Package data_receiver is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	DataReceiverService_PutEvents_FullMethodName  = "/zenoss.cloud.DataReceiverService/PutEvents"
	DataReceiverService_PutEvent_FullMethodName   = "/zenoss.cloud.DataReceiverService/PutEvent"
	DataReceiverService_PutMetrics_FullMethodName = "/zenoss.cloud.DataReceiverService/PutMetrics"
	DataReceiverService_PutMetric_FullMethodName  = "/zenoss.cloud.DataReceiverService/PutMetric"
	DataReceiverService_PutModels_FullMethodName  = "/zenoss.cloud.DataReceiverService/PutModels"
)

Variables

View Source
var (
	Severity_name = map[int32]string{
		0: "SEVERITY_DEFAULT",
		1: "SEVERITY_DEBUG",
		2: "SEVERITY_INFO",
		3: "SEVERITY_WARNING",
		4: "SEVERITY_ERROR",
		5: "SEVERITY_CRITICAL",
	}
	Severity_value = map[string]int32{
		"SEVERITY_DEFAULT":  0,
		"SEVERITY_DEBUG":    1,
		"SEVERITY_INFO":     2,
		"SEVERITY_WARNING":  3,
		"SEVERITY_ERROR":    4,
		"SEVERITY_CRITICAL": 5,
	}
)

Enum value maps for Severity.

View Source
var (
	Status_name = map[int32]string{
		0: "STATUS_DEFAULT",
		1: "STATUS_OPEN",
		2: "STATUS_SUPPRESSED",
		3: "STATUS_CLOSED",
	}
	Status_value = map[string]int32{
		"STATUS_DEFAULT":    0,
		"STATUS_OPEN":       1,
		"STATUS_SUPPRESSED": 2,
		"STATUS_CLOSED":     3,
	}
)

Enum value maps for Status.

View Source
var DataReceiverService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "zenoss.cloud.DataReceiverService",
	HandlerType: (*DataReceiverServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PutEvents",
			Handler:    _DataReceiverService_PutEvents_Handler,
		},
		{
			MethodName: "PutMetrics",
			Handler:    _DataReceiverService_PutMetrics_Handler,
		},
		{
			MethodName: "PutModels",
			Handler:    _DataReceiverService_PutModels_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PutEvent",
			Handler:       _DataReceiverService_PutEvent_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "PutMetric",
			Handler:       _DataReceiverService_PutMetric_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "zenoss/cloud/data_receiver.proto",
}

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

View Source
var File_zenoss_cloud_data_receiver_proto protoreflect.FileDescriptor

Functions

func RegisterDataReceiverServiceHandler

func RegisterDataReceiverServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterDataReceiverServiceHandler registers the http handlers for service DataReceiverService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDataReceiverServiceHandlerClient

func RegisterDataReceiverServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DataReceiverServiceClient) error

RegisterDataReceiverServiceHandlerClient registers the http handlers for service DataReceiverService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DataReceiverServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DataReceiverServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DataReceiverServiceClient" to call the correct interceptors.

func RegisterDataReceiverServiceHandlerFromEndpoint

func RegisterDataReceiverServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDataReceiverServiceHandlerFromEndpoint is same as RegisterDataReceiverServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDataReceiverServiceHandlerServer added in v1.4.0

func RegisterDataReceiverServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DataReceiverServiceServer) error

RegisterDataReceiverServiceHandlerServer registers the http handlers for service DataReceiverService to "mux". UnaryRPC :call DataReceiverServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDataReceiverServiceHandlerFromEndpoint instead.

func RegisterDataReceiverServiceServer

func RegisterDataReceiverServiceServer(s grpc.ServiceRegistrar, srv DataReceiverServiceServer)

Types

type CompactMetric

type CompactMetric struct {

	// The metric id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The time at which the value was captured
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The metric value
	Value float64 `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactMetric) Descriptor deprecated

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

Deprecated: Use CompactMetric.ProtoReflect.Descriptor instead.

func (*CompactMetric) GetId

func (x *CompactMetric) GetId() string

func (*CompactMetric) GetTimestamp

func (x *CompactMetric) GetTimestamp() int64

func (*CompactMetric) GetValue

func (x *CompactMetric) GetValue() float64

func (*CompactMetric) ProtoMessage

func (*CompactMetric) ProtoMessage()

func (*CompactMetric) ProtoReflect added in v1.4.0

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

func (*CompactMetric) Reset

func (x *CompactMetric) Reset()

func (*CompactMetric) String

func (x *CompactMetric) String() string

type CompactMetricError

type CompactMetricError struct {
	Error  string         `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Metric *CompactMetric `protobuf:"bytes,2,opt,name=metric,proto3" json:"metric,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactMetricError) Descriptor deprecated

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

Deprecated: Use CompactMetricError.ProtoReflect.Descriptor instead.

func (*CompactMetricError) GetError

func (x *CompactMetricError) GetError() string

func (*CompactMetricError) GetMetric

func (x *CompactMetricError) GetMetric() *CompactMetric

func (*CompactMetricError) ProtoMessage

func (*CompactMetricError) ProtoMessage()

func (*CompactMetricError) ProtoReflect added in v1.4.0

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

func (*CompactMetricError) Reset

func (x *CompactMetricError) Reset()

func (*CompactMetricError) String

func (x *CompactMetricError) String() string

type DataReceiverServiceClient

type DataReceiverServiceClient interface {
	// Send Events
	PutEvents(ctx context.Context, in *Events, opts ...grpc.CallOption) (*EventStatusResult, error)
	// Stream Events of any type.
	PutEvent(ctx context.Context, opts ...grpc.CallOption) (DataReceiverService_PutEventClient, error)
	// Send Metrics
	PutMetrics(ctx context.Context, in *Metrics, opts ...grpc.CallOption) (*StatusResult, error)
	// Stream Metric of any type
	PutMetric(ctx context.Context, opts ...grpc.CallOption) (DataReceiverService_PutMetricClient, error)
	// Send batch of models
	PutModels(ctx context.Context, in *Models, opts ...grpc.CallOption) (*ModelStatusResult, error)
}

DataReceiverServiceClient is the client API for DataReceiverService 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.

type DataReceiverServiceServer

type DataReceiverServiceServer interface {
	// Send Events
	PutEvents(context.Context, *Events) (*EventStatusResult, error)
	// Stream Events of any type.
	PutEvent(DataReceiverService_PutEventServer) error
	// Send Metrics
	PutMetrics(context.Context, *Metrics) (*StatusResult, error)
	// Stream Metric of any type
	PutMetric(DataReceiverService_PutMetricServer) error
	// Send batch of models
	PutModels(context.Context, *Models) (*ModelStatusResult, error)
	// contains filtered or unexported methods
}

DataReceiverServiceServer is the server API for DataReceiverService service. All implementations must embed UnimplementedDataReceiverServiceServer for forward compatibility

type DataReceiverService_PutEventClient added in v1.1.0

type DataReceiverService_PutEventClient interface {
	Send(*EventWrapper) error
	CloseAndRecv() (*Void, error)
	grpc.ClientStream
}

type DataReceiverService_PutEventServer added in v1.1.0

type DataReceiverService_PutEventServer interface {
	SendAndClose(*Void) error
	Recv() (*EventWrapper, error)
	grpc.ServerStream
}

type DataReceiverService_PutMetricClient

type DataReceiverService_PutMetricClient interface {
	Send(*MetricWrapper) error
	CloseAndRecv() (*Void, error)
	grpc.ClientStream
}

type DataReceiverService_PutMetricServer

type DataReceiverService_PutMetricServer interface {
	SendAndClose(*Void) error
	Recv() (*MetricWrapper, error)
	grpc.ServerStream
}

type Event added in v1.1.0

type Event struct {

	// timestamp is the time (in ms since epoch) at which the event occurred.
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// name, when combined with dimensions, makes this event unique.
	//   - should be set to the ID for systems that have an event ID concept
	//   - otherwise the same as "type"
	//   - e.g. linkDown, fault-F0157, adaeff80-b1b0-47fe-92a1-69e958145e10
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Dimensions associated with this event.
	// Dimensions, when combined with name, make this event unique.
	//   - typically set the same as the entity to which event is related
	Dimensions map[string]string `` /* 161-byte string literal not displayed */
	// Fields associated with this event.
	MetadataFields *structpb.Struct `protobuf:"bytes,4,opt,name=metadataFields,proto3" json:"metadataFields,omitempty"`
	// type uniquely identifies the context-free type of event.
	//   - typically set the same as "name" for systems that have an event ID.
	//   - e.g. linkDown, fault-F0157
	Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	// summary is a short (<128 character) summary of the event.
	//   - most commonly displayed per-event field
	//   - highly recommend to set this
	Summary string `protobuf:"bytes,6,opt,name=summary,proto3" json:"summary,omitempty"`
	// body is a long (? character) further description of the event.
	//   - it is not necessary to repeat summary in the body
	Body string `protobuf:"bytes,7,opt,name=body,proto3" json:"body,omitempty"`
	// severity defines how severe the event is.
	//   - use SEVERITY_DEFAULT when not currently known
	//   - use SEVERITY_DEBUG when not severe enough to show by default
	//   - use SEVERITY_INFO when when no action is likely required
	//   - use SEVERITY_WARNING when delayed action may be required
	//   - use SEVERITY_ERROR when system is degraded, but not down
	//   - use SEVERITY_CRITICAL for system down
	Severity Severity `protobuf:"varint,8,opt,name=severity,proto3,enum=zenoss.cloud.Severity" json:"severity,omitempty"`
	// status defines the event's disposition from the system perspective.
	//   - use STATUS_DEFAULT when not currently known
	//   - use STATUS_OPEN when event is known to be actively ongoing
	//   - use STATUS_SUPPRESSED when event should be suppressed
	//   - use STATUS_CLOSED when the event is known to have subsided
	Status Status `protobuf:"varint,9,opt,name=status,proto3,enum=zenoss.cloud.Status" json:"status,omitempty"`
	// acknowledged explicitly sets the events acknowledged state.
	Acknowledged *wrapperspb.BoolValue `protobuf:"bytes,10,opt,name=acknowledged,proto3" json:"acknowledged,omitempty"`
	// contains filtered or unexported fields
}

Public Event struct. Note the conspicuous absence of 'id' and 'tenant' which are inferred by auth.

func (*Event) Descriptor deprecated added in v1.1.0

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAcknowledged added in v1.1.0

func (x *Event) GetAcknowledged() *wrapperspb.BoolValue

func (*Event) GetBody added in v1.1.0

func (x *Event) GetBody() string

func (*Event) GetDimensions added in v1.1.0

func (x *Event) GetDimensions() map[string]string

func (*Event) GetMetadataFields added in v1.1.0

func (x *Event) GetMetadataFields() *structpb.Struct

func (*Event) GetName added in v1.1.0

func (x *Event) GetName() string

func (*Event) GetSeverity added in v1.1.0

func (x *Event) GetSeverity() Severity

func (*Event) GetStatus added in v1.1.0

func (x *Event) GetStatus() Status

func (*Event) GetSummary added in v1.1.0

func (x *Event) GetSummary() string

func (*Event) GetTimestamp added in v1.1.0

func (x *Event) GetTimestamp() int64

func (*Event) GetType added in v1.1.0

func (x *Event) GetType() string

func (*Event) ProtoMessage added in v1.1.0

func (*Event) ProtoMessage()

func (*Event) ProtoReflect added in v1.4.0

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

func (*Event) Reset added in v1.1.0

func (x *Event) Reset()

func (*Event) String added in v1.1.0

func (x *Event) String() string

type EventError added in v1.1.0

type EventError struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Event *Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*EventError) Descriptor deprecated added in v1.1.0

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

Deprecated: Use EventError.ProtoReflect.Descriptor instead.

func (*EventError) GetError added in v1.1.0

func (x *EventError) GetError() string

func (*EventError) GetEvent added in v1.1.0

func (x *EventError) GetEvent() *Event

func (*EventError) ProtoMessage added in v1.1.0

func (*EventError) ProtoMessage()

func (*EventError) ProtoReflect added in v1.4.0

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

func (*EventError) Reset added in v1.1.0

func (x *EventError) Reset()

func (*EventError) String added in v1.1.0

func (x *EventError) String() string

type EventStatusResult added in v1.1.0

type EventStatusResult struct {

	// failed is the count of events that failed to be accepted
	Failed int32 `protobuf:"varint,1,opt,name=failed,proto3" json:"failed,omitempty"`
	// succeeded is the count of events that were accepted
	Succeeded int32 `protobuf:"varint,2,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	// message is an informational message that may or may not be set
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// Failed events only returned if detailedResponse is set to true
	FailedEvents []*EventError `protobuf:"bytes,4,rep,name=failedEvents,proto3" json:"failedEvents,omitempty"`
	// contains filtered or unexported fields
}

func (*EventStatusResult) Descriptor deprecated added in v1.1.0

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

Deprecated: Use EventStatusResult.ProtoReflect.Descriptor instead.

func (*EventStatusResult) GetFailed added in v1.1.0

func (x *EventStatusResult) GetFailed() int32

func (*EventStatusResult) GetFailedEvents added in v1.1.0

func (x *EventStatusResult) GetFailedEvents() []*EventError

func (*EventStatusResult) GetMessage added in v1.1.0

func (x *EventStatusResult) GetMessage() string

func (*EventStatusResult) GetSucceeded added in v1.1.0

func (x *EventStatusResult) GetSucceeded() int32

func (*EventStatusResult) ProtoMessage added in v1.1.0

func (*EventStatusResult) ProtoMessage()

func (*EventStatusResult) ProtoReflect added in v1.4.0

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

func (*EventStatusResult) Reset added in v1.1.0

func (x *EventStatusResult) Reset()

func (*EventStatusResult) String added in v1.1.0

func (x *EventStatusResult) String() string

type EventWrapper added in v1.1.0

type EventWrapper struct {

	// Types that are assignable to EventType:
	//
	//	*EventWrapper_Canonical
	EventType isEventWrapper_EventType `protobuf_oneof:"event_type"`
	// contains filtered or unexported fields
}

func (*EventWrapper) Descriptor deprecated added in v1.1.0

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

Deprecated: Use EventWrapper.ProtoReflect.Descriptor instead.

func (*EventWrapper) GetCanonical added in v1.1.0

func (x *EventWrapper) GetCanonical() *Event

func (*EventWrapper) GetEventType added in v1.1.0

func (m *EventWrapper) GetEventType() isEventWrapper_EventType

func (*EventWrapper) ProtoMessage added in v1.1.0

func (*EventWrapper) ProtoMessage()

func (*EventWrapper) ProtoReflect added in v1.4.0

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

func (*EventWrapper) Reset added in v1.1.0

func (x *EventWrapper) Reset()

func (*EventWrapper) String added in v1.1.0

func (x *EventWrapper) String() string

type EventWrapper_Canonical added in v1.1.0

type EventWrapper_Canonical struct {
	// Canonical format
	Canonical *Event `protobuf:"bytes,1,opt,name=canonical,proto3,oneof"`
}

type Events added in v1.1.0

type Events struct {

	// detailedResponse: if true, return any events that failed to be sent.
	DetailedResponse bool `protobuf:"varint,1,opt,name=detailedResponse,proto3" json:"detailedResponse,omitempty"`
	// The events
	Events []*Event `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*Events) Descriptor deprecated added in v1.1.0

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

Deprecated: Use Events.ProtoReflect.Descriptor instead.

func (*Events) GetDetailedResponse added in v1.1.0

func (x *Events) GetDetailedResponse() bool

func (*Events) GetEvents added in v1.1.0

func (x *Events) GetEvents() []*Event

func (*Events) ProtoMessage added in v1.1.0

func (*Events) ProtoMessage()

func (*Events) ProtoReflect added in v1.4.0

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

func (*Events) Reset added in v1.1.0

func (x *Events) Reset()

func (*Events) String added in v1.1.0

func (x *Events) String() string

type Metric

type Metric struct {

	// The metric name
	Metric string `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	// The time at which the value was captured
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The metric value
	Value float64 `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"`
	// Dimensions associated with this datapoint.
	Dimensions map[string]string `` /* 161-byte string literal not displayed */
	// Metadata for the datapoint. Note: using Struct as it is easier than AnyArray when using json representations
	MetadataFields *structpb.Struct `protobuf:"bytes,6,opt,name=metadataFields,proto3" json:"metadataFields,omitempty"`
	// contains filtered or unexported fields
}

Canonical Metric format

func (*Metric) Descriptor deprecated

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

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetDimensions

func (x *Metric) GetDimensions() map[string]string

func (*Metric) GetMetadataFields

func (x *Metric) GetMetadataFields() *structpb.Struct

func (*Metric) GetMetric

func (x *Metric) GetMetric() string

func (*Metric) GetTimestamp

func (x *Metric) GetTimestamp() int64

func (*Metric) GetValue

func (x *Metric) GetValue() float64

func (*Metric) ProtoMessage

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect added in v1.4.0

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

func (*Metric) Reset

func (x *Metric) Reset()

func (*Metric) String

func (x *Metric) String() string

type MetricBatch

type MetricBatch struct {

	// Tags that apply to all metrics in the batch
	GlobalTags map[string]string `` /* 179-byte string literal not displayed */
	// The metrics
	Metrics []*MetricWrapper `protobuf:"bytes,3,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

DEPRECATED Batch of metrics

func (*MetricBatch) Descriptor deprecated

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

Deprecated: Use MetricBatch.ProtoReflect.Descriptor instead.

func (*MetricBatch) GetGlobalTags

func (x *MetricBatch) GetGlobalTags() map[string]string

func (*MetricBatch) GetMetrics

func (x *MetricBatch) GetMetrics() []*MetricWrapper

func (*MetricBatch) ProtoMessage

func (*MetricBatch) ProtoMessage()

func (*MetricBatch) ProtoReflect added in v1.4.0

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

func (*MetricBatch) Reset

func (x *MetricBatch) Reset()

func (*MetricBatch) String

func (x *MetricBatch) String() string

type MetricError

type MetricError struct {
	Error  string  `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Metric *Metric `protobuf:"bytes,2,opt,name=metric,proto3" json:"metric,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricError) Descriptor deprecated

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

Deprecated: Use MetricError.ProtoReflect.Descriptor instead.

func (*MetricError) GetError

func (x *MetricError) GetError() string

func (*MetricError) GetMetric

func (x *MetricError) GetMetric() *Metric

func (*MetricError) ProtoMessage

func (*MetricError) ProtoMessage()

func (*MetricError) ProtoReflect added in v1.4.0

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

func (*MetricError) Reset

func (x *MetricError) Reset()

func (*MetricError) String

func (x *MetricError) String() string

type MetricWrapper

type MetricWrapper struct {

	// Types that are assignable to MetricType:
	//
	//	*MetricWrapper_Tagged
	//	*MetricWrapper_Compact
	//	*MetricWrapper_Canonical
	MetricType isMetricWrapper_MetricType `protobuf_oneof:"metric_type"`
	// contains filtered or unexported fields
}

func (*MetricWrapper) Descriptor deprecated

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

Deprecated: Use MetricWrapper.ProtoReflect.Descriptor instead.

func (*MetricWrapper) GetCanonical

func (x *MetricWrapper) GetCanonical() *Metric

func (*MetricWrapper) GetCompact

func (x *MetricWrapper) GetCompact() *CompactMetric

func (*MetricWrapper) GetMetricType

func (m *MetricWrapper) GetMetricType() isMetricWrapper_MetricType

func (*MetricWrapper) GetTagged

func (x *MetricWrapper) GetTagged() *TaggedMetric

func (*MetricWrapper) ProtoMessage

func (*MetricWrapper) ProtoMessage()

func (*MetricWrapper) ProtoReflect added in v1.4.0

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

func (*MetricWrapper) Reset

func (x *MetricWrapper) Reset()

func (*MetricWrapper) String

func (x *MetricWrapper) String() string

type MetricWrapper_Canonical

type MetricWrapper_Canonical struct {
	// Canonical format
	Canonical *Metric `protobuf:"bytes,3,opt,name=canonical,proto3,oneof"`
}

type MetricWrapper_Compact

type MetricWrapper_Compact struct {
	// Compact format
	Compact *CompactMetric `protobuf:"bytes,2,opt,name=compact,proto3,oneof"`
}

type MetricWrapper_Tagged

type MetricWrapper_Tagged struct {
	// Verbose format
	Tagged *TaggedMetric `protobuf:"bytes,1,opt,name=tagged,proto3,oneof"`
}

type Metrics

type Metrics struct {

	// detailedResponse if set to true will return any metrics that failed to be sent
	DetailedResponse bool             `protobuf:"varint,1,opt,name=detailedResponse,proto3" json:"detailedResponse,omitempty"`
	CompactMetrics   []*CompactMetric `protobuf:"bytes,3,rep,name=compactMetrics,proto3" json:"compactMetrics,omitempty"`
	TaggedMetrics    []*TaggedMetric  `protobuf:"bytes,4,rep,name=taggedMetrics,proto3" json:"taggedMetrics,omitempty"`
	Metrics          []*Metric        `protobuf:"bytes,5,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*Metrics) Descriptor deprecated

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

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetCompactMetrics

func (x *Metrics) GetCompactMetrics() []*CompactMetric

func (*Metrics) GetDetailedResponse

func (x *Metrics) GetDetailedResponse() bool

func (*Metrics) GetMetrics

func (x *Metrics) GetMetrics() []*Metric

func (*Metrics) GetTaggedMetrics

func (x *Metrics) GetTaggedMetrics() []*TaggedMetric

func (*Metrics) ProtoMessage

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect added in v1.4.0

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

func (*Metrics) Reset

func (x *Metrics) Reset()

func (*Metrics) String

func (x *Metrics) String() string

type MockDataReceiverServiceClient

type MockDataReceiverServiceClient struct {
	mock.Mock
}

MockDataReceiverServiceClient is an autogenerated mock type for the DataReceiverServiceClient type

func NewMockDataReceiverServiceClient added in v1.4.0

func NewMockDataReceiverServiceClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDataReceiverServiceClient

NewMockDataReceiverServiceClient creates a new instance of MockDataReceiverServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockDataReceiverServiceClient) EXPECT added in v1.4.0

func (*MockDataReceiverServiceClient) PutEvent added in v1.1.0

PutEvent provides a mock function with given fields: ctx, opts

func (*MockDataReceiverServiceClient) PutEvents added in v1.1.0

PutEvents provides a mock function with given fields: ctx, in, opts

func (*MockDataReceiverServiceClient) PutMetric

PutMetric provides a mock function with given fields: ctx, opts

func (*MockDataReceiverServiceClient) PutMetrics

func (_m *MockDataReceiverServiceClient) PutMetrics(ctx context.Context, in *Metrics, opts ...grpc.CallOption) (*StatusResult, error)

PutMetrics provides a mock function with given fields: ctx, in, opts

func (*MockDataReceiverServiceClient) PutModels

PutModels provides a mock function with given fields: ctx, in, opts

type MockDataReceiverServiceClient_Expecter added in v1.4.0

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

func (*MockDataReceiverServiceClient_Expecter) PutEvent added in v1.4.0

func (_e *MockDataReceiverServiceClient_Expecter) PutEvent(ctx interface{}, opts ...interface{}) *MockDataReceiverServiceClient_PutEvent_Call

PutEvent is a helper method to define mock.On call

  • ctx context.Context
  • opts ...grpc.CallOption

func (*MockDataReceiverServiceClient_Expecter) PutEvents added in v1.4.0

func (_e *MockDataReceiverServiceClient_Expecter) PutEvents(ctx interface{}, in interface{}, opts ...interface{}) *MockDataReceiverServiceClient_PutEvents_Call

PutEvents is a helper method to define mock.On call

  • ctx context.Context
  • in *Events
  • opts ...grpc.CallOption

func (*MockDataReceiverServiceClient_Expecter) PutMetric added in v1.4.0

func (_e *MockDataReceiverServiceClient_Expecter) PutMetric(ctx interface{}, opts ...interface{}) *MockDataReceiverServiceClient_PutMetric_Call

PutMetric is a helper method to define mock.On call

  • ctx context.Context
  • opts ...grpc.CallOption

func (*MockDataReceiverServiceClient_Expecter) PutMetrics added in v1.4.0

func (_e *MockDataReceiverServiceClient_Expecter) PutMetrics(ctx interface{}, in interface{}, opts ...interface{}) *MockDataReceiverServiceClient_PutMetrics_Call

PutMetrics is a helper method to define mock.On call

  • ctx context.Context
  • in *Metrics
  • opts ...grpc.CallOption

func (*MockDataReceiverServiceClient_Expecter) PutModels added in v1.4.0

func (_e *MockDataReceiverServiceClient_Expecter) PutModels(ctx interface{}, in interface{}, opts ...interface{}) *MockDataReceiverServiceClient_PutModels_Call

PutModels is a helper method to define mock.On call

  • ctx context.Context
  • in *Models
  • opts ...grpc.CallOption

type MockDataReceiverServiceClient_PutEvent_Call added in v1.4.0

type MockDataReceiverServiceClient_PutEvent_Call struct {
	*mock.Call
}

MockDataReceiverServiceClient_PutEvent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutEvent'

func (*MockDataReceiverServiceClient_PutEvent_Call) Return added in v1.4.0

func (*MockDataReceiverServiceClient_PutEvent_Call) Run added in v1.4.0

func (*MockDataReceiverServiceClient_PutEvent_Call) RunAndReturn added in v1.5.1

type MockDataReceiverServiceClient_PutEvents_Call added in v1.4.0

type MockDataReceiverServiceClient_PutEvents_Call struct {
	*mock.Call
}

MockDataReceiverServiceClient_PutEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutEvents'

func (*MockDataReceiverServiceClient_PutEvents_Call) Return added in v1.4.0

func (*MockDataReceiverServiceClient_PutEvents_Call) Run added in v1.4.0

func (*MockDataReceiverServiceClient_PutEvents_Call) RunAndReturn added in v1.5.1

type MockDataReceiverServiceClient_PutMetric_Call added in v1.4.0

type MockDataReceiverServiceClient_PutMetric_Call struct {
	*mock.Call
}

MockDataReceiverServiceClient_PutMetric_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutMetric'

func (*MockDataReceiverServiceClient_PutMetric_Call) Return added in v1.4.0

func (*MockDataReceiverServiceClient_PutMetric_Call) Run added in v1.4.0

func (*MockDataReceiverServiceClient_PutMetric_Call) RunAndReturn added in v1.5.1

type MockDataReceiverServiceClient_PutMetrics_Call added in v1.4.0

type MockDataReceiverServiceClient_PutMetrics_Call struct {
	*mock.Call
}

MockDataReceiverServiceClient_PutMetrics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutMetrics'

func (*MockDataReceiverServiceClient_PutMetrics_Call) Return added in v1.4.0

func (*MockDataReceiverServiceClient_PutMetrics_Call) Run added in v1.4.0

func (*MockDataReceiverServiceClient_PutMetrics_Call) RunAndReturn added in v1.5.1

type MockDataReceiverServiceClient_PutModels_Call added in v1.4.0

type MockDataReceiverServiceClient_PutModels_Call struct {
	*mock.Call
}

MockDataReceiverServiceClient_PutModels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutModels'

func (*MockDataReceiverServiceClient_PutModels_Call) Return added in v1.4.0

func (*MockDataReceiverServiceClient_PutModels_Call) Run added in v1.4.0

func (*MockDataReceiverServiceClient_PutModels_Call) RunAndReturn added in v1.5.1

type MockDataReceiverServiceServer

type MockDataReceiverServiceServer struct {
	mock.Mock
}

MockDataReceiverServiceServer is an autogenerated mock type for the DataReceiverServiceServer type

func NewMockDataReceiverServiceServer added in v1.4.0

func NewMockDataReceiverServiceServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDataReceiverServiceServer

NewMockDataReceiverServiceServer creates a new instance of MockDataReceiverServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockDataReceiverServiceServer) EXPECT added in v1.4.0

func (*MockDataReceiverServiceServer) PutEvent added in v1.1.0

PutEvent provides a mock function with given fields: _a0

func (*MockDataReceiverServiceServer) PutEvents added in v1.1.0

PutEvents provides a mock function with given fields: _a0, _a1

func (*MockDataReceiverServiceServer) PutMetric

PutMetric provides a mock function with given fields: _a0

func (*MockDataReceiverServiceServer) PutMetrics

PutMetrics provides a mock function with given fields: _a0, _a1

func (*MockDataReceiverServiceServer) PutModels

PutModels provides a mock function with given fields: _a0, _a1

type MockDataReceiverServiceServer_Expecter added in v1.4.0

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

func (*MockDataReceiverServiceServer_Expecter) PutEvent added in v1.4.0

PutEvent is a helper method to define mock.On call

  • _a0 DataReceiverService_PutEventServer

func (*MockDataReceiverServiceServer_Expecter) PutEvents added in v1.4.0

func (_e *MockDataReceiverServiceServer_Expecter) PutEvents(_a0 interface{}, _a1 interface{}) *MockDataReceiverServiceServer_PutEvents_Call

PutEvents is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *Events

func (*MockDataReceiverServiceServer_Expecter) PutMetric added in v1.4.0

PutMetric is a helper method to define mock.On call

  • _a0 DataReceiverService_PutMetricServer

func (*MockDataReceiverServiceServer_Expecter) PutMetrics added in v1.4.0

func (_e *MockDataReceiverServiceServer_Expecter) PutMetrics(_a0 interface{}, _a1 interface{}) *MockDataReceiverServiceServer_PutMetrics_Call

PutMetrics is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *Metrics

func (*MockDataReceiverServiceServer_Expecter) PutModels added in v1.4.0

func (_e *MockDataReceiverServiceServer_Expecter) PutModels(_a0 interface{}, _a1 interface{}) *MockDataReceiverServiceServer_PutModels_Call

PutModels is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *Models

type MockDataReceiverServiceServer_PutEvent_Call added in v1.4.0

type MockDataReceiverServiceServer_PutEvent_Call struct {
	*mock.Call
}

MockDataReceiverServiceServer_PutEvent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutEvent'

func (*MockDataReceiverServiceServer_PutEvent_Call) Return added in v1.4.0

func (*MockDataReceiverServiceServer_PutEvent_Call) Run added in v1.4.0

func (*MockDataReceiverServiceServer_PutEvent_Call) RunAndReturn added in v1.5.1

type MockDataReceiverServiceServer_PutEvents_Call added in v1.4.0

type MockDataReceiverServiceServer_PutEvents_Call struct {
	*mock.Call
}

MockDataReceiverServiceServer_PutEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutEvents'

func (*MockDataReceiverServiceServer_PutEvents_Call) Return added in v1.4.0

func (*MockDataReceiverServiceServer_PutEvents_Call) Run added in v1.4.0

func (*MockDataReceiverServiceServer_PutEvents_Call) RunAndReturn added in v1.5.1

type MockDataReceiverServiceServer_PutMetric_Call added in v1.4.0

type MockDataReceiverServiceServer_PutMetric_Call struct {
	*mock.Call
}

MockDataReceiverServiceServer_PutMetric_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutMetric'

func (*MockDataReceiverServiceServer_PutMetric_Call) Return added in v1.4.0

func (*MockDataReceiverServiceServer_PutMetric_Call) Run added in v1.4.0

func (*MockDataReceiverServiceServer_PutMetric_Call) RunAndReturn added in v1.5.1

type MockDataReceiverServiceServer_PutMetrics_Call added in v1.4.0

type MockDataReceiverServiceServer_PutMetrics_Call struct {
	*mock.Call
}

MockDataReceiverServiceServer_PutMetrics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutMetrics'

func (*MockDataReceiverServiceServer_PutMetrics_Call) Return added in v1.4.0

func (*MockDataReceiverServiceServer_PutMetrics_Call) Run added in v1.4.0

func (*MockDataReceiverServiceServer_PutMetrics_Call) RunAndReturn added in v1.5.1

type MockDataReceiverServiceServer_PutModels_Call added in v1.4.0

type MockDataReceiverServiceServer_PutModels_Call struct {
	*mock.Call
}

MockDataReceiverServiceServer_PutModels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutModels'

func (*MockDataReceiverServiceServer_PutModels_Call) Return added in v1.4.0

func (*MockDataReceiverServiceServer_PutModels_Call) Run added in v1.4.0

func (*MockDataReceiverServiceServer_PutModels_Call) RunAndReturn added in v1.5.1

type MockDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call added in v1.5.0

type MockDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call struct {
	*mock.Call
}

MockDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'mustEmbedUnimplementedDataReceiverServiceServer'

func (*MockDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call) Return added in v1.5.0

func (*MockDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call) Run added in v1.5.0

func (*MockDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventClient added in v1.1.0

type MockDataReceiverService_PutEventClient struct {
	mock.Mock
}

MockDataReceiverService_PutEventClient is an autogenerated mock type for the DataReceiverService_PutEventClient type

func NewMockDataReceiverService_PutEventClient added in v1.4.0

func NewMockDataReceiverService_PutEventClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDataReceiverService_PutEventClient

NewMockDataReceiverService_PutEventClient creates a new instance of MockDataReceiverService_PutEventClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockDataReceiverService_PutEventClient) CloseAndRecv added in v1.1.0

func (_m *MockDataReceiverService_PutEventClient) CloseAndRecv() (*Void, error)

CloseAndRecv provides a mock function with given fields:

func (*MockDataReceiverService_PutEventClient) CloseSend added in v1.1.0

CloseSend provides a mock function with given fields:

func (*MockDataReceiverService_PutEventClient) Context added in v1.1.0

Context provides a mock function with given fields:

func (*MockDataReceiverService_PutEventClient) EXPECT added in v1.4.0

func (*MockDataReceiverService_PutEventClient) Header added in v1.1.0

Header provides a mock function with given fields:

func (*MockDataReceiverService_PutEventClient) RecvMsg added in v1.1.0

func (_m *MockDataReceiverService_PutEventClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockDataReceiverService_PutEventClient) Send added in v1.1.0

Send provides a mock function with given fields: _a0

func (*MockDataReceiverService_PutEventClient) SendMsg added in v1.1.0

func (_m *MockDataReceiverService_PutEventClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*MockDataReceiverService_PutEventClient) Trailer added in v1.1.0

Trailer provides a mock function with given fields:

type MockDataReceiverService_PutEventClient_CloseAndRecv_Call added in v1.4.0

type MockDataReceiverService_PutEventClient_CloseAndRecv_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventClient_CloseAndRecv_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CloseAndRecv'

func (*MockDataReceiverService_PutEventClient_CloseAndRecv_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventClient_CloseAndRecv_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventClient_CloseAndRecv_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventClient_CloseSend_Call added in v1.4.0

type MockDataReceiverService_PutEventClient_CloseSend_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventClient_CloseSend_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CloseSend'

func (*MockDataReceiverService_PutEventClient_CloseSend_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventClient_CloseSend_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventClient_CloseSend_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventClient_Context_Call added in v1.4.0

type MockDataReceiverService_PutEventClient_Context_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventClient_Context_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Context'

func (*MockDataReceiverService_PutEventClient_Context_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventClient_Context_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventClient_Context_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventClient_Expecter added in v1.4.0

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

func (*MockDataReceiverService_PutEventClient_Expecter) CloseAndRecv added in v1.4.0

CloseAndRecv is a helper method to define mock.On call

func (*MockDataReceiverService_PutEventClient_Expecter) CloseSend added in v1.4.0

CloseSend is a helper method to define mock.On call

func (*MockDataReceiverService_PutEventClient_Expecter) Context added in v1.4.0

Context is a helper method to define mock.On call

func (*MockDataReceiverService_PutEventClient_Expecter) Header added in v1.4.0

Header is a helper method to define mock.On call

func (*MockDataReceiverService_PutEventClient_Expecter) RecvMsg added in v1.4.0

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutEventClient_Expecter) Send added in v1.4.0

Send is a helper method to define mock.On call

  • _a0 *EventWrapper

func (*MockDataReceiverService_PutEventClient_Expecter) SendMsg added in v1.4.0

SendMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutEventClient_Expecter) Trailer added in v1.4.0

Trailer is a helper method to define mock.On call

type MockDataReceiverService_PutEventClient_Header_Call added in v1.4.0

type MockDataReceiverService_PutEventClient_Header_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventClient_Header_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Header'

func (*MockDataReceiverService_PutEventClient_Header_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventClient_Header_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventClient_Header_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventClient_RecvMsg_Call added in v1.4.0

type MockDataReceiverService_PutEventClient_RecvMsg_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventClient_RecvMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecvMsg'

func (*MockDataReceiverService_PutEventClient_RecvMsg_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventClient_RecvMsg_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventClient_RecvMsg_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventClient_SendMsg_Call added in v1.4.0

type MockDataReceiverService_PutEventClient_SendMsg_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventClient_SendMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendMsg'

func (*MockDataReceiverService_PutEventClient_SendMsg_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventClient_SendMsg_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventClient_SendMsg_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventClient_Send_Call added in v1.4.0

type MockDataReceiverService_PutEventClient_Send_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventClient_Send_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Send'

func (*MockDataReceiverService_PutEventClient_Send_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventClient_Send_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventClient_Send_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventClient_Trailer_Call added in v1.4.0

type MockDataReceiverService_PutEventClient_Trailer_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventClient_Trailer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Trailer'

func (*MockDataReceiverService_PutEventClient_Trailer_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventClient_Trailer_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventClient_Trailer_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventServer added in v1.1.0

type MockDataReceiverService_PutEventServer struct {
	mock.Mock
}

MockDataReceiverService_PutEventServer is an autogenerated mock type for the DataReceiverService_PutEventServer type

func NewMockDataReceiverService_PutEventServer added in v1.4.0

func NewMockDataReceiverService_PutEventServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDataReceiverService_PutEventServer

NewMockDataReceiverService_PutEventServer creates a new instance of MockDataReceiverService_PutEventServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockDataReceiverService_PutEventServer) Context added in v1.1.0

Context provides a mock function with given fields:

func (*MockDataReceiverService_PutEventServer) EXPECT added in v1.4.0

func (*MockDataReceiverService_PutEventServer) Recv added in v1.1.0

Recv provides a mock function with given fields:

func (*MockDataReceiverService_PutEventServer) RecvMsg added in v1.1.0

func (_m *MockDataReceiverService_PutEventServer) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockDataReceiverService_PutEventServer) SendAndClose added in v1.1.0

func (_m *MockDataReceiverService_PutEventServer) SendAndClose(_a0 *Void) error

SendAndClose provides a mock function with given fields: _a0

func (*MockDataReceiverService_PutEventServer) SendHeader added in v1.1.0

SendHeader provides a mock function with given fields: _a0

func (*MockDataReceiverService_PutEventServer) SendMsg added in v1.1.0

func (_m *MockDataReceiverService_PutEventServer) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*MockDataReceiverService_PutEventServer) SetHeader added in v1.1.0

SetHeader provides a mock function with given fields: _a0

func (*MockDataReceiverService_PutEventServer) SetTrailer added in v1.1.0

SetTrailer provides a mock function with given fields: _a0

type MockDataReceiverService_PutEventServer_Context_Call added in v1.4.0

type MockDataReceiverService_PutEventServer_Context_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventServer_Context_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Context'

func (*MockDataReceiverService_PutEventServer_Context_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventServer_Context_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventServer_Context_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventServer_Expecter added in v1.4.0

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

func (*MockDataReceiverService_PutEventServer_Expecter) Context added in v1.4.0

Context is a helper method to define mock.On call

func (*MockDataReceiverService_PutEventServer_Expecter) Recv added in v1.4.0

Recv is a helper method to define mock.On call

func (*MockDataReceiverService_PutEventServer_Expecter) RecvMsg added in v1.4.0

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutEventServer_Expecter) SendAndClose added in v1.4.0

SendAndClose is a helper method to define mock.On call

  • _a0 *Void

func (*MockDataReceiverService_PutEventServer_Expecter) SendHeader added in v1.4.0

SendHeader is a helper method to define mock.On call

  • _a0 metadata.MD

func (*MockDataReceiverService_PutEventServer_Expecter) SendMsg added in v1.4.0

SendMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutEventServer_Expecter) SetHeader added in v1.4.0

SetHeader is a helper method to define mock.On call

  • _a0 metadata.MD

func (*MockDataReceiverService_PutEventServer_Expecter) SetTrailer added in v1.4.0

SetTrailer is a helper method to define mock.On call

  • _a0 metadata.MD

type MockDataReceiverService_PutEventServer_RecvMsg_Call added in v1.4.0

type MockDataReceiverService_PutEventServer_RecvMsg_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventServer_RecvMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecvMsg'

func (*MockDataReceiverService_PutEventServer_RecvMsg_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventServer_RecvMsg_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventServer_RecvMsg_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventServer_Recv_Call added in v1.4.0

type MockDataReceiverService_PutEventServer_Recv_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventServer_Recv_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Recv'

func (*MockDataReceiverService_PutEventServer_Recv_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventServer_Recv_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventServer_Recv_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventServer_SendAndClose_Call added in v1.4.0

type MockDataReceiverService_PutEventServer_SendAndClose_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventServer_SendAndClose_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendAndClose'

func (*MockDataReceiverService_PutEventServer_SendAndClose_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventServer_SendAndClose_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventServer_SendAndClose_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventServer_SendHeader_Call added in v1.4.0

type MockDataReceiverService_PutEventServer_SendHeader_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventServer_SendHeader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendHeader'

func (*MockDataReceiverService_PutEventServer_SendHeader_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventServer_SendHeader_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventServer_SendHeader_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventServer_SendMsg_Call added in v1.4.0

type MockDataReceiverService_PutEventServer_SendMsg_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventServer_SendMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendMsg'

func (*MockDataReceiverService_PutEventServer_SendMsg_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventServer_SendMsg_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventServer_SendMsg_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventServer_SetHeader_Call added in v1.4.0

type MockDataReceiverService_PutEventServer_SetHeader_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventServer_SetHeader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetHeader'

func (*MockDataReceiverService_PutEventServer_SetHeader_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventServer_SetHeader_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventServer_SetHeader_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutEventServer_SetTrailer_Call added in v1.4.0

type MockDataReceiverService_PutEventServer_SetTrailer_Call struct {
	*mock.Call
}

MockDataReceiverService_PutEventServer_SetTrailer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetTrailer'

func (*MockDataReceiverService_PutEventServer_SetTrailer_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutEventServer_SetTrailer_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutEventServer_SetTrailer_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricClient

type MockDataReceiverService_PutMetricClient struct {
	mock.Mock
}

MockDataReceiverService_PutMetricClient is an autogenerated mock type for the DataReceiverService_PutMetricClient type

func NewMockDataReceiverService_PutMetricClient added in v1.4.0

func NewMockDataReceiverService_PutMetricClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDataReceiverService_PutMetricClient

NewMockDataReceiverService_PutMetricClient creates a new instance of MockDataReceiverService_PutMetricClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockDataReceiverService_PutMetricClient) CloseAndRecv

func (_m *MockDataReceiverService_PutMetricClient) CloseAndRecv() (*Void, error)

CloseAndRecv provides a mock function with given fields:

func (*MockDataReceiverService_PutMetricClient) CloseSend

CloseSend provides a mock function with given fields:

func (*MockDataReceiverService_PutMetricClient) Context

Context provides a mock function with given fields:

func (*MockDataReceiverService_PutMetricClient) EXPECT added in v1.4.0

func (*MockDataReceiverService_PutMetricClient) Header

Header provides a mock function with given fields:

func (*MockDataReceiverService_PutMetricClient) RecvMsg

func (_m *MockDataReceiverService_PutMetricClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockDataReceiverService_PutMetricClient) Send

Send provides a mock function with given fields: _a0

func (*MockDataReceiverService_PutMetricClient) SendMsg

func (_m *MockDataReceiverService_PutMetricClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*MockDataReceiverService_PutMetricClient) Trailer

Trailer provides a mock function with given fields:

type MockDataReceiverService_PutMetricClient_CloseAndRecv_Call added in v1.4.0

type MockDataReceiverService_PutMetricClient_CloseAndRecv_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricClient_CloseAndRecv_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CloseAndRecv'

func (*MockDataReceiverService_PutMetricClient_CloseAndRecv_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_CloseAndRecv_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_CloseAndRecv_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricClient_CloseSend_Call added in v1.4.0

type MockDataReceiverService_PutMetricClient_CloseSend_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricClient_CloseSend_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CloseSend'

func (*MockDataReceiverService_PutMetricClient_CloseSend_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_CloseSend_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_CloseSend_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricClient_Context_Call added in v1.4.0

type MockDataReceiverService_PutMetricClient_Context_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricClient_Context_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Context'

func (*MockDataReceiverService_PutMetricClient_Context_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_Context_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_Context_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricClient_Expecter added in v1.4.0

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

func (*MockDataReceiverService_PutMetricClient_Expecter) CloseAndRecv added in v1.4.0

CloseAndRecv is a helper method to define mock.On call

func (*MockDataReceiverService_PutMetricClient_Expecter) CloseSend added in v1.4.0

CloseSend is a helper method to define mock.On call

func (*MockDataReceiverService_PutMetricClient_Expecter) Context added in v1.4.0

Context is a helper method to define mock.On call

func (*MockDataReceiverService_PutMetricClient_Expecter) Header added in v1.4.0

Header is a helper method to define mock.On call

func (*MockDataReceiverService_PutMetricClient_Expecter) RecvMsg added in v1.4.0

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutMetricClient_Expecter) Send added in v1.4.0

Send is a helper method to define mock.On call

  • _a0 *MetricWrapper

func (*MockDataReceiverService_PutMetricClient_Expecter) SendMsg added in v1.4.0

SendMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutMetricClient_Expecter) Trailer added in v1.4.0

Trailer is a helper method to define mock.On call

type MockDataReceiverService_PutMetricClient_Header_Call added in v1.4.0

type MockDataReceiverService_PutMetricClient_Header_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricClient_Header_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Header'

func (*MockDataReceiverService_PutMetricClient_Header_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_Header_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_Header_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricClient_RecvMsg_Call added in v1.4.0

type MockDataReceiverService_PutMetricClient_RecvMsg_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricClient_RecvMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecvMsg'

func (*MockDataReceiverService_PutMetricClient_RecvMsg_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_RecvMsg_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_RecvMsg_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricClient_SendMsg_Call added in v1.4.0

type MockDataReceiverService_PutMetricClient_SendMsg_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricClient_SendMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendMsg'

func (*MockDataReceiverService_PutMetricClient_SendMsg_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_SendMsg_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_SendMsg_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricClient_Send_Call added in v1.4.0

type MockDataReceiverService_PutMetricClient_Send_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricClient_Send_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Send'

func (*MockDataReceiverService_PutMetricClient_Send_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_Send_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_Send_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricClient_Trailer_Call added in v1.4.0

type MockDataReceiverService_PutMetricClient_Trailer_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricClient_Trailer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Trailer'

func (*MockDataReceiverService_PutMetricClient_Trailer_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_Trailer_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricClient_Trailer_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricServer

type MockDataReceiverService_PutMetricServer struct {
	mock.Mock
}

MockDataReceiverService_PutMetricServer is an autogenerated mock type for the DataReceiverService_PutMetricServer type

func NewMockDataReceiverService_PutMetricServer added in v1.4.0

func NewMockDataReceiverService_PutMetricServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDataReceiverService_PutMetricServer

NewMockDataReceiverService_PutMetricServer creates a new instance of MockDataReceiverService_PutMetricServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockDataReceiverService_PutMetricServer) Context

Context provides a mock function with given fields:

func (*MockDataReceiverService_PutMetricServer) EXPECT added in v1.4.0

func (*MockDataReceiverService_PutMetricServer) Recv

Recv provides a mock function with given fields:

func (*MockDataReceiverService_PutMetricServer) RecvMsg

func (_m *MockDataReceiverService_PutMetricServer) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockDataReceiverService_PutMetricServer) SendAndClose

func (_m *MockDataReceiverService_PutMetricServer) SendAndClose(_a0 *Void) error

SendAndClose provides a mock function with given fields: _a0

func (*MockDataReceiverService_PutMetricServer) SendHeader

SendHeader provides a mock function with given fields: _a0

func (*MockDataReceiverService_PutMetricServer) SendMsg

func (_m *MockDataReceiverService_PutMetricServer) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*MockDataReceiverService_PutMetricServer) SetHeader

SetHeader provides a mock function with given fields: _a0

func (*MockDataReceiverService_PutMetricServer) SetTrailer

SetTrailer provides a mock function with given fields: _a0

type MockDataReceiverService_PutMetricServer_Context_Call added in v1.4.0

type MockDataReceiverService_PutMetricServer_Context_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricServer_Context_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Context'

func (*MockDataReceiverService_PutMetricServer_Context_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_Context_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_Context_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricServer_Expecter added in v1.4.0

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

func (*MockDataReceiverService_PutMetricServer_Expecter) Context added in v1.4.0

Context is a helper method to define mock.On call

func (*MockDataReceiverService_PutMetricServer_Expecter) Recv added in v1.4.0

Recv is a helper method to define mock.On call

func (*MockDataReceiverService_PutMetricServer_Expecter) RecvMsg added in v1.4.0

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutMetricServer_Expecter) SendAndClose added in v1.4.0

SendAndClose is a helper method to define mock.On call

  • _a0 *Void

func (*MockDataReceiverService_PutMetricServer_Expecter) SendHeader added in v1.4.0

SendHeader is a helper method to define mock.On call

  • _a0 metadata.MD

func (*MockDataReceiverService_PutMetricServer_Expecter) SendMsg added in v1.4.0

SendMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutMetricServer_Expecter) SetHeader added in v1.4.0

SetHeader is a helper method to define mock.On call

  • _a0 metadata.MD

func (*MockDataReceiverService_PutMetricServer_Expecter) SetTrailer added in v1.4.0

SetTrailer is a helper method to define mock.On call

  • _a0 metadata.MD

type MockDataReceiverService_PutMetricServer_RecvMsg_Call added in v1.4.0

type MockDataReceiverService_PutMetricServer_RecvMsg_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricServer_RecvMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecvMsg'

func (*MockDataReceiverService_PutMetricServer_RecvMsg_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_RecvMsg_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_RecvMsg_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricServer_Recv_Call added in v1.4.0

type MockDataReceiverService_PutMetricServer_Recv_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricServer_Recv_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Recv'

func (*MockDataReceiverService_PutMetricServer_Recv_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_Recv_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_Recv_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricServer_SendAndClose_Call added in v1.4.0

type MockDataReceiverService_PutMetricServer_SendAndClose_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricServer_SendAndClose_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendAndClose'

func (*MockDataReceiverService_PutMetricServer_SendAndClose_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_SendAndClose_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_SendAndClose_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricServer_SendHeader_Call added in v1.4.0

type MockDataReceiverService_PutMetricServer_SendHeader_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricServer_SendHeader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendHeader'

func (*MockDataReceiverService_PutMetricServer_SendHeader_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_SendHeader_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_SendHeader_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricServer_SendMsg_Call added in v1.4.0

type MockDataReceiverService_PutMetricServer_SendMsg_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricServer_SendMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendMsg'

func (*MockDataReceiverService_PutMetricServer_SendMsg_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_SendMsg_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_SendMsg_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricServer_SetHeader_Call added in v1.4.0

type MockDataReceiverService_PutMetricServer_SetHeader_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricServer_SetHeader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetHeader'

func (*MockDataReceiverService_PutMetricServer_SetHeader_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_SetHeader_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_SetHeader_Call) RunAndReturn added in v1.5.1

type MockDataReceiverService_PutMetricServer_SetTrailer_Call added in v1.4.0

type MockDataReceiverService_PutMetricServer_SetTrailer_Call struct {
	*mock.Call
}

MockDataReceiverService_PutMetricServer_SetTrailer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetTrailer'

func (*MockDataReceiverService_PutMetricServer_SetTrailer_Call) Return added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_SetTrailer_Call) Run added in v1.4.0

func (*MockDataReceiverService_PutMetricServer_SetTrailer_Call) RunAndReturn added in v1.5.1

type MockUnsafeDataReceiverServiceServer added in v1.5.0

type MockUnsafeDataReceiverServiceServer struct {
	mock.Mock
}

MockUnsafeDataReceiverServiceServer is an autogenerated mock type for the UnsafeDataReceiverServiceServer type

func NewMockUnsafeDataReceiverServiceServer added in v1.5.0

func NewMockUnsafeDataReceiverServiceServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockUnsafeDataReceiverServiceServer

NewMockUnsafeDataReceiverServiceServer creates a new instance of MockUnsafeDataReceiverServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockUnsafeDataReceiverServiceServer) EXPECT added in v1.5.0

type MockUnsafeDataReceiverServiceServer_Expecter added in v1.5.0

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

type MockUnsafeDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call added in v1.5.0

type MockUnsafeDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call struct {
	*mock.Call
}

MockUnsafeDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'mustEmbedUnimplementedDataReceiverServiceServer'

func (*MockUnsafeDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call) Return added in v1.5.0

func (*MockUnsafeDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call) Run added in v1.5.0

func (*MockUnsafeDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call) RunAndReturn added in v1.5.1

type Model

type Model struct {

	// The time when the value was sent.
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Dimensions associated with this model.
	Dimensions map[string]string `` /* 161-byte string literal not displayed */
	// Fields associated with this model.
	MetadataFields *structpb.Struct `protobuf:"bytes,3,opt,name=metadataFields,proto3" json:"metadataFields,omitempty"`
	// contains filtered or unexported fields
}

func (*Model) Descriptor deprecated

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

Deprecated: Use Model.ProtoReflect.Descriptor instead.

func (*Model) GetDimensions

func (x *Model) GetDimensions() map[string]string

func (*Model) GetMetadataFields

func (x *Model) GetMetadataFields() *structpb.Struct

func (*Model) GetTimestamp

func (x *Model) GetTimestamp() int64

func (*Model) ProtoMessage

func (*Model) ProtoMessage()

func (*Model) ProtoReflect added in v1.4.0

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

func (*Model) Reset

func (x *Model) Reset()

func (*Model) String

func (x *Model) String() string

type ModelError

type ModelError struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Model *Model `protobuf:"bytes,2,opt,name=model,proto3" json:"model,omitempty"`
	// contains filtered or unexported fields
}

func (*ModelError) Descriptor deprecated

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

Deprecated: Use ModelError.ProtoReflect.Descriptor instead.

func (*ModelError) GetError

func (x *ModelError) GetError() string

func (*ModelError) GetModel

func (x *ModelError) GetModel() *Model

func (*ModelError) ProtoMessage

func (*ModelError) ProtoMessage()

func (*ModelError) ProtoReflect added in v1.4.0

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

func (*ModelError) Reset

func (x *ModelError) Reset()

func (*ModelError) String

func (x *ModelError) String() string

type ModelStatusResult

type ModelStatusResult struct {

	// failed is the count of models that failed to be accepted
	Failed int32 `protobuf:"varint,1,opt,name=failed,proto3" json:"failed,omitempty"`
	// succeeded is the count of models that were accepted
	Succeeded int32 `protobuf:"varint,2,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	// message is an informational message that may or may not be set
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// Failed models only returned if detailedResponse is set to true
	FailedModels []*ModelError `protobuf:"bytes,4,rep,name=failedModels,proto3" json:"failedModels,omitempty"`
	// contains filtered or unexported fields
}

func (*ModelStatusResult) Descriptor deprecated

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

Deprecated: Use ModelStatusResult.ProtoReflect.Descriptor instead.

func (*ModelStatusResult) GetFailed

func (x *ModelStatusResult) GetFailed() int32

func (*ModelStatusResult) GetFailedModels

func (x *ModelStatusResult) GetFailedModels() []*ModelError

func (*ModelStatusResult) GetMessage

func (x *ModelStatusResult) GetMessage() string

func (*ModelStatusResult) GetSucceeded

func (x *ModelStatusResult) GetSucceeded() int32

func (*ModelStatusResult) ProtoMessage

func (*ModelStatusResult) ProtoMessage()

func (*ModelStatusResult) ProtoReflect added in v1.4.0

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

func (*ModelStatusResult) Reset

func (x *ModelStatusResult) Reset()

func (*ModelStatusResult) String

func (x *ModelStatusResult) String() string

type Models

type Models struct {

	// detailedResponse if set to true will return any models that failed to be sent
	DetailedResponse bool `protobuf:"varint,1,opt,name=detailedResponse,proto3" json:"detailedResponse,omitempty"`
	// The models
	Models []*Model `protobuf:"bytes,2,rep,name=models,proto3" json:"models,omitempty"`
	// contains filtered or unexported fields
}

func (*Models) Descriptor deprecated

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

Deprecated: Use Models.ProtoReflect.Descriptor instead.

func (*Models) GetDetailedResponse

func (x *Models) GetDetailedResponse() bool

func (*Models) GetModels

func (x *Models) GetModels() []*Model

func (*Models) ProtoMessage

func (*Models) ProtoMessage()

func (*Models) ProtoReflect added in v1.4.0

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

func (*Models) Reset

func (x *Models) Reset()

func (*Models) String

func (x *Models) String() string

type Severity added in v1.1.0

type Severity int32
const (
	Severity_SEVERITY_DEFAULT  Severity = 0
	Severity_SEVERITY_DEBUG    Severity = 1
	Severity_SEVERITY_INFO     Severity = 2
	Severity_SEVERITY_WARNING  Severity = 3
	Severity_SEVERITY_ERROR    Severity = 4
	Severity_SEVERITY_CRITICAL Severity = 5
)

func (Severity) Descriptor added in v1.4.0

func (Severity) Descriptor() protoreflect.EnumDescriptor

func (Severity) Enum added in v1.4.0

func (x Severity) Enum() *Severity

func (Severity) EnumDescriptor deprecated added in v1.1.0

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

Deprecated: Use Severity.Descriptor instead.

func (Severity) Number added in v1.4.0

func (x Severity) Number() protoreflect.EnumNumber

func (Severity) String added in v1.1.0

func (x Severity) String() string

func (Severity) Type added in v1.4.0

type Status added in v1.1.0

type Status int32
const (
	Status_STATUS_DEFAULT    Status = 0
	Status_STATUS_OPEN       Status = 1
	Status_STATUS_SUPPRESSED Status = 2
	Status_STATUS_CLOSED     Status = 3
)

func (Status) Descriptor added in v1.4.0

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum added in v1.4.0

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated added in v1.1.0

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number added in v1.4.0

func (x Status) Number() protoreflect.EnumNumber

func (Status) String added in v1.1.0

func (x Status) String() string

func (Status) Type added in v1.4.0

func (Status) Type() protoreflect.EnumType

type StatusResult

type StatusResult struct {

	// failed is the count of metrics that failed to be accepted
	Failed int32 `protobuf:"varint,1,opt,name=failed,proto3" json:"failed,omitempty"`
	// succeeded is the count of metrics that were accepted
	Succeeded int32 `protobuf:"varint,2,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	// message is an informational message that may or may not be set
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// Failed metrics only returned if detailedResponse is set to true
	FailedCompactMetrics []*CompactMetricError `protobuf:"bytes,4,rep,name=failedCompactMetrics,proto3" json:"failedCompactMetrics,omitempty"`
	FailedTaggedMetrics  []*TaggedMetricError  `protobuf:"bytes,5,rep,name=failedTaggedMetrics,proto3" json:"failedTaggedMetrics,omitempty"`
	FailedMetrics        []*MetricError        `protobuf:"bytes,6,rep,name=failedMetrics,proto3" json:"failedMetrics,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResult) Descriptor deprecated

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

Deprecated: Use StatusResult.ProtoReflect.Descriptor instead.

func (*StatusResult) GetFailed

func (x *StatusResult) GetFailed() int32

func (*StatusResult) GetFailedCompactMetrics

func (x *StatusResult) GetFailedCompactMetrics() []*CompactMetricError

func (*StatusResult) GetFailedMetrics

func (x *StatusResult) GetFailedMetrics() []*MetricError

func (*StatusResult) GetFailedTaggedMetrics

func (x *StatusResult) GetFailedTaggedMetrics() []*TaggedMetricError

func (*StatusResult) GetMessage

func (x *StatusResult) GetMessage() string

func (*StatusResult) GetSucceeded

func (x *StatusResult) GetSucceeded() int32

func (*StatusResult) ProtoMessage

func (*StatusResult) ProtoMessage()

func (*StatusResult) ProtoReflect added in v1.4.0

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

func (*StatusResult) Reset

func (x *StatusResult) Reset()

func (*StatusResult) String

func (x *StatusResult) String() string

type TaggedMetric

type TaggedMetric struct {

	// The metric name
	Metric string `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	// The time at which the value was captured
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The metric value
	Value float64 `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"`
	// Metadata associated with this datapoint.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaggedMetric) Descriptor deprecated

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

Deprecated: Use TaggedMetric.ProtoReflect.Descriptor instead.

func (*TaggedMetric) GetMetric

func (x *TaggedMetric) GetMetric() string

func (*TaggedMetric) GetTags

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

func (*TaggedMetric) GetTimestamp

func (x *TaggedMetric) GetTimestamp() int64

func (*TaggedMetric) GetValue

func (x *TaggedMetric) GetValue() float64

func (*TaggedMetric) ProtoMessage

func (*TaggedMetric) ProtoMessage()

func (*TaggedMetric) ProtoReflect added in v1.4.0

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

func (*TaggedMetric) Reset

func (x *TaggedMetric) Reset()

func (*TaggedMetric) String

func (x *TaggedMetric) String() string

type TaggedMetricError

type TaggedMetricError struct {
	Error  string        `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Metric *TaggedMetric `protobuf:"bytes,2,opt,name=metric,proto3" json:"metric,omitempty"`
	// contains filtered or unexported fields
}

func (*TaggedMetricError) Descriptor deprecated

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

Deprecated: Use TaggedMetricError.ProtoReflect.Descriptor instead.

func (*TaggedMetricError) GetError

func (x *TaggedMetricError) GetError() string

func (*TaggedMetricError) GetMetric

func (x *TaggedMetricError) GetMetric() *TaggedMetric

func (*TaggedMetricError) ProtoMessage

func (*TaggedMetricError) ProtoMessage()

func (*TaggedMetricError) ProtoReflect added in v1.4.0

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

func (*TaggedMetricError) Reset

func (x *TaggedMetricError) Reset()

func (*TaggedMetricError) String

func (x *TaggedMetricError) String() string

type UnimplementedDataReceiverServiceServer

type UnimplementedDataReceiverServiceServer struct {
}

UnimplementedDataReceiverServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDataReceiverServiceServer) PutEvent added in v1.1.0

func (UnimplementedDataReceiverServiceServer) PutEvents added in v1.1.0

func (UnimplementedDataReceiverServiceServer) PutMetric

func (UnimplementedDataReceiverServiceServer) PutMetrics

func (UnimplementedDataReceiverServiceServer) PutModels

type UnsafeDataReceiverServiceServer added in v1.5.0

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

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

type Void

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

func (*Void) Descriptor deprecated

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

Deprecated: Use Void.ProtoReflect.Descriptor instead.

func (*Void) ProtoMessage

func (*Void) ProtoMessage()

func (*Void) ProtoReflect added in v1.4.0

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

func (*Void) Reset

func (x *Void) Reset()

func (*Void) String

func (x *Void) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL