Documentation ¶
Index ¶
- Variables
- func RegisterDataRegistryServiceServer(s *grpc.Server, srv DataRegistryServiceServer)
- type DataRegistryServiceClient
- type DataRegistryServiceServer
- type DataRegistryService_CreateOrUpdateMetricsClient
- type DataRegistryService_CreateOrUpdateMetricsServer
- type Definition
- func (*Definition) Descriptor() ([]byte, []int)deprecated
- func (x *Definition) GetDimensions() []string
- func (x *Definition) GetMetadataFields() *structpb.Struct
- func (x *Definition) GetMetric() string
- func (x *Definition) GetUpdateMode() UpdateMode
- func (*Definition) ProtoMessage()
- func (x *Definition) ProtoReflect() protoreflect.Message
- func (x *Definition) Reset()
- func (x *Definition) String() string
- type DefinitionResponse
- func (*DefinitionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DefinitionResponse) GetDefinitionId() string
- func (*DefinitionResponse) ProtoMessage()
- func (x *DefinitionResponse) ProtoReflect() protoreflect.Message
- func (x *DefinitionResponse) Reset()
- func (x *DefinitionResponse) String() string
- type DefinitionUpdate
- func (*DefinitionUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *DefinitionUpdate) GetDefinitionId() string
- func (x *DefinitionUpdate) GetMetadataFields() *structpb.Struct
- func (x *DefinitionUpdate) GetUpdateMode() UpdateMode
- func (*DefinitionUpdate) ProtoMessage()
- func (x *DefinitionUpdate) ProtoReflect() protoreflect.Message
- func (x *DefinitionUpdate) Reset()
- func (x *DefinitionUpdate) String() string
- type GetMetricRequest
- type GetMetricResponse
- func (*GetMetricResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetMetricResponse) GetMetric() *data_receiver.Metric
- func (*GetMetricResponse) ProtoMessage()
- func (x *GetMetricResponse) ProtoReflect() protoreflect.Message
- func (x *GetMetricResponse) Reset()
- func (x *GetMetricResponse) String() string
- type MockDataRegistryServiceClient
- func (_m *MockDataRegistryServiceClient) CreateOrUpdateMetric(ctx context.Context, in *RegisterMetricRequest, opts ...grpc.CallOption) (*RegisterMetricResponse, error)
- func (_m *MockDataRegistryServiceClient) CreateOrUpdateMetrics(ctx context.Context, opts ...grpc.CallOption) (DataRegistryService_CreateOrUpdateMetricsClient, error)
- func (_m *MockDataRegistryServiceClient) EXPECT() *MockDataRegistryServiceClient_Expecter
- func (_m *MockDataRegistryServiceClient) GetMetric(ctx context.Context, in *GetMetricRequest, opts ...grpc.CallOption) (*GetMetricResponse, error)
- func (_m *MockDataRegistryServiceClient) RegisterDefinition(ctx context.Context, in *Definition, opts ...grpc.CallOption) (*DefinitionResponse, error)
- func (_m *MockDataRegistryServiceClient) UpdateDefinition(ctx context.Context, in *DefinitionUpdate, opts ...grpc.CallOption) (*DefinitionResponse, error)
- func (_m *MockDataRegistryServiceClient) UpdateMetric(ctx context.Context, in *UpdateMetricRequest, opts ...grpc.CallOption) (*RegisterMetricResponse, error)
- type MockDataRegistryServiceClient_CreateOrUpdateMetric_Call
- func (_c *MockDataRegistryServiceClient_CreateOrUpdateMetric_Call) Return(_a0 *RegisterMetricResponse, _a1 error) *MockDataRegistryServiceClient_CreateOrUpdateMetric_Call
- func (_c *MockDataRegistryServiceClient_CreateOrUpdateMetric_Call) Run(...) *MockDataRegistryServiceClient_CreateOrUpdateMetric_Call
- type MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call
- func (_c *MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call) Return(_a0 DataRegistryService_CreateOrUpdateMetricsClient, _a1 error) *MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call
- func (_c *MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call) Run(run func(ctx context.Context, opts ...grpc.CallOption)) *MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call
- type MockDataRegistryServiceClient_Expecter
- func (_e *MockDataRegistryServiceClient_Expecter) CreateOrUpdateMetric(ctx interface{}, in interface{}, opts ...interface{}) *MockDataRegistryServiceClient_CreateOrUpdateMetric_Call
- func (_e *MockDataRegistryServiceClient_Expecter) CreateOrUpdateMetrics(ctx interface{}, opts ...interface{}) *MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call
- func (_e *MockDataRegistryServiceClient_Expecter) GetMetric(ctx interface{}, in interface{}, opts ...interface{}) *MockDataRegistryServiceClient_GetMetric_Call
- func (_e *MockDataRegistryServiceClient_Expecter) RegisterDefinition(ctx interface{}, in interface{}, opts ...interface{}) *MockDataRegistryServiceClient_RegisterDefinition_Call
- func (_e *MockDataRegistryServiceClient_Expecter) UpdateDefinition(ctx interface{}, in interface{}, opts ...interface{}) *MockDataRegistryServiceClient_UpdateDefinition_Call
- func (_e *MockDataRegistryServiceClient_Expecter) UpdateMetric(ctx interface{}, in interface{}, opts ...interface{}) *MockDataRegistryServiceClient_UpdateMetric_Call
- type MockDataRegistryServiceClient_GetMetric_Call
- func (_c *MockDataRegistryServiceClient_GetMetric_Call) Return(_a0 *GetMetricResponse, _a1 error) *MockDataRegistryServiceClient_GetMetric_Call
- func (_c *MockDataRegistryServiceClient_GetMetric_Call) Run(run func(ctx context.Context, in *GetMetricRequest, opts ...grpc.CallOption)) *MockDataRegistryServiceClient_GetMetric_Call
- type MockDataRegistryServiceClient_RegisterDefinition_Call
- func (_c *MockDataRegistryServiceClient_RegisterDefinition_Call) Return(_a0 *DefinitionResponse, _a1 error) *MockDataRegistryServiceClient_RegisterDefinition_Call
- func (_c *MockDataRegistryServiceClient_RegisterDefinition_Call) Run(run func(ctx context.Context, in *Definition, opts ...grpc.CallOption)) *MockDataRegistryServiceClient_RegisterDefinition_Call
- type MockDataRegistryServiceClient_UpdateDefinition_Call
- func (_c *MockDataRegistryServiceClient_UpdateDefinition_Call) Return(_a0 *DefinitionResponse, _a1 error) *MockDataRegistryServiceClient_UpdateDefinition_Call
- func (_c *MockDataRegistryServiceClient_UpdateDefinition_Call) Run(run func(ctx context.Context, in *DefinitionUpdate, opts ...grpc.CallOption)) *MockDataRegistryServiceClient_UpdateDefinition_Call
- type MockDataRegistryServiceClient_UpdateMetric_Call
- type MockDataRegistryServiceServer
- func (_m *MockDataRegistryServiceServer) CreateOrUpdateMetric(_a0 context.Context, _a1 *RegisterMetricRequest) (*RegisterMetricResponse, error)
- func (_m *MockDataRegistryServiceServer) CreateOrUpdateMetrics(_a0 DataRegistryService_CreateOrUpdateMetricsServer) error
- func (_m *MockDataRegistryServiceServer) EXPECT() *MockDataRegistryServiceServer_Expecter
- func (_m *MockDataRegistryServiceServer) GetMetric(_a0 context.Context, _a1 *GetMetricRequest) (*GetMetricResponse, error)
- func (_m *MockDataRegistryServiceServer) RegisterDefinition(_a0 context.Context, _a1 *Definition) (*DefinitionResponse, error)
- func (_m *MockDataRegistryServiceServer) UpdateDefinition(_a0 context.Context, _a1 *DefinitionUpdate) (*DefinitionResponse, error)
- func (_m *MockDataRegistryServiceServer) UpdateMetric(_a0 context.Context, _a1 *UpdateMetricRequest) (*RegisterMetricResponse, error)
- type MockDataRegistryServiceServer_CreateOrUpdateMetric_Call
- func (_c *MockDataRegistryServiceServer_CreateOrUpdateMetric_Call) Return(_a0 *RegisterMetricResponse, _a1 error) *MockDataRegistryServiceServer_CreateOrUpdateMetric_Call
- func (_c *MockDataRegistryServiceServer_CreateOrUpdateMetric_Call) Run(run func(_a0 context.Context, _a1 *RegisterMetricRequest)) *MockDataRegistryServiceServer_CreateOrUpdateMetric_Call
- type MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call
- func (_c *MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call) Return(_a0 error) *MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call
- func (_c *MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call) Run(run func(_a0 DataRegistryService_CreateOrUpdateMetricsServer)) *MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call
- type MockDataRegistryServiceServer_Expecter
- func (_e *MockDataRegistryServiceServer_Expecter) CreateOrUpdateMetric(_a0 interface{}, _a1 interface{}) *MockDataRegistryServiceServer_CreateOrUpdateMetric_Call
- func (_e *MockDataRegistryServiceServer_Expecter) CreateOrUpdateMetrics(_a0 interface{}) *MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call
- func (_e *MockDataRegistryServiceServer_Expecter) GetMetric(_a0 interface{}, _a1 interface{}) *MockDataRegistryServiceServer_GetMetric_Call
- func (_e *MockDataRegistryServiceServer_Expecter) RegisterDefinition(_a0 interface{}, _a1 interface{}) *MockDataRegistryServiceServer_RegisterDefinition_Call
- func (_e *MockDataRegistryServiceServer_Expecter) UpdateDefinition(_a0 interface{}, _a1 interface{}) *MockDataRegistryServiceServer_UpdateDefinition_Call
- func (_e *MockDataRegistryServiceServer_Expecter) UpdateMetric(_a0 interface{}, _a1 interface{}) *MockDataRegistryServiceServer_UpdateMetric_Call
- type MockDataRegistryServiceServer_GetMetric_Call
- func (_c *MockDataRegistryServiceServer_GetMetric_Call) Return(_a0 *GetMetricResponse, _a1 error) *MockDataRegistryServiceServer_GetMetric_Call
- func (_c *MockDataRegistryServiceServer_GetMetric_Call) Run(run func(_a0 context.Context, _a1 *GetMetricRequest)) *MockDataRegistryServiceServer_GetMetric_Call
- type MockDataRegistryServiceServer_RegisterDefinition_Call
- func (_c *MockDataRegistryServiceServer_RegisterDefinition_Call) Return(_a0 *DefinitionResponse, _a1 error) *MockDataRegistryServiceServer_RegisterDefinition_Call
- func (_c *MockDataRegistryServiceServer_RegisterDefinition_Call) Run(run func(_a0 context.Context, _a1 *Definition)) *MockDataRegistryServiceServer_RegisterDefinition_Call
- type MockDataRegistryServiceServer_UpdateDefinition_Call
- func (_c *MockDataRegistryServiceServer_UpdateDefinition_Call) Return(_a0 *DefinitionResponse, _a1 error) *MockDataRegistryServiceServer_UpdateDefinition_Call
- func (_c *MockDataRegistryServiceServer_UpdateDefinition_Call) Run(run func(_a0 context.Context, _a1 *DefinitionUpdate)) *MockDataRegistryServiceServer_UpdateDefinition_Call
- type MockDataRegistryServiceServer_UpdateMetric_Call
- func (_c *MockDataRegistryServiceServer_UpdateMetric_Call) Return(_a0 *RegisterMetricResponse, _a1 error) *MockDataRegistryServiceServer_UpdateMetric_Call
- func (_c *MockDataRegistryServiceServer_UpdateMetric_Call) Run(run func(_a0 context.Context, _a1 *UpdateMetricRequest)) *MockDataRegistryServiceServer_UpdateMetric_Call
- type MockDataRegistryService_CreateOrUpdateMetricsClient
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) CloseAndRecv() (*RegisterMetricsResponse, error)
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) CloseSend() error
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) Context() context.Context
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) EXPECT() *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) Header() (metadata.MD, error)
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) RecvMsg(m interface{}) error
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) Send(_a0 *RegisterMetricRequest) error
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) SendMsg(m interface{}) error
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) Trailer() metadata.MD
- type MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call) Return(_a0 *RegisterMetricsResponse, _a1 error) *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call
- type MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call
- type MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call) Return(_a0 context.Context) *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call
- type MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) CloseAndRecv() *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) CloseSend() *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) Context() *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) Header() *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) RecvMsg(m interface{}) *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) Send(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) SendMsg(m interface{}) *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) Trailer() *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call
- type MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call) Return(_a0 metadata.MD, _a1 error) *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call
- type MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call) Run(run func(m interface{})) *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call
- type MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call) Run(run func(m interface{})) *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call
- type MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call) Run(run func(_a0 *RegisterMetricRequest)) *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call
- type MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call) Return(_a0 metadata.MD) *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call
- type MockDataRegistryService_CreateOrUpdateMetricsServer
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) Context() context.Context
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) EXPECT() *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) Recv() (*RegisterMetricRequest, error)
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) RecvMsg(m interface{}) error
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) SendAndClose(_a0 *RegisterMetricsResponse) error
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) SendHeader(_a0 metadata.MD) error
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) SendMsg(m interface{}) error
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) SetHeader(_a0 metadata.MD) error
- func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) SetTrailer(_a0 metadata.MD)
- type MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call) Return(_a0 context.Context) *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call
- type MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) Context() *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) Recv() *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) RecvMsg(m interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SendAndClose(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SendHeader(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SendMsg(m interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SetHeader(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call
- func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SetTrailer(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call
- type MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call) Run(run func(m interface{})) *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call
- type MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call) Return(_a0 *RegisterMetricRequest, _a1 error) *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call) Run(run func()) *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call
- type MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call) Run(run func(_a0 *RegisterMetricsResponse)) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call
- type MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call) Run(run func(_a0 metadata.MD)) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call
- type MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call) Run(run func(m interface{})) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call
- type MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call) Return(_a0 error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call) Run(run func(_a0 metadata.MD)) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call
- type MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call) Return() *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call) Run(run func(_a0 metadata.MD)) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call
- type RegisterMetricRequest
- func (*RegisterMetricRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterMetricRequest) GetMetric() *data_receiver.MetricWrapper
- func (x *RegisterMetricRequest) GetUpdateMode() UpdateMode
- func (*RegisterMetricRequest) ProtoMessage()
- func (x *RegisterMetricRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterMetricRequest) Reset()
- func (x *RegisterMetricRequest) String() string
- type RegisterMetricResponse
- func (*RegisterMetricResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterMetricResponse) GetDefinitionId() string
- func (x *RegisterMetricResponse) GetInstanceId() string
- func (x *RegisterMetricResponse) GetName() string
- func (*RegisterMetricResponse) ProtoMessage()
- func (x *RegisterMetricResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterMetricResponse) Reset()
- func (x *RegisterMetricResponse) String() string
- type RegisterMetricVerboseResponse
- func (*RegisterMetricVerboseResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterMetricVerboseResponse) GetError() string
- func (x *RegisterMetricVerboseResponse) GetResponse() *RegisterMetricResponse
- func (*RegisterMetricVerboseResponse) ProtoMessage()
- func (x *RegisterMetricVerboseResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterMetricVerboseResponse) Reset()
- func (x *RegisterMetricVerboseResponse) String() string
- type RegisterMetricsResponse
- func (*RegisterMetricsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterMetricsResponse) GetResponses() []*RegisterMetricVerboseResponse
- func (*RegisterMetricsResponse) ProtoMessage()
- func (x *RegisterMetricsResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterMetricsResponse) Reset()
- func (x *RegisterMetricsResponse) String() string
- type UnimplementedDataRegistryServiceServer
- func (*UnimplementedDataRegistryServiceServer) CreateOrUpdateMetric(context.Context, *RegisterMetricRequest) (*RegisterMetricResponse, error)
- func (*UnimplementedDataRegistryServiceServer) CreateOrUpdateMetrics(DataRegistryService_CreateOrUpdateMetricsServer) error
- func (*UnimplementedDataRegistryServiceServer) GetMetric(context.Context, *GetMetricRequest) (*GetMetricResponse, error)
- func (*UnimplementedDataRegistryServiceServer) RegisterDefinition(context.Context, *Definition) (*DefinitionResponse, error)
- func (*UnimplementedDataRegistryServiceServer) UpdateDefinition(context.Context, *DefinitionUpdate) (*DefinitionResponse, error)
- func (*UnimplementedDataRegistryServiceServer) UpdateMetric(context.Context, *UpdateMetricRequest) (*RegisterMetricResponse, error)
- type UpdateMetricRequest
- func (*UpdateMetricRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateMetricRequest) GetInstanceId() string
- func (x *UpdateMetricRequest) GetMetadataFields() *structpb.Struct
- func (x *UpdateMetricRequest) GetTimestamp() int64
- func (x *UpdateMetricRequest) GetUpdateMode() UpdateMode
- func (*UpdateMetricRequest) ProtoMessage()
- func (x *UpdateMetricRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateMetricRequest) Reset()
- func (x *UpdateMetricRequest) String() string
- type UpdateMode
Constants ¶
This section is empty.
Variables ¶
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.
var File_zenoss_cloud_data_registry_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDataRegistryServiceServer ¶
func RegisterDataRegistryServiceServer(s *grpc.Server, 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) (DataRegistryService_CreateOrUpdateMetricsClient, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDataRegistryServiceClient ¶
func NewDataRegistryServiceClient(cc grpc.ClientConnInterface) DataRegistryServiceClient
type DataRegistryServiceServer ¶
type DataRegistryServiceServer interface { CreateOrUpdateMetric(context.Context, *RegisterMetricRequest) (*RegisterMetricResponse, error) CreateOrUpdateMetrics(DataRegistryService_CreateOrUpdateMetricsServer) 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) }
DataRegistryServiceServer is the server API for DataRegistryService service.
type DataRegistryService_CreateOrUpdateMetricsClient ¶
type DataRegistryService_CreateOrUpdateMetricsClient interface { Send(*RegisterMetricRequest) error CloseAndRecv() (*RegisterMetricsResponse, error) grpc.ClientStream }
type DataRegistryService_CreateOrUpdateMetricsServer ¶
type DataRegistryService_CreateOrUpdateMetricsServer interface { SendAndClose(*RegisterMetricsResponse) error Recv() (*RegisterMetricRequest, error) grpc.ServerStream }
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 ¶
MockDataRegistryServiceClient is an autogenerated mock type for the DataRegistryServiceClient type
func NewMockDataRegistryServiceClient ¶ added in v1.4.0
func NewMockDataRegistryServiceClient(t testing.TB) *MockDataRegistryServiceClient
NewMockDataRegistryServiceClient creates a new instance of MockDataRegistryServiceClient. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
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) (DataRegistryService_CreateOrUpdateMetricsClient, 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
MockDataRegistryServiceClient_CreateOrUpdateMetric_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateOrUpdateMetric'
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
type MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call ¶ added in v1.4.0
MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateOrUpdateMetrics'
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
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
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
type MockDataRegistryServiceClient_RegisterDefinition_Call ¶ added in v1.4.0
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
type MockDataRegistryServiceClient_UpdateDefinition_Call ¶ added in v1.4.0
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
type MockDataRegistryServiceClient_UpdateMetric_Call ¶ added in v1.4.0
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
type MockDataRegistryServiceServer ¶
MockDataRegistryServiceServer is an autogenerated mock type for the DataRegistryServiceServer type
func NewMockDataRegistryServiceServer ¶ added in v1.4.0
func NewMockDataRegistryServiceServer(t testing.TB) *MockDataRegistryServiceServer
NewMockDataRegistryServiceServer creates a new instance of MockDataRegistryServiceServer. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
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 DataRegistryService_CreateOrUpdateMetricsServer) 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
MockDataRegistryServiceServer_CreateOrUpdateMetric_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateOrUpdateMetric'
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
type MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call ¶ added in v1.4.0
MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateOrUpdateMetrics'
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 DataRegistryService_CreateOrUpdateMetricsServer
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
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
type MockDataRegistryServiceServer_RegisterDefinition_Call ¶ added in v1.4.0
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
type MockDataRegistryServiceServer_UpdateDefinition_Call ¶ added in v1.4.0
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
type MockDataRegistryServiceServer_UpdateMetric_Call ¶ added in v1.4.0
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
type MockDataRegistryService_CreateOrUpdateMetricsClient ¶
MockDataRegistryService_CreateOrUpdateMetricsClient is an autogenerated mock type for the DataRegistryService_CreateOrUpdateMetricsClient type
func NewMockDataRegistryService_CreateOrUpdateMetricsClient ¶ added in v1.4.0
func NewMockDataRegistryService_CreateOrUpdateMetricsClient(t testing.TB) *MockDataRegistryService_CreateOrUpdateMetricsClient
NewMockDataRegistryService_CreateOrUpdateMetricsClient creates a new instance of MockDataRegistryService_CreateOrUpdateMetricsClient. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*MockDataRegistryService_CreateOrUpdateMetricsClient) CloseAndRecv ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) CloseAndRecv() (*RegisterMetricsResponse, error)
CloseAndRecv provides a mock function with given fields:
func (*MockDataRegistryService_CreateOrUpdateMetricsClient) CloseSend ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) CloseSend() error
CloseSend provides a mock function with given fields:
func (*MockDataRegistryService_CreateOrUpdateMetricsClient) Context ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) Context() context.Context
Context provides a mock function with given fields:
func (*MockDataRegistryService_CreateOrUpdateMetricsClient) Header ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) Header() (metadata.MD, error)
Header provides a mock function with given fields:
func (*MockDataRegistryService_CreateOrUpdateMetricsClient) RecvMsg ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*MockDataRegistryService_CreateOrUpdateMetricsClient) Send ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) Send(_a0 *RegisterMetricRequest) error
Send provides a mock function with given fields: _a0
func (*MockDataRegistryService_CreateOrUpdateMetricsClient) SendMsg ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*MockDataRegistryService_CreateOrUpdateMetricsClient) Trailer ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsClient) Trailer() metadata.MD
Trailer provides a mock function with given fields:
type MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call ¶ added in v1.4.0
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) Return ¶ added in v1.4.0
type MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call ¶ added in v1.4.0
MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CloseSend'
type MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call ¶ added in v1.4.0
MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Context'
type MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter ¶ added in v1.4.0
type MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter struct {
// contains filtered or unexported fields
}
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) CloseAndRecv ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) CloseAndRecv() *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call
CloseAndRecv is a helper method to define mock.On call
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) CloseSend ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) CloseSend() *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call
CloseSend is a helper method to define mock.On call
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) Context ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) Context() *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call
Context is a helper method to define mock.On call
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) Header ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) Header() *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call
Header is a helper method to define mock.On call
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) RecvMsg ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) RecvMsg(m interface{}) *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call
RecvMsg is a helper method to define mock.On call
- m interface{}
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) Send ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) Send(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call
Send is a helper method to define mock.On call
- _a0 *RegisterMetricRequest
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) SendMsg ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) SendMsg(m interface{}) *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call
SendMsg is a helper method to define mock.On call
- m interface{}
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) Trailer ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsClient_Expecter) Trailer() *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call
Trailer is a helper method to define mock.On call
type MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call ¶ added in v1.4.0
MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Header'
type MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call ¶ added in v1.4.0
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) Run ¶ added in v1.4.0
func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call) Run(run func(m interface{})) *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call
type MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call ¶ added in v1.4.0
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) Run ¶ added in v1.4.0
func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call) Run(run func(m interface{})) *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call
type MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call ¶ added in v1.4.0
MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Send'
type MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call ¶ added in v1.4.0
MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Trailer'
type MockDataRegistryService_CreateOrUpdateMetricsServer ¶
MockDataRegistryService_CreateOrUpdateMetricsServer is an autogenerated mock type for the DataRegistryService_CreateOrUpdateMetricsServer type
func NewMockDataRegistryService_CreateOrUpdateMetricsServer ¶ added in v1.4.0
func NewMockDataRegistryService_CreateOrUpdateMetricsServer(t testing.TB) *MockDataRegistryService_CreateOrUpdateMetricsServer
NewMockDataRegistryService_CreateOrUpdateMetricsServer creates a new instance of MockDataRegistryService_CreateOrUpdateMetricsServer. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*MockDataRegistryService_CreateOrUpdateMetricsServer) Context ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) Context() context.Context
Context provides a mock function with given fields:
func (*MockDataRegistryService_CreateOrUpdateMetricsServer) Recv ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) Recv() (*RegisterMetricRequest, error)
Recv provides a mock function with given fields:
func (*MockDataRegistryService_CreateOrUpdateMetricsServer) RecvMsg ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*MockDataRegistryService_CreateOrUpdateMetricsServer) SendAndClose ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) SendAndClose(_a0 *RegisterMetricsResponse) error
SendAndClose provides a mock function with given fields: _a0
func (*MockDataRegistryService_CreateOrUpdateMetricsServer) SendHeader ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) SendHeader(_a0 metadata.MD) error
SendHeader provides a mock function with given fields: _a0
func (*MockDataRegistryService_CreateOrUpdateMetricsServer) SendMsg ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*MockDataRegistryService_CreateOrUpdateMetricsServer) SetHeader ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) SetHeader(_a0 metadata.MD) error
SetHeader provides a mock function with given fields: _a0
func (*MockDataRegistryService_CreateOrUpdateMetricsServer) SetTrailer ¶
func (_m *MockDataRegistryService_CreateOrUpdateMetricsServer) SetTrailer(_a0 metadata.MD)
SetTrailer provides a mock function with given fields: _a0
type MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call ¶ added in v1.4.0
MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Context'
type MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter ¶ added in v1.4.0
type MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter struct {
// contains filtered or unexported fields
}
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) Context ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) Context() *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call
Context is a helper method to define mock.On call
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) Recv ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) Recv() *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call
Recv is a helper method to define mock.On call
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) RecvMsg ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) RecvMsg(m interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call
RecvMsg is a helper method to define mock.On call
- m interface{}
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SendAndClose ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SendAndClose(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call
SendAndClose is a helper method to define mock.On call
- _a0 *RegisterMetricsResponse
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SendHeader ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SendHeader(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call
SendHeader is a helper method to define mock.On call
- _a0 metadata.MD
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SendMsg ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SendMsg(m interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call
SendMsg is a helper method to define mock.On call
- m interface{}
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SetHeader ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SetHeader(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call
SetHeader is a helper method to define mock.On call
- _a0 metadata.MD
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SetTrailer ¶ added in v1.4.0
func (_e *MockDataRegistryService_CreateOrUpdateMetricsServer_Expecter) SetTrailer(_a0 interface{}) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call
SetTrailer is a helper method to define mock.On call
- _a0 metadata.MD
type MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call ¶ added in v1.4.0
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) Run ¶ added in v1.4.0
func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call) Run(run func(m interface{})) *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call
type MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call ¶ added in v1.4.0
MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Recv'
type MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call ¶ added in v1.4.0
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) Return ¶ added in v1.4.0
type MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call ¶ added in v1.4.0
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) Return ¶ added in v1.4.0
type MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call ¶ added in v1.4.0
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) Run ¶ added in v1.4.0
func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call) Run(run func(m interface{})) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call
type MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call ¶ added in v1.4.0
MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetHeader'
type MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call ¶ added in v1.4.0
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) Return ¶ added in v1.4.0
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 can be embedded to have forward compatible implementations.
func (*UnimplementedDataRegistryServiceServer) CreateOrUpdateMetric ¶
func (*UnimplementedDataRegistryServiceServer) CreateOrUpdateMetric(context.Context, *RegisterMetricRequest) (*RegisterMetricResponse, error)
func (*UnimplementedDataRegistryServiceServer) CreateOrUpdateMetrics ¶
func (*UnimplementedDataRegistryServiceServer) CreateOrUpdateMetrics(DataRegistryService_CreateOrUpdateMetricsServer) 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 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