data_registry

package
v1.5.2 Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2025 License: Apache-2.0 Imports: 13 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	DataRegistryService_CreateOrUpdateMetric_FullMethodName  = "/zenoss.cloud.DataRegistryService/CreateOrUpdateMetric"
	DataRegistryService_CreateOrUpdateMetrics_FullMethodName = "/zenoss.cloud.DataRegistryService/CreateOrUpdateMetrics"
	DataRegistryService_UpdateMetric_FullMethodName          = "/zenoss.cloud.DataRegistryService/UpdateMetric"
	DataRegistryService_RegisterDefinition_FullMethodName    = "/zenoss.cloud.DataRegistryService/RegisterDefinition"
	DataRegistryService_UpdateDefinition_FullMethodName      = "/zenoss.cloud.DataRegistryService/UpdateDefinition"
	DataRegistryService_GetMetric_FullMethodName             = "/zenoss.cloud.DataRegistryService/GetMetric"
)

Variables

View Source 
var (
	UpdateMode_name = map[int32]string{
		0: "MERGE",
		1: "REPLACE",
		2: "REPLACEALL",
	}
	UpdateMode_value = map[string]int32{
		"MERGE":      0,
		"REPLACE":    1,
		"REPLACEALL": 2,
	}
)

Enum value maps for UpdateMode.

View Source 
var DataRegistryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "zenoss.cloud.DataRegistryService",
	HandlerType: (*DataRegistryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateOrUpdateMetric",
			Handler:    _DataRegistryService_CreateOrUpdateMetric_Handler,
		},
		{
			MethodName: "UpdateMetric",
			Handler:    _DataRegistryService_UpdateMetric_Handler,
		},
		{
			MethodName: "RegisterDefinition",
			Handler:    _DataRegistryService_RegisterDefinition_Handler,
		},
		{
			MethodName: "UpdateDefinition",
			Handler:    _DataRegistryService_UpdateDefinition_Handler,
		},
		{
			MethodName: "GetMetric",
			Handler:    _DataRegistryService_GetMetric_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CreateOrUpdateMetrics",
			Handler:       _DataRegistryService_CreateOrUpdateMetrics_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "zenoss/cloud/data_registry.proto",
}

DataRegistryService_ServiceDesc is the grpc.ServiceDesc for DataRegistryService 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_registry_proto protoreflect.FileDescriptor

Functions

func RegisterDataRegistryServiceServer 

func RegisterDataRegistryServiceServer(s grpc.ServiceRegistrar, srv DataRegistryServiceServer)

Types

type DataRegistryServiceClient 

type DataRegistryServiceClient interface {
	CreateOrUpdateMetric(ctx context.Context, in *RegisterMetricRequest, opts ...grpc.CallOption) (*RegisterMetricResponse, error)
	CreateOrUpdateMetrics(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[RegisterMetricRequest, RegisterMetricsResponse], error)
	UpdateMetric(ctx context.Context, in *UpdateMetricRequest, opts ...grpc.CallOption) (*RegisterMetricResponse, error)
	RegisterDefinition(ctx context.Context, in *Definition, opts ...grpc.CallOption) (*DefinitionResponse, error)
	UpdateDefinition(ctx context.Context, in *DefinitionUpdate, opts ...grpc.CallOption) (*DefinitionResponse, error)
	GetMetric(ctx context.Context, in *GetMetricRequest, opts ...grpc.CallOption) (*GetMetricResponse, error)
}

DataRegistryServiceClient is the client API for DataRegistryService 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 NewDataRegistryServiceClient 

func NewDataRegistryServiceClient(cc grpc.ClientConnInterface) DataRegistryServiceClient

type DataRegistryServiceServer 

type DataRegistryServiceServer interface {
	CreateOrUpdateMetric(context.Context, *RegisterMetricRequest) (*RegisterMetricResponse, error)
	CreateOrUpdateMetrics(grpc.ClientStreamingServer[RegisterMetricRequest, RegisterMetricsResponse]) error
	UpdateMetric(context.Context, *UpdateMetricRequest) (*RegisterMetricResponse, error)
	RegisterDefinition(context.Context, *Definition) (*DefinitionResponse, error)
	UpdateDefinition(context.Context, *DefinitionUpdate) (*DefinitionResponse, error)
	GetMetric(context.Context, *GetMetricRequest) (*GetMetricResponse, error)
	// contains filtered or unexported methods
}

DataRegistryServiceServer is the server API for DataRegistryService service. All implementations must embed UnimplementedDataRegistryServiceServer for forward compatibility.

type DataRegistryService_CreateOrUpdateMetricsClient 

type DataRegistryService_CreateOrUpdateMetricsClient = grpc.ClientStreamingClient[RegisterMetricRequest, RegisterMetricsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type DataRegistryService_CreateOrUpdateMetricsServer 

type DataRegistryService_CreateOrUpdateMetricsServer = grpc.ClientStreamingServer[RegisterMetricRequest, RegisterMetricsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Definition 

type Definition struct {

	// The metric name
	Metric string `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	// Dimensions associated with this datapoint.
	Dimensions []string `protobuf:"bytes,2,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// Metadata for the datapoint. Note: using Struct as it is easier than AnyArray when using json representations
	MetadataFields *structpb.Struct `protobuf:"bytes,3,opt,name=metadataFields,proto3" json:"metadataFields,omitempty"`
	// Determines what happens to the existing definition metadata fields.  If MERGE (default), the provided metadata
	// is merged with the existing metadata.  If REPLACE, the provided metadata replaces the metadata on the existing
	// definition.
	UpdateMode UpdateMode `protobuf:"varint,4,opt,name=update_mode,json=updateMode,proto3,enum=zenoss.cloud.UpdateMode" json:"update_mode,omitempty"`
	// contains filtered or unexported fields
}

func (*Definition) Descriptor deprecated 

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

Deprecated: Use Definition.ProtoReflect.Descriptor instead.

func (*Definition) GetDimensions 

func (x *Definition) GetDimensions() []string

func (*Definition) GetMetadataFields 

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

func (*Definition) GetMetric 

func (x *Definition) GetMetric() string

func (*Definition) GetUpdateMode 

func (x *Definition) GetUpdateMode() UpdateMode

func (*Definition) ProtoMessage 

func (*Definition) ProtoMessage()

func (*Definition) ProtoReflect added in v1.4.0 

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

func (*Definition) Reset 

func (x *Definition) Reset()

func (*Definition) String 

func (x *Definition) String() string

type DefinitionResponse 

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

func (*DefinitionResponse) Descriptor deprecated 

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

Deprecated: Use DefinitionResponse.ProtoReflect.Descriptor instead.

func (*DefinitionResponse) GetDefinitionId 

func (x *DefinitionResponse) GetDefinitionId() string

func (*DefinitionResponse) ProtoMessage 

func (*DefinitionResponse) ProtoMessage()

func (*DefinitionResponse) ProtoReflect added in v1.4.0 

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

func (*DefinitionResponse) Reset 

func (x *DefinitionResponse) Reset()

func (*DefinitionResponse) String 

func (x *DefinitionResponse) String() string

type DefinitionUpdate 

type DefinitionUpdate struct {

	// The metric name
	DefinitionId string `protobuf:"bytes,1,opt,name=definition_id,json=definitionId,proto3" json:"definition_id,omitempty"`
	// Metadata for the datapoint. Note: using Struct as it is easier than AnyArray when using json representations
	MetadataFields *structpb.Struct `protobuf:"bytes,2,opt,name=metadataFields,proto3" json:"metadataFields,omitempty"`
	// Determines what happens to the existing definition metadata fields.  If MERGE (default), the provided metadata
	// is merged with the existing metadata.  If REPLACE, the provided metadata replaces the metadata on the existing
	// definition.
	UpdateMode UpdateMode `protobuf:"varint,3,opt,name=update_mode,json=updateMode,proto3,enum=zenoss.cloud.UpdateMode" json:"update_mode,omitempty"`
	// contains filtered or unexported fields
}

func (*DefinitionUpdate) Descriptor deprecated 

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

Deprecated: Use DefinitionUpdate.ProtoReflect.Descriptor instead.

func (*DefinitionUpdate) GetDefinitionId 

func (x *DefinitionUpdate) GetDefinitionId() string

func (*DefinitionUpdate) GetMetadataFields 

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

func (*DefinitionUpdate) GetUpdateMode 

func (x *DefinitionUpdate) GetUpdateMode() UpdateMode

func (*DefinitionUpdate) ProtoMessage 

func (*DefinitionUpdate) ProtoMessage()

func (*DefinitionUpdate) ProtoReflect added in v1.4.0 

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

func (*DefinitionUpdate) Reset 

func (x *DefinitionUpdate) Reset()

func (*DefinitionUpdate) String 

func (x *DefinitionUpdate) String() string

type GetMetricRequest 

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

func (*GetMetricRequest) Descriptor deprecated 

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

Deprecated: Use GetMetricRequest.ProtoReflect.Descriptor instead.

func (*GetMetricRequest) GetInstanceId 

func (x *GetMetricRequest) GetInstanceId() string

func (*GetMetricRequest) ProtoMessage 

func (*GetMetricRequest) ProtoMessage()

func (*GetMetricRequest) ProtoReflect added in v1.4.0 

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

func (*GetMetricRequest) Reset 

func (x *GetMetricRequest) Reset()

func (*GetMetricRequest) String 

func (x *GetMetricRequest) String() string

type GetMetricResponse 

type GetMetricResponse struct {
	Metric *data_receiver.Metric `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMetricResponse) Descriptor deprecated 

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

Deprecated: Use GetMetricResponse.ProtoReflect.Descriptor instead.

func (*GetMetricResponse) GetMetric 

func (x *GetMetricResponse) GetMetric() *data_receiver.Metric

func (*GetMetricResponse) ProtoMessage 

func (*GetMetricResponse) ProtoMessage()

func (*GetMetricResponse) ProtoReflect added in v1.4.0 

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

func (*GetMetricResponse) Reset 

func (x *GetMetricResponse) Reset()

func (*GetMetricResponse) String 

func (x *GetMetricResponse) String() string

type MockDataRegistryServiceClient 

type MockDataRegistryServiceClient struct {
	mock.Mock
}

MockDataRegistryServiceClient is an autogenerated mock type for the DataRegistryServiceClient type

func NewMockDataRegistryServiceClient added in v1.4.0 

func NewMockDataRegistryServiceClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDataRegistryServiceClient

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

func (*MockDataRegistryServiceClient) CreateOrUpdateMetric 

func (_m *MockDataRegistryServiceClient) CreateOrUpdateMetric(ctx context.Context, in *RegisterMetricRequest, opts ...grpc.CallOption) (*RegisterMetricResponse, error)

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

func (*MockDataRegistryServiceClient) CreateOrUpdateMetrics 

func (_m *MockDataRegistryServiceClient) CreateOrUpdateMetrics(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[RegisterMetricRequest, RegisterMetricsResponse], error)

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

func (*MockDataRegistryServiceClient) EXPECT added in v1.4.0 

func (_m *MockDataRegistryServiceClient) EXPECT() *MockDataRegistryServiceClient_Expecter

func (*MockDataRegistryServiceClient) GetMetric 

func (_m *MockDataRegistryServiceClient) GetMetric(ctx context.Context, in *GetMetricRequest, opts ...grpc.CallOption) (*GetMetricResponse, error)

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

func (*MockDataRegistryServiceClient) RegisterDefinition 

func (_m *MockDataRegistryServiceClient) RegisterDefinition(ctx context.Context, in *Definition, opts ...grpc.CallOption) (*DefinitionResponse, error)

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

func (*MockDataRegistryServiceClient) UpdateDefinition 

func (_m *MockDataRegistryServiceClient) UpdateDefinition(ctx context.Context, in *DefinitionUpdate, opts ...grpc.CallOption) (*DefinitionResponse, error)

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

func (*MockDataRegistryServiceClient) UpdateMetric 

func (_m *MockDataRegistryServiceClient) UpdateMetric(ctx context.Context, in *UpdateMetricRequest, opts ...grpc.CallOption) (*RegisterMetricResponse, error)

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

type MockDataRegistryServiceClient_CreateOrUpdateMetric_Call added in v1.4.0 

type MockDataRegistryServiceClient_CreateOrUpdateMetric_Call struct {
	*mock.Call
}

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

func (*MockDataRegistryServiceClient_CreateOrUpdateMetric_Call) Return added in v1.4.0 

func (_c *MockDataRegistryServiceClient_CreateOrUpdateMetric_Call) Return(_a0 *RegisterMetricResponse, _a1 error) *MockDataRegistryServiceClient_CreateOrUpdateMetric_Call

func (*MockDataRegistryServiceClient_CreateOrUpdateMetric_Call) Run added in v1.4.0 

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

func (*MockDataRegistryServiceClient_CreateOrUpdateMetric_Call) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryServiceClient_CreateOrUpdateMetric_Call) RunAndReturn(run func(context.Context, *RegisterMetricRequest, ...grpc.CallOption) (*RegisterMetricResponse, error)) *MockDataRegistryServiceClient_CreateOrUpdateMetric_Call

type MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call added in v1.4.0 

type MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call struct {
	*mock.Call
}

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

func (*MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call) Return added in v1.4.0 

func (_c *MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call) Return(_a0 grpc.ClientStreamingClient[RegisterMetricRequest, RegisterMetricsResponse], _a1 error) *MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call

func (*MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call) Run added in v1.4.0 

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

func (*MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call) RunAndReturn(run func(context.Context, ...grpc.CallOption) (grpc.ClientStreamingClient[RegisterMetricRequest, RegisterMetricsResponse], error)) *MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call

type MockDataRegistryServiceClient_Expecter added in v1.4.0 

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

func (*MockDataRegistryServiceClient_Expecter) CreateOrUpdateMetric added in v1.4.0 

func (_e *MockDataRegistryServiceClient_Expecter) CreateOrUpdateMetric(ctx interface{}, in interface{}, opts ...interface{}) *MockDataRegistryServiceClient_CreateOrUpdateMetric_Call

CreateOrUpdateMetric is a helper method to define mock.On call

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

func (*MockDataRegistryServiceClient_Expecter) CreateOrUpdateMetrics added in v1.4.0 

func (_e *MockDataRegistryServiceClient_Expecter) CreateOrUpdateMetrics(ctx interface{}, opts ...interface{}) *MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call

CreateOrUpdateMetrics is a helper method to define mock.On call

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

func (*MockDataRegistryServiceClient_Expecter) GetMetric added in v1.4.0 

func (_e *MockDataRegistryServiceClient_Expecter) GetMetric(ctx interface{}, in interface{}, opts ...interface{}) *MockDataRegistryServiceClient_GetMetric_Call

GetMetric is a helper method to define mock.On call

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

func (*MockDataRegistryServiceClient_Expecter) RegisterDefinition added in v1.4.0 

func (_e *MockDataRegistryServiceClient_Expecter) RegisterDefinition(ctx interface{}, in interface{}, opts ...interface{}) *MockDataRegistryServiceClient_RegisterDefinition_Call

RegisterDefinition is a helper method to define mock.On call

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

func (*MockDataRegistryServiceClient_Expecter) UpdateDefinition added in v1.4.0 

func (_e *MockDataRegistryServiceClient_Expecter) UpdateDefinition(ctx interface{}, in interface{}, opts ...interface{}) *MockDataRegistryServiceClient_UpdateDefinition_Call

UpdateDefinition is a helper method to define mock.On call

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

func (*MockDataRegistryServiceClient_Expecter) UpdateMetric added in v1.4.0 

func (_e *MockDataRegistryServiceClient_Expecter) UpdateMetric(ctx interface{}, in interface{}, opts ...interface{}) *MockDataRegistryServiceClient_UpdateMetric_Call

UpdateMetric is a helper method to define mock.On call

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

type MockDataRegistryServiceClient_GetMetric_Call added in v1.4.0 

type MockDataRegistryServiceClient_GetMetric_Call struct {
	*mock.Call
}

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

func (*MockDataRegistryServiceClient_GetMetric_Call) Return added in v1.4.0 

func (_c *MockDataRegistryServiceClient_GetMetric_Call) Return(_a0 *GetMetricResponse, _a1 error) *MockDataRegistryServiceClient_GetMetric_Call

func (*MockDataRegistryServiceClient_GetMetric_Call) Run added in v1.4.0 

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

func (*MockDataRegistryServiceClient_GetMetric_Call) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryServiceClient_GetMetric_Call) RunAndReturn(run func(context.Context, *GetMetricRequest, ...grpc.CallOption) (*GetMetricResponse, error)) *MockDataRegistryServiceClient_GetMetric_Call

type MockDataRegistryServiceClient_RegisterDefinition_Call added in v1.4.0 

type MockDataRegistryServiceClient_RegisterDefinition_Call struct {
	*mock.Call
}

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

func (*MockDataRegistryServiceClient_RegisterDefinition_Call) Return added in v1.4.0 

func (_c *MockDataRegistryServiceClient_RegisterDefinition_Call) Return(_a0 *DefinitionResponse, _a1 error) *MockDataRegistryServiceClient_RegisterDefinition_Call

func (*MockDataRegistryServiceClient_RegisterDefinition_Call) Run added in v1.4.0 

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

func (*MockDataRegistryServiceClient_RegisterDefinition_Call) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryServiceClient_RegisterDefinition_Call) RunAndReturn(run func(context.Context, *Definition, ...grpc.CallOption) (*DefinitionResponse, error)) *MockDataRegistryServiceClient_RegisterDefinition_Call

type MockDataRegistryServiceClient_UpdateDefinition_Call added in v1.4.0 

type MockDataRegistryServiceClient_UpdateDefinition_Call struct {
	*mock.Call
}

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

func (*MockDataRegistryServiceClient_UpdateDefinition_Call) Return added in v1.4.0 

func (_c *MockDataRegistryServiceClient_UpdateDefinition_Call) Return(_a0 *DefinitionResponse, _a1 error) *MockDataRegistryServiceClient_UpdateDefinition_Call

func (*MockDataRegistryServiceClient_UpdateDefinition_Call) Run added in v1.4.0 

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

func (*MockDataRegistryServiceClient_UpdateDefinition_Call) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryServiceClient_UpdateDefinition_Call) RunAndReturn(run func(context.Context, *DefinitionUpdate, ...grpc.CallOption) (*DefinitionResponse, error)) *MockDataRegistryServiceClient_UpdateDefinition_Call

type MockDataRegistryServiceClient_UpdateMetric_Call added in v1.4.0 

type MockDataRegistryServiceClient_UpdateMetric_Call struct {
	*mock.Call
}

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

func (*MockDataRegistryServiceClient_UpdateMetric_Call) Return added in v1.4.0 

func (_c *MockDataRegistryServiceClient_UpdateMetric_Call) Return(_a0 *RegisterMetricResponse, _a1 error) *MockDataRegistryServiceClient_UpdateMetric_Call

func (*MockDataRegistryServiceClient_UpdateMetric_Call) Run added in v1.4.0 

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

func (*MockDataRegistryServiceClient_UpdateMetric_Call) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryServiceClient_UpdateMetric_Call) RunAndReturn(run func(context.Context, *UpdateMetricRequest, ...grpc.CallOption) (*RegisterMetricResponse, error)) *MockDataRegistryServiceClient_UpdateMetric_Call

type MockDataRegistryServiceServer 

type MockDataRegistryServiceServer struct {
	mock.Mock
}

MockDataRegistryServiceServer is an autogenerated mock type for the DataRegistryServiceServer type

func NewMockDataRegistryServiceServer added in v1.4.0 

func NewMockDataRegistryServiceServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDataRegistryServiceServer

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

func (*MockDataRegistryServiceServer) CreateOrUpdateMetric 

func (_m *MockDataRegistryServiceServer) CreateOrUpdateMetric(_a0 context.Context, _a1 *RegisterMetricRequest) (*RegisterMetricResponse, error)

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

func (*MockDataRegistryServiceServer) CreateOrUpdateMetrics 

func (_m *MockDataRegistryServiceServer) CreateOrUpdateMetrics(_a0 grpc.ClientStreamingServer[RegisterMetricRequest, RegisterMetricsResponse]) error

CreateOrUpdateMetrics provides a mock function with given fields: _a0

func (*MockDataRegistryServiceServer) EXPECT added in v1.4.0 

func (_m *MockDataRegistryServiceServer) EXPECT() *MockDataRegistryServiceServer_Expecter

func (*MockDataRegistryServiceServer) GetMetric 

func (_m *MockDataRegistryServiceServer) GetMetric(_a0 context.Context, _a1 *GetMetricRequest) (*GetMetricResponse, error)

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

func (*MockDataRegistryServiceServer) RegisterDefinition 

func (_m *MockDataRegistryServiceServer) RegisterDefinition(_a0 context.Context, _a1 *Definition) (*DefinitionResponse, error)

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

func (*MockDataRegistryServiceServer) UpdateDefinition 

func (_m *MockDataRegistryServiceServer) UpdateDefinition(_a0 context.Context, _a1 *DefinitionUpdate) (*DefinitionResponse, error)

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

func (*MockDataRegistryServiceServer) UpdateMetric 

func (_m *MockDataRegistryServiceServer) UpdateMetric(_a0 context.Context, _a1 *UpdateMetricRequest) (*RegisterMetricResponse, error)

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

type MockDataRegistryServiceServer_CreateOrUpdateMetric_Call added in v1.4.0 

type MockDataRegistryServiceServer_CreateOrUpdateMetric_Call struct {
	*mock.Call
}

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

func (*MockDataRegistryServiceServer_CreateOrUpdateMetric_Call) Return added in v1.4.0 

func (_c *MockDataRegistryServiceServer_CreateOrUpdateMetric_Call) Return(_a0 *RegisterMetricResponse, _a1 error) *MockDataRegistryServiceServer_CreateOrUpdateMetric_Call

func (*MockDataRegistryServiceServer_CreateOrUpdateMetric_Call) Run added in v1.4.0 

func (_c *MockDataRegistryServiceServer_CreateOrUpdateMetric_Call) Run(run func(_a0 context.Context, _a1 *RegisterMetricRequest)) *MockDataRegistryServiceServer_CreateOrUpdateMetric_Call

func (*MockDataRegistryServiceServer_CreateOrUpdateMetric_Call) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryServiceServer_CreateOrUpdateMetric_Call) RunAndReturn(run func(context.Context, *RegisterMetricRequest) (*RegisterMetricResponse, error)) *MockDataRegistryServiceServer_CreateOrUpdateMetric_Call

type MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call added in v1.4.0 

type MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call struct {
	*mock.Call
}

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

func (*MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call) Return added in v1.4.0 

func (_c *MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call) Return(_a0 error) *MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call

func (*MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call) Run added in v1.4.0 

func (_c *MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call) Run(run func(_a0 grpc.ClientStreamingServer[RegisterMetricRequest, RegisterMetricsResponse])) *MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call

func (*MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call) RunAndReturn(run func(grpc.ClientStreamingServer[RegisterMetricRequest, RegisterMetricsResponse]) error) *MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call

type MockDataRegistryServiceServer_Expecter added in v1.4.0 

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

func (*MockDataRegistryServiceServer_Expecter) CreateOrUpdateMetric added in v1.4.0 

func (_e *MockDataRegistryServiceServer_Expecter) CreateOrUpdateMetric(_a0 interface{}, _a1 interface{}) *MockDataRegistryServiceServer_CreateOrUpdateMetric_Call

CreateOrUpdateMetric is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *RegisterMetricRequest

func (*MockDataRegistryServiceServer_Expecter) CreateOrUpdateMetrics added in v1.4.0 

func (_e *MockDataRegistryServiceServer_Expecter) CreateOrUpdateMetrics(_a0 interface{}) *MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call

CreateOrUpdateMetrics is a helper method to define mock.On call

  • _a0 grpc.ClientStreamingServer[RegisterMetricRequest,RegisterMetricsResponse]

func (*MockDataRegistryServiceServer_Expecter) GetMetric added in v1.4.0 

func (_e *MockDataRegistryServiceServer_Expecter) GetMetric(_a0 interface{}, _a1 interface{}) *MockDataRegistryServiceServer_GetMetric_Call

GetMetric is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *GetMetricRequest

func (*MockDataRegistryServiceServer_Expecter) RegisterDefinition added in v1.4.0 

func (_e *MockDataRegistryServiceServer_Expecter) RegisterDefinition(_a0 interface{}, _a1 interface{}) *MockDataRegistryServiceServer_RegisterDefinition_Call

RegisterDefinition is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *Definition

func (*MockDataRegistryServiceServer_Expecter) UpdateDefinition added in v1.4.0 

func (_e *MockDataRegistryServiceServer_Expecter) UpdateDefinition(_a0 interface{}, _a1 interface{}) *MockDataRegistryServiceServer_UpdateDefinition_Call

UpdateDefinition is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *DefinitionUpdate

func (*MockDataRegistryServiceServer_Expecter) UpdateMetric added in v1.4.0 

func (_e *MockDataRegistryServiceServer_Expecter) UpdateMetric(_a0 interface{}, _a1 interface{}) *MockDataRegistryServiceServer_UpdateMetric_Call

UpdateMetric is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *UpdateMetricRequest

type MockDataRegistryServiceServer_GetMetric_Call added in v1.4.0 

type MockDataRegistryServiceServer_GetMetric_Call struct {
	*mock.Call
}

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

func (*MockDataRegistryServiceServer_GetMetric_Call) Return added in v1.4.0 

func (_c *MockDataRegistryServiceServer_GetMetric_Call) Return(_a0 *GetMetricResponse, _a1 error) *MockDataRegistryServiceServer_GetMetric_Call

func (*MockDataRegistryServiceServer_GetMetric_Call) Run added in v1.4.0 

func (_c *MockDataRegistryServiceServer_GetMetric_Call) Run(run func(_a0 context.Context, _a1 *GetMetricRequest)) *MockDataRegistryServiceServer_GetMetric_Call

func (*MockDataRegistryServiceServer_GetMetric_Call) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryServiceServer_GetMetric_Call) RunAndReturn(run func(context.Context, *GetMetricRequest) (*GetMetricResponse, error)) *MockDataRegistryServiceServer_GetMetric_Call

type MockDataRegistryServiceServer_RegisterDefinition_Call added in v1.4.0 

type MockDataRegistryServiceServer_RegisterDefinition_Call struct {
	*mock.Call
}

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

func (*MockDataRegistryServiceServer_RegisterDefinition_Call) Return added in v1.4.0 

func (_c *MockDataRegistryServiceServer_RegisterDefinition_Call) Return(_a0 *DefinitionResponse, _a1 error) *MockDataRegistryServiceServer_RegisterDefinition_Call

func (*MockDataRegistryServiceServer_RegisterDefinition_Call) Run added in v1.4.0 

func (_c *MockDataRegistryServiceServer_RegisterDefinition_Call) Run(run func(_a0 context.Context, _a1 *Definition)) *MockDataRegistryServiceServer_RegisterDefinition_Call

func (*MockDataRegistryServiceServer_RegisterDefinition_Call) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryServiceServer_RegisterDefinition_Call) RunAndReturn(run func(context.Context, *Definition) (*DefinitionResponse, error)) *MockDataRegistryServiceServer_RegisterDefinition_Call

type MockDataRegistryServiceServer_UpdateDefinition_Call added in v1.4.0 

type MockDataRegistryServiceServer_UpdateDefinition_Call struct {
	*mock.Call
}

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

func (*MockDataRegistryServiceServer_UpdateDefinition_Call) Return added in v1.4.0 

func (_c *MockDataRegistryServiceServer_UpdateDefinition_Call) Return(_a0 *DefinitionResponse, _a1 error) *MockDataRegistryServiceServer_UpdateDefinition_Call

func (*MockDataRegistryServiceServer_UpdateDefinition_Call) Run added in v1.4.0 

func (_c *MockDataRegistryServiceServer_UpdateDefinition_Call) Run(run func(_a0 context.Context, _a1 *DefinitionUpdate)) *MockDataRegistryServiceServer_UpdateDefinition_Call

func (*MockDataRegistryServiceServer_UpdateDefinition_Call) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryServiceServer_UpdateDefinition_Call) RunAndReturn(run func(context.Context, *DefinitionUpdate) (*DefinitionResponse, error)) *MockDataRegistryServiceServer_UpdateDefinition_Call

type MockDataRegistryServiceServer_UpdateMetric_Call added in v1.4.0 

type MockDataRegistryServiceServer_UpdateMetric_Call struct {
	*mock.Call
}

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

func (*MockDataRegistryServiceServer_UpdateMetric_Call) Return added in v1.4.0 

func (_c *MockDataRegistryServiceServer_UpdateMetric_Call) Return(_a0 *RegisterMetricResponse, _a1 error) *MockDataRegistryServiceServer_UpdateMetric_Call

func (*MockDataRegistryServiceServer_UpdateMetric_Call) Run added in v1.4.0 

func (_c *MockDataRegistryServiceServer_UpdateMetric_Call) Run(run func(_a0 context.Context, _a1 *UpdateMetricRequest)) *MockDataRegistryServiceServer_UpdateMetric_Call

func (*MockDataRegistryServiceServer_UpdateMetric_Call) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryServiceServer_UpdateMetric_Call) RunAndReturn(run func(context.Context, *UpdateMetricRequest) (*RegisterMetricResponse, error)) *MockDataRegistryServiceServer_UpdateMetric_Call

type MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call added in v1.5.0 

type MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call struct {
	*mock.Call
}

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

func (*MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Return added in v1.5.0 

func (_c *MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Return() *MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call

func (*MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Run added in v1.5.0 

func (_c *MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Run(run func()) *MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call

func (*MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) RunAndReturn(run func()) *MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call

type MockDataRegistryService_CreateOrUpdateMetricsClient 

type MockDataRegistryService_CreateOrUpdateMetricsClient[Req interface{}, Res interface{}] struct {
	mock.Mock
}

MockDataRegistryService_CreateOrUpdateMetricsClient is an autogenerated mock type for the DataRegistryService_CreateOrUpdateMetricsClient type

func NewMockDataRegistryService_CreateOrUpdateMetricsClient added in v1.4.0 

func NewMockDataRegistryService_CreateOrUpdateMetricsClient[Req interface{}, Res interface{}](t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]

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

func (*MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) CloseAndRecv 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) CloseAndRecv() (*RegisterMetricsResponse, error)

CloseAndRecv provides a mock function with no fields

func (*MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) CloseSend 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) CloseSend() error

CloseSend provides a mock function with no fields

func (*MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) Context 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) Context() context.Context

Context provides a mock function with no fields

func (*MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) EXPECT added in v1.4.0 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) EXPECT() *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) Header 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) Header() (metadata.MD, error)

Header provides a mock function with no fields

func (*MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) RecvMsg 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) Send 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) Send(_a0 *RegisterMetricRequest) error

Send provides a mock function with given fields: _a0

func (*MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) SendMsg 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) Trailer 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient[Req, Res]) Trailer() metadata.MD

Trailer provides a mock function with no fields

type MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call[Req, Res]) Return(_a0 *RegisterMetricsResponse, _a1 error) *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call[Req, Res]) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call[Req, Res]) RunAndReturn(run func() (*RegisterMetricsResponse, error)) *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call[Req, Res]) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call[Req, Res]) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call[Req, Res]) RunAndReturn(run func() error) *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call[Req, Res]) Return(_a0 context.Context) *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call[Req, Res]) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call[Req, Res]) RunAndReturn(run func() context.Context) *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req interface{}, Res interface{}] struct {
	// contains filtered or unexported fields
}

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) CloseAndRecv added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) CloseAndRecv() *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call[Req, Res]

CloseAndRecv is a helper method to define mock.On call

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) CloseSend added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) CloseSend() *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call[Req, Res]

CloseSend is a helper method to define mock.On call

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) Context added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) Context() *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call[Req, Res]

Context is a helper method to define mock.On call

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) Header added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) Header() *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call[Req, Res]

Header is a helper method to define mock.On call

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) RecvMsg added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) RecvMsg(m interface{}) *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call[Req, Res]

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) Send added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) Send(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call[Req, Res]

Send is a helper method to define mock.On call

  • _a0 *RegisterMetricRequest

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) SendMsg added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) SendMsg(m interface{}) *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call[Req, Res]

SendMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) Trailer added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter[Req, Res]) Trailer() *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call[Req, Res]

Trailer is a helper method to define mock.On call

type MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call[Req, Res]) Return(_a0 metadata.MD, _a1 error) *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call[Req, Res]) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call[Req, Res]) RunAndReturn(run func() (metadata.MD, error)) *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call[Req, Res]) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call[Req, Res]) Run(run func(m interface{})) *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call[Req, Res]) RunAndReturn(run func(interface{}) error) *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call[Req, Res]) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call[Req, Res]) Run(run func(m interface{})) *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call[Req, Res]) RunAndReturn(run func(interface{}) error) *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call[Req, Res]) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call[Req, Res]) Run(run func(_a0 *RegisterMetricRequest)) *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call[Req, Res]) RunAndReturn(run func(*RegisterMetricRequest) error) *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call[Req, Res]) Return(_a0 metadata.MD) *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call[Req, Res]) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call[Req, Res]) RunAndReturn(run func() metadata.MD) *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsServer 

type MockDataRegistryService_CreateOrUpdateMetricsServer[Req interface{}, Res interface{}] struct {
	mock.Mock
}

MockDataRegistryService_CreateOrUpdateMetricsServer is an autogenerated mock type for the DataRegistryService_CreateOrUpdateMetricsServer type

func NewMockDataRegistryService_CreateOrUpdateMetricsServer added in v1.4.0 

func NewMockDataRegistryService_CreateOrUpdateMetricsServer[Req interface{}, Res interface{}](t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]

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

func (*MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) Context 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) Context() context.Context

Context provides a mock function with no fields

func (*MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) EXPECT added in v1.4.0 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) EXPECT() *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) Recv 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) Recv() (*RegisterMetricRequest, error)

Recv provides a mock function with no fields

func (*MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) RecvMsg 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) SendAndClose 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) SendAndClose(_a0 *RegisterMetricsResponse) error

SendAndClose provides a mock function with given fields: _a0

func (*MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) SendHeader 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) SendHeader(_a0 metadata.MD) error

SendHeader provides a mock function with given fields: _a0

func (*MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) SendMsg 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) SetHeader 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) SetHeader(_a0 metadata.MD) error

SetHeader provides a mock function with given fields: _a0

func (*MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) SetTrailer 

func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer[Req, Res]) SetTrailer(_a0 metadata.MD)

SetTrailer provides a mock function with given fields: _a0

type MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call[Req, Res]) Return(_a0 context.Context) *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call[Req, Res]) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call[Req, Res]) RunAndReturn(run func() context.Context) *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req interface{}, Res interface{}] struct {
	// contains filtered or unexported fields
}

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) Context added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) Context() *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call[Req, Res]

Context is a helper method to define mock.On call

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) Recv added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) Recv() *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call[Req, Res]

Recv is a helper method to define mock.On call

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) RecvMsg added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) RecvMsg(m interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call[Req, Res]

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) SendAndClose added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) SendAndClose(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call[Req, Res]

SendAndClose is a helper method to define mock.On call

  • _a0 *RegisterMetricsResponse

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) SendHeader added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) SendHeader(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call[Req, Res]

SendHeader is a helper method to define mock.On call

  • _a0 metadata.MD

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) SendMsg added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) SendMsg(m interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call[Req, Res]

SendMsg is a helper method to define mock.On call

  • m interface{}

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) SetHeader added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) SetHeader(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call[Req, Res]

SetHeader is a helper method to define mock.On call

  • _a0 metadata.MD

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) SetTrailer added in v1.4.0 

func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter[Req, Res]) SetTrailer(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call[Req, Res]

SetTrailer is a helper method to define mock.On call

  • _a0 metadata.MD

type MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call[Req, Res]) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call[Req, Res]) Run(run func(m interface{})) *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call[Req, Res]) RunAndReturn(run func(interface{}) error) *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call[Req, Res]) Return(_a0 *RegisterMetricRequest, _a1 error) *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call[Req, Res]) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call[Req, Res]) RunAndReturn(run func() (*RegisterMetricRequest, error)) *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call[Req, Res]) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call[Req, Res]) Run(run func(_a0 *RegisterMetricsResponse)) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call[Req, Res]) RunAndReturn(run func(*RegisterMetricsResponse) error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call[Req, Res]) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call[Req, Res]) Run(run func(_a0 metadata.MD)) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call[Req, Res]) RunAndReturn(run func(metadata.MD) error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call[Req, Res]) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call[Req, Res]) Run(run func(m interface{})) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call[Req, Res]) RunAndReturn(run func(interface{}) error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call[Req, Res]) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call[Req, Res]) Run(run func(_a0 metadata.MD)) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call[Req, Res]) RunAndReturn(run func(metadata.MD) error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call[Req, Res]

type MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call added in v1.4.0 

type MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call[Req interface{}, Res interface{}] struct {
	*mock.Call
}

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

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call[Req, Res]) Return added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call[Req, Res]) Return() *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call[Req, Res]) Run added in v1.4.0 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call[Req, Res]) Run(run func(_a0 metadata.MD)) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call[Req, Res]

func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call[Req, Res]) RunAndReturn added in v1.5.1 

func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call[Req, Res]) RunAndReturn(run func(metadata.MD)) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call[Req, Res]

type MockUnsafeDataRegistryServiceServer added in v1.5.0 

type MockUnsafeDataRegistryServiceServer struct {
	mock.Mock
}

MockUnsafeDataRegistryServiceServer is an autogenerated mock type for the UnsafeDataRegistryServiceServer type

func NewMockUnsafeDataRegistryServiceServer added in v1.5.0 

func NewMockUnsafeDataRegistryServiceServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockUnsafeDataRegistryServiceServer

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

func (*MockUnsafeDataRegistryServiceServer) EXPECT added in v1.5.0 

func (_m *MockUnsafeDataRegistryServiceServer) EXPECT() *MockUnsafeDataRegistryServiceServer_Expecter

type MockUnsafeDataRegistryServiceServer_Expecter added in v1.5.0 

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

type MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call added in v1.5.0 

type MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call struct {
	*mock.Call
}

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

func (*MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Return added in v1.5.0 

func (_c *MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Return() *MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call

func (*MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Run added in v1.5.0 

func (_c *MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Run(run func()) *MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call

func (*MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) RunAndReturn added in v1.5.1 

func (_c *MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) RunAndReturn(run func()) *MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call

type RegisterMetricRequest 

type RegisterMetricRequest struct {
	Metric     *data_receiver.MetricWrapper `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	UpdateMode UpdateMode                   `protobuf:"varint,2,opt,name=update_mode,json=updateMode,proto3,enum=zenoss.cloud.UpdateMode" json:"update_mode,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterMetricRequest) Descriptor deprecated 

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

Deprecated: Use RegisterMetricRequest.ProtoReflect.Descriptor instead.

func (*RegisterMetricRequest) GetMetric 

func (x *RegisterMetricRequest) GetMetric() *data_receiver.MetricWrapper

func (*RegisterMetricRequest) GetUpdateMode 

func (x *RegisterMetricRequest) GetUpdateMode() UpdateMode

func (*RegisterMetricRequest) ProtoMessage 

func (*RegisterMetricRequest) ProtoMessage()

func (*RegisterMetricRequest) ProtoReflect added in v1.4.0 

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

func (*RegisterMetricRequest) Reset 

func (x *RegisterMetricRequest) Reset()

func (*RegisterMetricRequest) String 

func (x *RegisterMetricRequest) String() string

type RegisterMetricResponse 

type RegisterMetricResponse struct {
	InstanceId   string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	DefinitionId string `protobuf:"bytes,2,opt,name=definitionId,proto3" json:"definitionId,omitempty"`
	Name         string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterMetricResponse) Descriptor deprecated 

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

Deprecated: Use RegisterMetricResponse.ProtoReflect.Descriptor instead.

func (*RegisterMetricResponse) GetDefinitionId 

func (x *RegisterMetricResponse) GetDefinitionId() string

func (*RegisterMetricResponse) GetInstanceId 

func (x *RegisterMetricResponse) GetInstanceId() string

func (*RegisterMetricResponse) GetName 

func (x *RegisterMetricResponse) GetName() string

func (*RegisterMetricResponse) ProtoMessage 

func (*RegisterMetricResponse) ProtoMessage()

func (*RegisterMetricResponse) ProtoReflect added in v1.4.0 

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

func (*RegisterMetricResponse) Reset 

func (x *RegisterMetricResponse) Reset()

func (*RegisterMetricResponse) String 

func (x *RegisterMetricResponse) String() string

type RegisterMetricVerboseResponse 

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

func (*RegisterMetricVerboseResponse) Descriptor deprecated 

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

Deprecated: Use RegisterMetricVerboseResponse.ProtoReflect.Descriptor instead.

func (*RegisterMetricVerboseResponse) GetError 

func (x *RegisterMetricVerboseResponse) GetError() string

func (*RegisterMetricVerboseResponse) GetResponse 

func (x *RegisterMetricVerboseResponse) GetResponse() *RegisterMetricResponse

func (*RegisterMetricVerboseResponse) ProtoMessage 

func (*RegisterMetricVerboseResponse) ProtoMessage()

func (*RegisterMetricVerboseResponse) ProtoReflect added in v1.4.0 

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

func (*RegisterMetricVerboseResponse) Reset 

func (x *RegisterMetricVerboseResponse) Reset()

func (*RegisterMetricVerboseResponse) String 

func (x *RegisterMetricVerboseResponse) String() string

type RegisterMetricsResponse 

type RegisterMetricsResponse struct {
	Responses []*RegisterMetricVerboseResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterMetricsResponse) Descriptor deprecated 

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

Deprecated: Use RegisterMetricsResponse.ProtoReflect.Descriptor instead.

func (*RegisterMetricsResponse) GetResponses 

func (x *RegisterMetricsResponse) GetResponses() []*RegisterMetricVerboseResponse

func (*RegisterMetricsResponse) ProtoMessage 

func (*RegisterMetricsResponse) ProtoMessage()

func (*RegisterMetricsResponse) ProtoReflect added in v1.4.0 

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

func (*RegisterMetricsResponse) Reset 

func (x *RegisterMetricsResponse) Reset()

func (*RegisterMetricsResponse) String 

func (x *RegisterMetricsResponse) String() string

type UnimplementedDataRegistryServiceServer 

type UnimplementedDataRegistryServiceServer struct{}

UnimplementedDataRegistryServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDataRegistryServiceServer) CreateOrUpdateMetric 

func (UnimplementedDataRegistryServiceServer) CreateOrUpdateMetric(context.Context, *RegisterMetricRequest) (*RegisterMetricResponse, error)

func (UnimplementedDataRegistryServiceServer) CreateOrUpdateMetrics 

func (UnimplementedDataRegistryServiceServer) CreateOrUpdateMetrics(grpc.ClientStreamingServer[RegisterMetricRequest, RegisterMetricsResponse]) error

func (UnimplementedDataRegistryServiceServer) GetMetric 

func (UnimplementedDataRegistryServiceServer) GetMetric(context.Context, *GetMetricRequest) (*GetMetricResponse, error)

func (UnimplementedDataRegistryServiceServer) RegisterDefinition 

func (UnimplementedDataRegistryServiceServer) RegisterDefinition(context.Context, *Definition) (*DefinitionResponse, error)

func (UnimplementedDataRegistryServiceServer) UpdateDefinition 

func (UnimplementedDataRegistryServiceServer) UpdateDefinition(context.Context, *DefinitionUpdate) (*DefinitionResponse, error)

func (UnimplementedDataRegistryServiceServer) UpdateMetric 

func (UnimplementedDataRegistryServiceServer) UpdateMetric(context.Context, *UpdateMetricRequest) (*RegisterMetricResponse, error)

type UnsafeDataRegistryServiceServer added in v1.5.0 

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

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

type UpdateMetricRequest 

type UpdateMetricRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	// Metadata for the datapoint
	MetadataFields *structpb.Struct `protobuf:"bytes,2,opt,name=metadataFields,proto3" json:"metadataFields,omitempty"`
	UpdateMode     UpdateMode       `protobuf:"varint,3,opt,name=update_mode,json=updateMode,proto3,enum=zenoss.cloud.UpdateMode" json:"update_mode,omitempty"`
	Timestamp      int64            `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateMetricRequest) Descriptor deprecated 

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

Deprecated: Use UpdateMetricRequest.ProtoReflect.Descriptor instead.

func (*UpdateMetricRequest) GetInstanceId 

func (x *UpdateMetricRequest) GetInstanceId() string

func (*UpdateMetricRequest) GetMetadataFields 

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

func (*UpdateMetricRequest) GetTimestamp 

func (x *UpdateMetricRequest) GetTimestamp() int64

func (*UpdateMetricRequest) GetUpdateMode 

func (x *UpdateMetricRequest) GetUpdateMode() UpdateMode

func (*UpdateMetricRequest) ProtoMessage 

func (*UpdateMetricRequest) ProtoMessage()

func (*UpdateMetricRequest) ProtoReflect added in v1.4.0 

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

func (*UpdateMetricRequest) Reset 

func (x *UpdateMetricRequest) Reset()

func (*UpdateMetricRequest) String 

func (x *UpdateMetricRequest) String() string

type UpdateMode 

type UpdateMode int32
const (
	UpdateMode_MERGE      UpdateMode = 0
	UpdateMode_REPLACE    UpdateMode = 1
	UpdateMode_REPLACEALL UpdateMode = 2
)

func (UpdateMode) Descriptor added in v1.4.0 

func (UpdateMode) Descriptor() protoreflect.EnumDescriptor

func (UpdateMode) Enum added in v1.4.0 

func (x UpdateMode) Enum() *UpdateMode

func (UpdateMode) EnumDescriptor deprecated 

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

Deprecated: Use UpdateMode.Descriptor instead.

func (UpdateMode) Number added in v1.4.0 

func (x UpdateMode) Number() protoreflect.EnumNumber

func (UpdateMode) String 

func (x UpdateMode) String() string

func (UpdateMode) Type added in v1.4.0 

func (UpdateMode) Type() protoreflect.EnumType

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.