Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterDataRegistryServiceServer(s grpc.ServiceRegistrar, 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
- func (_c *MockDataRegistryServiceClient_CreateOrUpdateMetric_Call) RunAndReturn(...) *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
- func (_c *MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call) RunAndReturn(...) *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
- func (_c *MockDataRegistryServiceClient_GetMetric_Call) RunAndReturn(...) *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
- func (_c *MockDataRegistryServiceClient_RegisterDefinition_Call) RunAndReturn(...) *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
- func (_c *MockDataRegistryServiceClient_UpdateDefinition_Call) RunAndReturn(...) *MockDataRegistryServiceClient_UpdateDefinition_Call
- type MockDataRegistryServiceClient_UpdateMetric_Call
- func (_c *MockDataRegistryServiceClient_UpdateMetric_Call) Return(_a0 *RegisterMetricResponse, _a1 error) *MockDataRegistryServiceClient_UpdateMetric_Call
- func (_c *MockDataRegistryServiceClient_UpdateMetric_Call) Run(...) *MockDataRegistryServiceClient_UpdateMetric_Call
- func (_c *MockDataRegistryServiceClient_UpdateMetric_Call) RunAndReturn(...) *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
- func (_c *MockDataRegistryServiceServer_CreateOrUpdateMetric_Call) RunAndReturn(...) *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
- func (_c *MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call) RunAndReturn(run func(DataRegistryService_CreateOrUpdateMetricsServer) error) *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
- func (_c *MockDataRegistryServiceServer_GetMetric_Call) RunAndReturn(run func(context.Context, *GetMetricRequest) (*GetMetricResponse, error)) *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
- func (_c *MockDataRegistryServiceServer_RegisterDefinition_Call) RunAndReturn(run func(context.Context, *Definition) (*DefinitionResponse, error)) *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
- func (_c *MockDataRegistryServiceServer_UpdateDefinition_Call) RunAndReturn(run func(context.Context, *DefinitionUpdate) (*DefinitionResponse, error)) *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
- func (_c *MockDataRegistryServiceServer_UpdateMetric_Call) RunAndReturn(...) *MockDataRegistryServiceServer_UpdateMetric_Call
- type MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call
- func (_c *MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Return() ...
- func (_c *MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Run(run func()) ...
- func (_c *MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) RunAndReturn(run func()) ...
- 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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call) RunAndReturn(run func() (*RegisterMetricsResponse, error)) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call) RunAndReturn(run func() error) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call) RunAndReturn(run func() context.Context) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call) RunAndReturn(run func() (metadata.MD, error)) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call) RunAndReturn(run func(interface{}) error) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call) RunAndReturn(run func(interface{}) error) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call) RunAndReturn(run func(*RegisterMetricRequest) error) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call) RunAndReturn(run func() metadata.MD) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call) RunAndReturn(run func() context.Context) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call) RunAndReturn(run func(interface{}) error) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call) RunAndReturn(run func() (*RegisterMetricRequest, error)) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call) RunAndReturn(run func(*RegisterMetricsResponse) error) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call) RunAndReturn(run func(metadata.MD) error) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call) RunAndReturn(run func(interface{}) error) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call) RunAndReturn(run func(metadata.MD) error) *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
- func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call) RunAndReturn(run func(metadata.MD)) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call
- type MockUnsafeDataRegistryServiceServer
- type MockUnsafeDataRegistryServiceServer_Expecter
- type MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call
- func (_c *MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Return() ...
- func (_c *MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Run(run func()) ...
- func (_c *MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) RunAndReturn(run func()) ...
- 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 UnsafeDataRegistryServiceServer
- 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 ¶
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 ¶
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 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)
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) (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://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(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) // 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 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 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) (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
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
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
func (*MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryServiceClient_CreateOrUpdateMetrics_Call) RunAndReturn(run func(context.Context, ...grpc.CallOption) (DataRegistryService_CreateOrUpdateMetricsClient, 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
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
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
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
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 ¶
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 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
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
MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateOrUpdateMetrics'
func (*MockDataRegistryServiceServer_CreateOrUpdateMetrics_Call) RunAndReturn ¶ added in v1.5.1
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
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
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
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
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 (*MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Run ¶ added in v1.5.0
func (*MockDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) RunAndReturn ¶ added in v1.5.1
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 interface { mock.TestingT Cleanup(func()) }) *MockDataRegistryService_CreateOrUpdateMetricsClient
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) 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
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call) RunAndReturn(run func() (*RegisterMetricsResponse, error)) *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseAndRecv_Call
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'
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call) RunAndReturn(run func() error) *MockDataRegistryService_CreateOrUpdateMetricsClient_CloseSend_Call
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'
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call) RunAndReturn(run func() context.Context) *MockDataRegistryService_CreateOrUpdateMetricsClient_Context_Call
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'
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call) RunAndReturn(run func() (metadata.MD, error)) *MockDataRegistryService_CreateOrUpdateMetricsClient_Header_Call
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
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_RecvMsg_Call) RunAndReturn(run func(interface{}) error) *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
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_SendMsg_Call) RunAndReturn(run func(interface{}) error) *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'
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call) RunAndReturn(run func(*RegisterMetricRequest) error) *MockDataRegistryService_CreateOrUpdateMetricsClient_Send_Call
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'
func (*MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call) RunAndReturn(run func() metadata.MD) *MockDataRegistryService_CreateOrUpdateMetricsClient_Trailer_Call
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 interface { mock.TestingT Cleanup(func()) }) *MockDataRegistryService_CreateOrUpdateMetricsServer
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) 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'
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call) RunAndReturn(run func() context.Context) *MockDataRegistryService_CreateOrUpdateMetricsServer_Context_Call
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
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_RecvMsg_Call) RunAndReturn(run func(interface{}) error) *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'
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call) RunAndReturn(run func() (*RegisterMetricRequest, error)) *MockDataRegistryService_CreateOrUpdateMetricsServer_Recv_Call
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
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SendAndClose_Call) RunAndReturn ¶ added in v1.5.1
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
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call) RunAndReturn(run func(metadata.MD) error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SendHeader_Call
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
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SendMsg_Call) RunAndReturn(run func(interface{}) error) *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'
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call) RunAndReturn(run func(metadata.MD) error) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetHeader_Call
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
func (*MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call) RunAndReturn ¶ added in v1.5.1
func (_c *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call) RunAndReturn(run func(metadata.MD)) *MockDataRegistryService_CreateOrUpdateMetricsServer_SetTrailer_Call
type MockUnsafeDataRegistryServiceServer ¶ added in v1.5.0
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 (*MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) Run ¶ added in v1.5.0
func (*MockUnsafeDataRegistryServiceServer_mustEmbedUnimplementedDataRegistryServiceServer_Call) RunAndReturn ¶ added in v1.5.1
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.
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 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