data_receiver

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2022 License: Apache-2.0 Imports: 19 Imported by: 9

Documentation

Overview

Package data_receiver is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

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.

func NewDataReceiverServiceClient 

func NewDataReceiverServiceClient(cc grpc.ClientConnInterface) DataReceiverServiceClient

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 mockConstructorTestingTNewMockDataReceiverServiceClient) *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.

func (*MockDataReceiverServiceClient) EXPECT added in v1.4.0 

func (_m *MockDataReceiverServiceClient) EXPECT() *MockDataReceiverServiceClient_Expecter

func (*MockDataReceiverServiceClient) PutEvent added in v1.1.0 

func (_m *MockDataReceiverServiceClient) PutEvent(ctx context.Context, opts ...grpc.CallOption) (DataReceiverService_PutEventClient, error)

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

func (*MockDataReceiverServiceClient) PutEvents added in v1.1.0 

func (_m *MockDataReceiverServiceClient) PutEvents(ctx context.Context, in *Events, opts ...grpc.CallOption) (*EventStatusResult, error)

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

func (*MockDataReceiverServiceClient) PutMetric 

func (_m *MockDataReceiverServiceClient) PutMetric(ctx context.Context, opts ...grpc.CallOption) (DataReceiverService_PutMetricClient, error)

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 

func (_m *MockDataReceiverServiceClient) PutModels(ctx context.Context, in *Models, opts ...grpc.CallOption) (*ModelStatusResult, error)

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 (_c *MockDataReceiverServiceClient_PutEvent_Call) Return(_a0 DataReceiverService_PutEventClient, _a1 error) *MockDataReceiverServiceClient_PutEvent_Call

func (*MockDataReceiverServiceClient_PutEvent_Call) Run added in v1.4.0 

func (_c *MockDataReceiverServiceClient_PutEvent_Call) Run(run func(ctx context.Context, opts ...grpc.CallOption)) *MockDataReceiverServiceClient_PutEvent_Call

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 (_c *MockDataReceiverServiceClient_PutEvents_Call) Return(_a0 *EventStatusResult, _a1 error) *MockDataReceiverServiceClient_PutEvents_Call

func (*MockDataReceiverServiceClient_PutEvents_Call) Run added in v1.4.0 

func (_c *MockDataReceiverServiceClient_PutEvents_Call) Run(run func(ctx context.Context, in *Events, opts ...grpc.CallOption)) *MockDataReceiverServiceClient_PutEvents_Call

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 (_c *MockDataReceiverServiceClient_PutMetric_Call) Return(_a0 DataReceiverService_PutMetricClient, _a1 error) *MockDataReceiverServiceClient_PutMetric_Call

func (*MockDataReceiverServiceClient_PutMetric_Call) Run added in v1.4.0 

func (_c *MockDataReceiverServiceClient_PutMetric_Call) Run(run func(ctx context.Context, opts ...grpc.CallOption)) *MockDataReceiverServiceClient_PutMetric_Call

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 (_c *MockDataReceiverServiceClient_PutMetrics_Call) Return(_a0 *StatusResult, _a1 error) *MockDataReceiverServiceClient_PutMetrics_Call

func (*MockDataReceiverServiceClient_PutMetrics_Call) Run added in v1.4.0 

func (_c *MockDataReceiverServiceClient_PutMetrics_Call) Run(run func(ctx context.Context, in *Metrics, opts ...grpc.CallOption)) *MockDataReceiverServiceClient_PutMetrics_Call

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 (_c *MockDataReceiverServiceClient_PutModels_Call) Return(_a0 *ModelStatusResult, _a1 error) *MockDataReceiverServiceClient_PutModels_Call

func (*MockDataReceiverServiceClient_PutModels_Call) Run added in v1.4.0 

func (_c *MockDataReceiverServiceClient_PutModels_Call) Run(run func(ctx context.Context, in *Models, opts ...grpc.CallOption)) *MockDataReceiverServiceClient_PutModels_Call

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 mockConstructorTestingTNewMockDataReceiverServiceServer) *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.

func (*MockDataReceiverServiceServer) EXPECT added in v1.4.0 

func (_m *MockDataReceiverServiceServer) EXPECT() *MockDataReceiverServiceServer_Expecter

func (*MockDataReceiverServiceServer) PutEvent added in v1.1.0 

func (_m *MockDataReceiverServiceServer) PutEvent(_a0 DataReceiverService_PutEventServer) error

PutEvent provides a mock function with given fields: _a0

func (*MockDataReceiverServiceServer) PutEvents added in v1.1.0 

func (_m *MockDataReceiverServiceServer) PutEvents(_a0 context.Context, _a1 *Events) (*EventStatusResult, error)

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

func (*MockDataReceiverServiceServer) PutMetric 

func (_m *MockDataReceiverServiceServer) PutMetric(_a0 DataReceiverService_PutMetricServer) error

PutMetric provides a mock function with given fields: _a0

func (*MockDataReceiverServiceServer) PutMetrics 

func (_m *MockDataReceiverServiceServer) PutMetrics(_a0 context.Context, _a1 *Metrics) (*StatusResult, error)

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

func (*MockDataReceiverServiceServer) PutModels 

func (_m *MockDataReceiverServiceServer) PutModels(_a0 context.Context, _a1 *Models) (*ModelStatusResult, error)

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 

func (_e *MockDataReceiverServiceServer_Expecter) PutEvent(_a0 interface{}) *MockDataReceiverServiceServer_PutEvent_Call

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 

func (_e *MockDataReceiverServiceServer_Expecter) PutMetric(_a0 interface{}) *MockDataReceiverServiceServer_PutMetric_Call

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 (_c *MockDataReceiverServiceServer_PutEvent_Call) Return(_a0 error) *MockDataReceiverServiceServer_PutEvent_Call

func (*MockDataReceiverServiceServer_PutEvent_Call) Run added in v1.4.0 

func (_c *MockDataReceiverServiceServer_PutEvent_Call) Run(run func(_a0 DataReceiverService_PutEventServer)) *MockDataReceiverServiceServer_PutEvent_Call

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 (_c *MockDataReceiverServiceServer_PutEvents_Call) Return(_a0 *EventStatusResult, _a1 error) *MockDataReceiverServiceServer_PutEvents_Call

func (*MockDataReceiverServiceServer_PutEvents_Call) Run added in v1.4.0 

func (_c *MockDataReceiverServiceServer_PutEvents_Call) Run(run func(_a0 context.Context, _a1 *Events)) *MockDataReceiverServiceServer_PutEvents_Call

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 (_c *MockDataReceiverServiceServer_PutMetric_Call) Return(_a0 error) *MockDataReceiverServiceServer_PutMetric_Call

func (*MockDataReceiverServiceServer_PutMetric_Call) Run added in v1.4.0 

func (_c *MockDataReceiverServiceServer_PutMetric_Call) Run(run func(_a0 DataReceiverService_PutMetricServer)) *MockDataReceiverServiceServer_PutMetric_Call

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 (_c *MockDataReceiverServiceServer_PutMetrics_Call) Return(_a0 *StatusResult, _a1 error) *MockDataReceiverServiceServer_PutMetrics_Call

func (*MockDataReceiverServiceServer_PutMetrics_Call) Run added in v1.4.0 

func (_c *MockDataReceiverServiceServer_PutMetrics_Call) Run(run func(_a0 context.Context, _a1 *Metrics)) *MockDataReceiverServiceServer_PutMetrics_Call

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 (_c *MockDataReceiverServiceServer_PutModels_Call) Return(_a0 *ModelStatusResult, _a1 error) *MockDataReceiverServiceServer_PutModels_Call

func (*MockDataReceiverServiceServer_PutModels_Call) Run added in v1.4.0 

func (_c *MockDataReceiverServiceServer_PutModels_Call) Run(run func(_a0 context.Context, _a1 *Models)) *MockDataReceiverServiceServer_PutModels_Call

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 (_c *MockDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call) Return() *MockDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call

func (*MockDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call) Run added in v1.5.0 

func (_c *MockDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call) Run(run func()) *MockDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call

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 mockConstructorTestingTNewMockDataReceiverService_PutEventClient) *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.

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 

func (_m *MockDataReceiverService_PutEventClient) CloseSend() error

CloseSend provides a mock function with given fields:

func (*MockDataReceiverService_PutEventClient) Context added in v1.1.0 

func (_m *MockDataReceiverService_PutEventClient) Context() context.Context

Context provides a mock function with given fields:

func (*MockDataReceiverService_PutEventClient) EXPECT added in v1.4.0 

func (_m *MockDataReceiverService_PutEventClient) EXPECT() *MockDataReceiverService_PutEventClient_Expecter

func (*MockDataReceiverService_PutEventClient) Header added in v1.1.0 

func (_m *MockDataReceiverService_PutEventClient) Header() (metadata.MD, error)

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 

func (_m *MockDataReceiverService_PutEventClient) Send(_a0 *EventWrapper) error

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 

func (_m *MockDataReceiverService_PutEventClient) Trailer() metadata.MD

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 (_c *MockDataReceiverService_PutEventClient_CloseAndRecv_Call) Return(_a0 *Void, _a1 error) *MockDataReceiverService_PutEventClient_CloseAndRecv_Call

func (*MockDataReceiverService_PutEventClient_CloseAndRecv_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventClient_CloseAndRecv_Call) Run(run func()) *MockDataReceiverService_PutEventClient_CloseAndRecv_Call

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 (_c *MockDataReceiverService_PutEventClient_CloseSend_Call) Return(_a0 error) *MockDataReceiverService_PutEventClient_CloseSend_Call

func (*MockDataReceiverService_PutEventClient_CloseSend_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventClient_CloseSend_Call) Run(run func()) *MockDataReceiverService_PutEventClient_CloseSend_Call

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 (_c *MockDataReceiverService_PutEventClient_Context_Call) Return(_a0 context.Context) *MockDataReceiverService_PutEventClient_Context_Call

func (*MockDataReceiverService_PutEventClient_Context_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventClient_Context_Call) Run(run func()) *MockDataReceiverService_PutEventClient_Context_Call

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 

func (_e *MockDataReceiverService_PutEventClient_Expecter) CloseAndRecv() *MockDataReceiverService_PutEventClient_CloseAndRecv_Call

CloseAndRecv is a helper method to define mock.On call

func (*MockDataReceiverService_PutEventClient_Expecter) CloseSend added in v1.4.0 

func (_e *MockDataReceiverService_PutEventClient_Expecter) CloseSend() *MockDataReceiverService_PutEventClient_CloseSend_Call

CloseSend is a helper method to define mock.On call

func (*MockDataReceiverService_PutEventClient_Expecter) Context added in v1.4.0 

func (_e *MockDataReceiverService_PutEventClient_Expecter) Context() *MockDataReceiverService_PutEventClient_Context_Call

Context is a helper method to define mock.On call

func (*MockDataReceiverService_PutEventClient_Expecter) Header added in v1.4.0 

func (_e *MockDataReceiverService_PutEventClient_Expecter) Header() *MockDataReceiverService_PutEventClient_Header_Call

Header is a helper method to define mock.On call

func (*MockDataReceiverService_PutEventClient_Expecter) RecvMsg added in v1.4.0 

func (_e *MockDataReceiverService_PutEventClient_Expecter) RecvMsg(m interface{}) *MockDataReceiverService_PutEventClient_RecvMsg_Call

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutEventClient_Expecter) Send added in v1.4.0 

func (_e *MockDataReceiverService_PutEventClient_Expecter) Send(_a0 interface{}) *MockDataReceiverService_PutEventClient_Send_Call

Send is a helper method to define mock.On call

  • _a0 *EventWrapper

func (*MockDataReceiverService_PutEventClient_Expecter) SendMsg added in v1.4.0 

func (_e *MockDataReceiverService_PutEventClient_Expecter) SendMsg(m interface{}) *MockDataReceiverService_PutEventClient_SendMsg_Call

SendMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutEventClient_Expecter) Trailer added in v1.4.0 

func (_e *MockDataReceiverService_PutEventClient_Expecter) Trailer() *MockDataReceiverService_PutEventClient_Trailer_Call

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 (_c *MockDataReceiverService_PutEventClient_Header_Call) Return(_a0 metadata.MD, _a1 error) *MockDataReceiverService_PutEventClient_Header_Call

func (*MockDataReceiverService_PutEventClient_Header_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventClient_Header_Call) Run(run func()) *MockDataReceiverService_PutEventClient_Header_Call

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 (_c *MockDataReceiverService_PutEventClient_RecvMsg_Call) Return(_a0 error) *MockDataReceiverService_PutEventClient_RecvMsg_Call

func (*MockDataReceiverService_PutEventClient_RecvMsg_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventClient_RecvMsg_Call) Run(run func(m interface{})) *MockDataReceiverService_PutEventClient_RecvMsg_Call

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 (_c *MockDataReceiverService_PutEventClient_SendMsg_Call) Return(_a0 error) *MockDataReceiverService_PutEventClient_SendMsg_Call

func (*MockDataReceiverService_PutEventClient_SendMsg_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventClient_SendMsg_Call) Run(run func(m interface{})) *MockDataReceiverService_PutEventClient_SendMsg_Call

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 (_c *MockDataReceiverService_PutEventClient_Send_Call) Return(_a0 error) *MockDataReceiverService_PutEventClient_Send_Call

func (*MockDataReceiverService_PutEventClient_Send_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventClient_Send_Call) Run(run func(_a0 *EventWrapper)) *MockDataReceiverService_PutEventClient_Send_Call

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 (_c *MockDataReceiverService_PutEventClient_Trailer_Call) Return(_a0 metadata.MD) *MockDataReceiverService_PutEventClient_Trailer_Call

func (*MockDataReceiverService_PutEventClient_Trailer_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventClient_Trailer_Call) Run(run func()) *MockDataReceiverService_PutEventClient_Trailer_Call

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 mockConstructorTestingTNewMockDataReceiverService_PutEventServer) *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.

func (*MockDataReceiverService_PutEventServer) Context added in v1.1.0 

func (_m *MockDataReceiverService_PutEventServer) Context() context.Context

Context provides a mock function with given fields:

func (*MockDataReceiverService_PutEventServer) EXPECT added in v1.4.0 

func (_m *MockDataReceiverService_PutEventServer) EXPECT() *MockDataReceiverService_PutEventServer_Expecter

func (*MockDataReceiverService_PutEventServer) Recv added in v1.1.0 

func (_m *MockDataReceiverService_PutEventServer) Recv() (*EventWrapper, error)

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 

func (_m *MockDataReceiverService_PutEventServer) SendHeader(_a0 metadata.MD) error

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 

func (_m *MockDataReceiverService_PutEventServer) SetHeader(_a0 metadata.MD) error

SetHeader provides a mock function with given fields: _a0

func (*MockDataReceiverService_PutEventServer) SetTrailer added in v1.1.0 

func (_m *MockDataReceiverService_PutEventServer) SetTrailer(_a0 metadata.MD)

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 (_c *MockDataReceiverService_PutEventServer_Context_Call) Return(_a0 context.Context) *MockDataReceiverService_PutEventServer_Context_Call

func (*MockDataReceiverService_PutEventServer_Context_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventServer_Context_Call) Run(run func()) *MockDataReceiverService_PutEventServer_Context_Call

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 

func (_e *MockDataReceiverService_PutEventServer_Expecter) Context() *MockDataReceiverService_PutEventServer_Context_Call

Context is a helper method to define mock.On call

func (*MockDataReceiverService_PutEventServer_Expecter) Recv added in v1.4.0 

func (_e *MockDataReceiverService_PutEventServer_Expecter) Recv() *MockDataReceiverService_PutEventServer_Recv_Call

Recv is a helper method to define mock.On call

func (*MockDataReceiverService_PutEventServer_Expecter) RecvMsg added in v1.4.0 

func (_e *MockDataReceiverService_PutEventServer_Expecter) RecvMsg(m interface{}) *MockDataReceiverService_PutEventServer_RecvMsg_Call

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutEventServer_Expecter) SendAndClose added in v1.4.0 

func (_e *MockDataReceiverService_PutEventServer_Expecter) SendAndClose(_a0 interface{}) *MockDataReceiverService_PutEventServer_SendAndClose_Call

SendAndClose is a helper method to define mock.On call

  • _a0 *Void

func (*MockDataReceiverService_PutEventServer_Expecter) SendHeader added in v1.4.0 

func (_e *MockDataReceiverService_PutEventServer_Expecter) SendHeader(_a0 interface{}) *MockDataReceiverService_PutEventServer_SendHeader_Call

SendHeader is a helper method to define mock.On call

  • _a0 metadata.MD

func (*MockDataReceiverService_PutEventServer_Expecter) SendMsg added in v1.4.0 

func (_e *MockDataReceiverService_PutEventServer_Expecter) SendMsg(m interface{}) *MockDataReceiverService_PutEventServer_SendMsg_Call

SendMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutEventServer_Expecter) SetHeader added in v1.4.0 

func (_e *MockDataReceiverService_PutEventServer_Expecter) SetHeader(_a0 interface{}) *MockDataReceiverService_PutEventServer_SetHeader_Call

SetHeader is a helper method to define mock.On call

  • _a0 metadata.MD

func (*MockDataReceiverService_PutEventServer_Expecter) SetTrailer added in v1.4.0 

func (_e *MockDataReceiverService_PutEventServer_Expecter) SetTrailer(_a0 interface{}) *MockDataReceiverService_PutEventServer_SetTrailer_Call

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 (_c *MockDataReceiverService_PutEventServer_RecvMsg_Call) Return(_a0 error) *MockDataReceiverService_PutEventServer_RecvMsg_Call

func (*MockDataReceiverService_PutEventServer_RecvMsg_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventServer_RecvMsg_Call) Run(run func(m interface{})) *MockDataReceiverService_PutEventServer_RecvMsg_Call

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 (_c *MockDataReceiverService_PutEventServer_Recv_Call) Return(_a0 *EventWrapper, _a1 error) *MockDataReceiverService_PutEventServer_Recv_Call

func (*MockDataReceiverService_PutEventServer_Recv_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventServer_Recv_Call) Run(run func()) *MockDataReceiverService_PutEventServer_Recv_Call

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 (_c *MockDataReceiverService_PutEventServer_SendAndClose_Call) Return(_a0 error) *MockDataReceiverService_PutEventServer_SendAndClose_Call

func (*MockDataReceiverService_PutEventServer_SendAndClose_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventServer_SendAndClose_Call) Run(run func(_a0 *Void)) *MockDataReceiverService_PutEventServer_SendAndClose_Call

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 (_c *MockDataReceiverService_PutEventServer_SendHeader_Call) Return(_a0 error) *MockDataReceiverService_PutEventServer_SendHeader_Call

func (*MockDataReceiverService_PutEventServer_SendHeader_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventServer_SendHeader_Call) Run(run func(_a0 metadata.MD)) *MockDataReceiverService_PutEventServer_SendHeader_Call

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 (_c *MockDataReceiverService_PutEventServer_SendMsg_Call) Return(_a0 error) *MockDataReceiverService_PutEventServer_SendMsg_Call

func (*MockDataReceiverService_PutEventServer_SendMsg_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventServer_SendMsg_Call) Run(run func(m interface{})) *MockDataReceiverService_PutEventServer_SendMsg_Call

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 (_c *MockDataReceiverService_PutEventServer_SetHeader_Call) Return(_a0 error) *MockDataReceiverService_PutEventServer_SetHeader_Call

func (*MockDataReceiverService_PutEventServer_SetHeader_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventServer_SetHeader_Call) Run(run func(_a0 metadata.MD)) *MockDataReceiverService_PutEventServer_SetHeader_Call

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 (_c *MockDataReceiverService_PutEventServer_SetTrailer_Call) Return() *MockDataReceiverService_PutEventServer_SetTrailer_Call

func (*MockDataReceiverService_PutEventServer_SetTrailer_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutEventServer_SetTrailer_Call) Run(run func(_a0 metadata.MD)) *MockDataReceiverService_PutEventServer_SetTrailer_Call

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 mockConstructorTestingTNewMockDataReceiverService_PutMetricClient) *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.

func (*MockDataReceiverService_PutMetricClient) CloseAndRecv 

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

CloseAndRecv provides a mock function with given fields:

func (*MockDataReceiverService_PutMetricClient) CloseSend 

func (_m *MockDataReceiverService_PutMetricClient) CloseSend() error

CloseSend provides a mock function with given fields:

func (*MockDataReceiverService_PutMetricClient) Context 

func (_m *MockDataReceiverService_PutMetricClient) Context() context.Context

Context provides a mock function with given fields:

func (*MockDataReceiverService_PutMetricClient) EXPECT added in v1.4.0 

func (_m *MockDataReceiverService_PutMetricClient) EXPECT() *MockDataReceiverService_PutMetricClient_Expecter

func (*MockDataReceiverService_PutMetricClient) Header 

func (_m *MockDataReceiverService_PutMetricClient) Header() (metadata.MD, error)

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 

func (_m *MockDataReceiverService_PutMetricClient) Send(_a0 *MetricWrapper) error

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 

func (_m *MockDataReceiverService_PutMetricClient) Trailer() metadata.MD

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 (_c *MockDataReceiverService_PutMetricClient_CloseAndRecv_Call) Return(_a0 *Void, _a1 error) *MockDataReceiverService_PutMetricClient_CloseAndRecv_Call

func (*MockDataReceiverService_PutMetricClient_CloseAndRecv_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricClient_CloseAndRecv_Call) Run(run func()) *MockDataReceiverService_PutMetricClient_CloseAndRecv_Call

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 (_c *MockDataReceiverService_PutMetricClient_CloseSend_Call) Return(_a0 error) *MockDataReceiverService_PutMetricClient_CloseSend_Call

func (*MockDataReceiverService_PutMetricClient_CloseSend_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricClient_CloseSend_Call) Run(run func()) *MockDataReceiverService_PutMetricClient_CloseSend_Call

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 (_c *MockDataReceiverService_PutMetricClient_Context_Call) Return(_a0 context.Context) *MockDataReceiverService_PutMetricClient_Context_Call

func (*MockDataReceiverService_PutMetricClient_Context_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricClient_Context_Call) Run(run func()) *MockDataReceiverService_PutMetricClient_Context_Call

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 

func (_e *MockDataReceiverService_PutMetricClient_Expecter) CloseAndRecv() *MockDataReceiverService_PutMetricClient_CloseAndRecv_Call

CloseAndRecv is a helper method to define mock.On call

func (*MockDataReceiverService_PutMetricClient_Expecter) CloseSend added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricClient_Expecter) CloseSend() *MockDataReceiverService_PutMetricClient_CloseSend_Call

CloseSend is a helper method to define mock.On call

func (*MockDataReceiverService_PutMetricClient_Expecter) Context added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricClient_Expecter) Context() *MockDataReceiverService_PutMetricClient_Context_Call

Context is a helper method to define mock.On call

func (*MockDataReceiverService_PutMetricClient_Expecter) Header added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricClient_Expecter) Header() *MockDataReceiverService_PutMetricClient_Header_Call

Header is a helper method to define mock.On call

func (*MockDataReceiverService_PutMetricClient_Expecter) RecvMsg added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricClient_Expecter) RecvMsg(m interface{}) *MockDataReceiverService_PutMetricClient_RecvMsg_Call

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutMetricClient_Expecter) Send added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricClient_Expecter) Send(_a0 interface{}) *MockDataReceiverService_PutMetricClient_Send_Call

Send is a helper method to define mock.On call

  • _a0 *MetricWrapper

func (*MockDataReceiverService_PutMetricClient_Expecter) SendMsg added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricClient_Expecter) SendMsg(m interface{}) *MockDataReceiverService_PutMetricClient_SendMsg_Call

SendMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutMetricClient_Expecter) Trailer added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricClient_Expecter) Trailer() *MockDataReceiverService_PutMetricClient_Trailer_Call

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 (_c *MockDataReceiverService_PutMetricClient_Header_Call) Return(_a0 metadata.MD, _a1 error) *MockDataReceiverService_PutMetricClient_Header_Call

func (*MockDataReceiverService_PutMetricClient_Header_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricClient_Header_Call) Run(run func()) *MockDataReceiverService_PutMetricClient_Header_Call

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 (_c *MockDataReceiverService_PutMetricClient_RecvMsg_Call) Return(_a0 error) *MockDataReceiverService_PutMetricClient_RecvMsg_Call

func (*MockDataReceiverService_PutMetricClient_RecvMsg_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricClient_RecvMsg_Call) Run(run func(m interface{})) *MockDataReceiverService_PutMetricClient_RecvMsg_Call

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 (_c *MockDataReceiverService_PutMetricClient_SendMsg_Call) Return(_a0 error) *MockDataReceiverService_PutMetricClient_SendMsg_Call

func (*MockDataReceiverService_PutMetricClient_SendMsg_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricClient_SendMsg_Call) Run(run func(m interface{})) *MockDataReceiverService_PutMetricClient_SendMsg_Call

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 (_c *MockDataReceiverService_PutMetricClient_Send_Call) Return(_a0 error) *MockDataReceiverService_PutMetricClient_Send_Call

func (*MockDataReceiverService_PutMetricClient_Send_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricClient_Send_Call) Run(run func(_a0 *MetricWrapper)) *MockDataReceiverService_PutMetricClient_Send_Call

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 (_c *MockDataReceiverService_PutMetricClient_Trailer_Call) Return(_a0 metadata.MD) *MockDataReceiverService_PutMetricClient_Trailer_Call

func (*MockDataReceiverService_PutMetricClient_Trailer_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricClient_Trailer_Call) Run(run func()) *MockDataReceiverService_PutMetricClient_Trailer_Call

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 mockConstructorTestingTNewMockDataReceiverService_PutMetricServer) *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.

func (*MockDataReceiverService_PutMetricServer) Context 

func (_m *MockDataReceiverService_PutMetricServer) Context() context.Context

Context provides a mock function with given fields:

func (*MockDataReceiverService_PutMetricServer) EXPECT added in v1.4.0 

func (_m *MockDataReceiverService_PutMetricServer) EXPECT() *MockDataReceiverService_PutMetricServer_Expecter

func (*MockDataReceiverService_PutMetricServer) Recv 

func (_m *MockDataReceiverService_PutMetricServer) Recv() (*MetricWrapper, error)

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 

func (_m *MockDataReceiverService_PutMetricServer) SendHeader(_a0 metadata.MD) error

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 

func (_m *MockDataReceiverService_PutMetricServer) SetHeader(_a0 metadata.MD) error

SetHeader provides a mock function with given fields: _a0

func (*MockDataReceiverService_PutMetricServer) SetTrailer 

func (_m *MockDataReceiverService_PutMetricServer) SetTrailer(_a0 metadata.MD)

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 (_c *MockDataReceiverService_PutMetricServer_Context_Call) Return(_a0 context.Context) *MockDataReceiverService_PutMetricServer_Context_Call

func (*MockDataReceiverService_PutMetricServer_Context_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricServer_Context_Call) Run(run func()) *MockDataReceiverService_PutMetricServer_Context_Call

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 

func (_e *MockDataReceiverService_PutMetricServer_Expecter) Context() *MockDataReceiverService_PutMetricServer_Context_Call

Context is a helper method to define mock.On call

func (*MockDataReceiverService_PutMetricServer_Expecter) Recv added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricServer_Expecter) Recv() *MockDataReceiverService_PutMetricServer_Recv_Call

Recv is a helper method to define mock.On call

func (*MockDataReceiverService_PutMetricServer_Expecter) RecvMsg added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricServer_Expecter) RecvMsg(m interface{}) *MockDataReceiverService_PutMetricServer_RecvMsg_Call

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutMetricServer_Expecter) SendAndClose added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricServer_Expecter) SendAndClose(_a0 interface{}) *MockDataReceiverService_PutMetricServer_SendAndClose_Call

SendAndClose is a helper method to define mock.On call

  • _a0 *Void

func (*MockDataReceiverService_PutMetricServer_Expecter) SendHeader added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricServer_Expecter) SendHeader(_a0 interface{}) *MockDataReceiverService_PutMetricServer_SendHeader_Call

SendHeader is a helper method to define mock.On call

  • _a0 metadata.MD

func (*MockDataReceiverService_PutMetricServer_Expecter) SendMsg added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricServer_Expecter) SendMsg(m interface{}) *MockDataReceiverService_PutMetricServer_SendMsg_Call

SendMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataReceiverService_PutMetricServer_Expecter) SetHeader added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricServer_Expecter) SetHeader(_a0 interface{}) *MockDataReceiverService_PutMetricServer_SetHeader_Call

SetHeader is a helper method to define mock.On call

  • _a0 metadata.MD

func (*MockDataReceiverService_PutMetricServer_Expecter) SetTrailer added in v1.4.0 

func (_e *MockDataReceiverService_PutMetricServer_Expecter) SetTrailer(_a0 interface{}) *MockDataReceiverService_PutMetricServer_SetTrailer_Call

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 (_c *MockDataReceiverService_PutMetricServer_RecvMsg_Call) Return(_a0 error) *MockDataReceiverService_PutMetricServer_RecvMsg_Call

func (*MockDataReceiverService_PutMetricServer_RecvMsg_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricServer_RecvMsg_Call) Run(run func(m interface{})) *MockDataReceiverService_PutMetricServer_RecvMsg_Call

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 (_c *MockDataReceiverService_PutMetricServer_Recv_Call) Return(_a0 *MetricWrapper, _a1 error) *MockDataReceiverService_PutMetricServer_Recv_Call

func (*MockDataReceiverService_PutMetricServer_Recv_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricServer_Recv_Call) Run(run func()) *MockDataReceiverService_PutMetricServer_Recv_Call

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 (_c *MockDataReceiverService_PutMetricServer_SendAndClose_Call) Return(_a0 error) *MockDataReceiverService_PutMetricServer_SendAndClose_Call

func (*MockDataReceiverService_PutMetricServer_SendAndClose_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricServer_SendAndClose_Call) Run(run func(_a0 *Void)) *MockDataReceiverService_PutMetricServer_SendAndClose_Call

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 (_c *MockDataReceiverService_PutMetricServer_SendHeader_Call) Return(_a0 error) *MockDataReceiverService_PutMetricServer_SendHeader_Call

func (*MockDataReceiverService_PutMetricServer_SendHeader_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricServer_SendHeader_Call) Run(run func(_a0 metadata.MD)) *MockDataReceiverService_PutMetricServer_SendHeader_Call

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 (_c *MockDataReceiverService_PutMetricServer_SendMsg_Call) Return(_a0 error) *MockDataReceiverService_PutMetricServer_SendMsg_Call

func (*MockDataReceiverService_PutMetricServer_SendMsg_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricServer_SendMsg_Call) Run(run func(m interface{})) *MockDataReceiverService_PutMetricServer_SendMsg_Call

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 (_c *MockDataReceiverService_PutMetricServer_SetHeader_Call) Return(_a0 error) *MockDataReceiverService_PutMetricServer_SetHeader_Call

func (*MockDataReceiverService_PutMetricServer_SetHeader_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricServer_SetHeader_Call) Run(run func(_a0 metadata.MD)) *MockDataReceiverService_PutMetricServer_SetHeader_Call

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 (_c *MockDataReceiverService_PutMetricServer_SetTrailer_Call) Return() *MockDataReceiverService_PutMetricServer_SetTrailer_Call

func (*MockDataReceiverService_PutMetricServer_SetTrailer_Call) Run added in v1.4.0 

func (_c *MockDataReceiverService_PutMetricServer_SetTrailer_Call) Run(run func(_a0 metadata.MD)) *MockDataReceiverService_PutMetricServer_SetTrailer_Call

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 mockConstructorTestingTNewMockUnsafeDataReceiverServiceServer) *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.

func (*MockUnsafeDataReceiverServiceServer) EXPECT added in v1.5.0 

func (_m *MockUnsafeDataReceiverServiceServer) EXPECT() *MockUnsafeDataReceiverServiceServer_Expecter

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 (_c *MockUnsafeDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call) Return() *MockUnsafeDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call

func (*MockUnsafeDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call) Run added in v1.5.0 

func (_c *MockUnsafeDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call) Run(run func()) *MockUnsafeDataReceiverServiceServer_mustEmbedUnimplementedDataReceiverServiceServer_Call

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 

func (Severity) Type() protoreflect.EnumType

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) PutEvent(DataReceiverService_PutEventServer) error

func (UnimplementedDataReceiverServiceServer) PutEvents added in v1.1.0 

func (UnimplementedDataReceiverServiceServer) PutEvents(context.Context, *Events) (*EventStatusResult, error)

func (UnimplementedDataReceiverServiceServer) PutMetric 

func (UnimplementedDataReceiverServiceServer) PutMetric(DataReceiverService_PutMetricServer) error

func (UnimplementedDataReceiverServiceServer) PutMetrics 

func (UnimplementedDataReceiverServiceServer) PutMetrics(context.Context, *Metrics) (*StatusResult, error)

func (UnimplementedDataReceiverServiceServer) PutModels 

func (UnimplementedDataReceiverServiceServer) PutModels(context.Context, *Models) (*ModelStatusResult, error)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.