data_registry

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 30, 2021 License: Apache-2.0 Imports: 11 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterDataRegistryServiceServer 

func RegisterDataRegistryServiceServer(s *grpc.Server, srv DataRegistryServiceServer)

Types

type DataRegistryServiceClient 

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

DataRegistryServiceClient is the client API for DataRegistryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDataRegistryServiceClient 

func NewDataRegistryServiceClient(cc *grpc.ClientConn) DataRegistryServiceClient

type DataRegistryServiceServer 

type DataRegistryServiceServer interface {
	CreateOrUpdateMetric(context.Context, *RegisterMetricRequest) (*RegisterMetricResponse, error)
	CreateOrUpdateMetrics(DataRegistryService_CreateOrUpdateMetricsServer) error
	UpdateMetric(context.Context, *UpdateMetricRequest) (*RegisterMetricResponse, error)
	RegisterDefinition(context.Context, *Definition) (*DefinitionResponse, error)
	UpdateDefinition(context.Context, *DefinitionUpdate) (*DefinitionResponse, error)
	GetMetric(context.Context, *GetMetricRequest) (*GetMetricResponse, error)
}

DataRegistryServiceServer is the server API for DataRegistryService service.

type DataRegistryService_CreateOrUpdateMetricsClient 

type DataRegistryService_CreateOrUpdateMetricsClient interface {
	Send(*RegisterMetricRequest) error
	CloseAndRecv() (*RegisterMetricsResponse, error)
	grpc.ClientStream
}

type DataRegistryService_CreateOrUpdateMetricsServer 

type DataRegistryService_CreateOrUpdateMetricsServer interface {
	SendAndClose(*RegisterMetricsResponse) error
	Recv() (*RegisterMetricRequest, error)
	grpc.ServerStream
}

type Definition 

type Definition struct {
	// The metric name
	Metric string `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	// Dimensions associated with this datapoint.
	Dimensions []string `protobuf:"bytes,2,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// Metadata for the datapoint. Note: using Struct as it is easier than AnyArray when using json representations
	MetadataFields *_struct.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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Definition) Descriptor 

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

func (*Definition) GetDimensions 

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

func (*Definition) GetMetadataFields 

func (m *Definition) GetMetadataFields() *_struct.Struct

func (*Definition) GetMetric 

func (m *Definition) GetMetric() string

func (*Definition) GetUpdateMode 

func (m *Definition) GetUpdateMode() UpdateMode

func (*Definition) ProtoMessage 

func (*Definition) ProtoMessage()

func (*Definition) Reset 

func (m *Definition) Reset()

func (*Definition) String 

func (m *Definition) String() string

func (*Definition) XXX_DiscardUnknown 

func (m *Definition) XXX_DiscardUnknown()

func (*Definition) XXX_Marshal 

func (m *Definition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Definition) XXX_Merge 

func (m *Definition) XXX_Merge(src proto.Message)

func (*Definition) XXX_Size 

func (m *Definition) XXX_Size() int

func (*Definition) XXX_Unmarshal 

func (m *Definition) XXX_Unmarshal(b []byte) error

type DefinitionResponse 

type DefinitionResponse struct {
	DefinitionId         string   `protobuf:"bytes,1,opt,name=definitionId,proto3" json:"definitionId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DefinitionResponse) Descriptor 

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

func (*DefinitionResponse) GetDefinitionId 

func (m *DefinitionResponse) GetDefinitionId() string

func (*DefinitionResponse) ProtoMessage 

func (*DefinitionResponse) ProtoMessage()

func (*DefinitionResponse) Reset 

func (m *DefinitionResponse) Reset()

func (*DefinitionResponse) String 

func (m *DefinitionResponse) String() string

func (*DefinitionResponse) XXX_DiscardUnknown 

func (m *DefinitionResponse) XXX_DiscardUnknown()

func (*DefinitionResponse) XXX_Marshal 

func (m *DefinitionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DefinitionResponse) XXX_Merge 

func (m *DefinitionResponse) XXX_Merge(src proto.Message)

func (*DefinitionResponse) XXX_Size 

func (m *DefinitionResponse) XXX_Size() int

func (*DefinitionResponse) XXX_Unmarshal 

func (m *DefinitionResponse) XXX_Unmarshal(b []byte) error

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 *_struct.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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*DefinitionUpdate) Descriptor 

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

func (*DefinitionUpdate) GetDefinitionId 

func (m *DefinitionUpdate) GetDefinitionId() string

func (*DefinitionUpdate) GetMetadataFields 

func (m *DefinitionUpdate) GetMetadataFields() *_struct.Struct

func (*DefinitionUpdate) GetUpdateMode 

func (m *DefinitionUpdate) GetUpdateMode() UpdateMode

func (*DefinitionUpdate) ProtoMessage 

func (*DefinitionUpdate) ProtoMessage()

func (*DefinitionUpdate) Reset 

func (m *DefinitionUpdate) Reset()

func (*DefinitionUpdate) String 

func (m *DefinitionUpdate) String() string

func (*DefinitionUpdate) XXX_DiscardUnknown 

func (m *DefinitionUpdate) XXX_DiscardUnknown()

func (*DefinitionUpdate) XXX_Marshal 

func (m *DefinitionUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DefinitionUpdate) XXX_Merge 

func (m *DefinitionUpdate) XXX_Merge(src proto.Message)

func (*DefinitionUpdate) XXX_Size 

func (m *DefinitionUpdate) XXX_Size() int

func (*DefinitionUpdate) XXX_Unmarshal 

func (m *DefinitionUpdate) XXX_Unmarshal(b []byte) error

type GetMetricRequest 

type GetMetricRequest struct {
	InstanceId           string   `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetMetricRequest) Descriptor 

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

func (*GetMetricRequest) GetInstanceId 

func (m *GetMetricRequest) GetInstanceId() string

func (*GetMetricRequest) ProtoMessage 

func (*GetMetricRequest) ProtoMessage()

func (*GetMetricRequest) Reset 

func (m *GetMetricRequest) Reset()

func (*GetMetricRequest) String 

func (m *GetMetricRequest) String() string

func (*GetMetricRequest) XXX_DiscardUnknown 

func (m *GetMetricRequest) XXX_DiscardUnknown()

func (*GetMetricRequest) XXX_Marshal 

func (m *GetMetricRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMetricRequest) XXX_Merge 

func (m *GetMetricRequest) XXX_Merge(src proto.Message)

func (*GetMetricRequest) XXX_Size 

func (m *GetMetricRequest) XXX_Size() int

func (*GetMetricRequest) XXX_Unmarshal 

func (m *GetMetricRequest) XXX_Unmarshal(b []byte) error

type GetMetricResponse 

type GetMetricResponse struct {
	Metric               *data_receiver.Metric `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*GetMetricResponse) Descriptor 

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

func (*GetMetricResponse) GetMetric 

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

func (*GetMetricResponse) ProtoMessage 

func (*GetMetricResponse) ProtoMessage()

func (*GetMetricResponse) Reset 

func (m *GetMetricResponse) Reset()

func (*GetMetricResponse) String 

func (m *GetMetricResponse) String() string

func (*GetMetricResponse) XXX_DiscardUnknown 

func (m *GetMetricResponse) XXX_DiscardUnknown()

func (*GetMetricResponse) XXX_Marshal 

func (m *GetMetricResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMetricResponse) XXX_Merge 

func (m *GetMetricResponse) XXX_Merge(src proto.Message)

func (*GetMetricResponse) XXX_Size 

func (m *GetMetricResponse) XXX_Size() int

func (*GetMetricResponse) XXX_Unmarshal 

func (m *GetMetricResponse) XXX_Unmarshal(b []byte) error

type MockDataRegistryServiceClient 

type MockDataRegistryServiceClient struct {
	mock.Mock
}

MockDataRegistryServiceClient is an autogenerated mock type for the DataRegistryServiceClient type

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) 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 MockDataRegistryServiceServer 

type MockDataRegistryServiceServer struct {
	mock.Mock
}

MockDataRegistryServiceServer is an autogenerated mock type for the DataRegistryServiceServer type

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) 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 MockDataRegistryService_CreateOrUpdateMetricsClient 

type MockDataRegistryService_CreateOrUpdateMetricsClient struct {
	mock.Mock
}

MockDataRegistryService_CreateOrUpdateMetricsClient is an autogenerated mock type for the DataRegistryService_CreateOrUpdateMetricsClient type

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_CreateOrUpdateMetricsServer 

type MockDataRegistryService_CreateOrUpdateMetricsServer struct {
	mock.Mock
}

MockDataRegistryService_CreateOrUpdateMetricsServer is an autogenerated mock type for the DataRegistryService_CreateOrUpdateMetricsServer type

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 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"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*RegisterMetricRequest) Descriptor 

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

func (*RegisterMetricRequest) GetMetric 

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

func (*RegisterMetricRequest) GetUpdateMode 

func (m *RegisterMetricRequest) GetUpdateMode() UpdateMode

func (*RegisterMetricRequest) ProtoMessage 

func (*RegisterMetricRequest) ProtoMessage()

func (*RegisterMetricRequest) Reset 

func (m *RegisterMetricRequest) Reset()

func (*RegisterMetricRequest) String 

func (m *RegisterMetricRequest) String() string

func (*RegisterMetricRequest) XXX_DiscardUnknown 

func (m *RegisterMetricRequest) XXX_DiscardUnknown()

func (*RegisterMetricRequest) XXX_Marshal 

func (m *RegisterMetricRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterMetricRequest) XXX_Merge 

func (m *RegisterMetricRequest) XXX_Merge(src proto.Message)

func (*RegisterMetricRequest) XXX_Size 

func (m *RegisterMetricRequest) XXX_Size() int

func (*RegisterMetricRequest) XXX_Unmarshal 

func (m *RegisterMetricRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterMetricResponse) Descriptor 

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

func (*RegisterMetricResponse) GetDefinitionId 

func (m *RegisterMetricResponse) GetDefinitionId() string

func (*RegisterMetricResponse) GetInstanceId 

func (m *RegisterMetricResponse) GetInstanceId() string

func (*RegisterMetricResponse) GetName 

func (m *RegisterMetricResponse) GetName() string

func (*RegisterMetricResponse) ProtoMessage 

func (*RegisterMetricResponse) ProtoMessage()

func (*RegisterMetricResponse) Reset 

func (m *RegisterMetricResponse) Reset()

func (*RegisterMetricResponse) String 

func (m *RegisterMetricResponse) String() string

func (*RegisterMetricResponse) XXX_DiscardUnknown 

func (m *RegisterMetricResponse) XXX_DiscardUnknown()

func (*RegisterMetricResponse) XXX_Marshal 

func (m *RegisterMetricResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterMetricResponse) XXX_Merge 

func (m *RegisterMetricResponse) XXX_Merge(src proto.Message)

func (*RegisterMetricResponse) XXX_Size 

func (m *RegisterMetricResponse) XXX_Size() int

func (*RegisterMetricResponse) XXX_Unmarshal 

func (m *RegisterMetricResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*RegisterMetricVerboseResponse) Descriptor 

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

func (*RegisterMetricVerboseResponse) GetError 

func (m *RegisterMetricVerboseResponse) GetError() string

func (*RegisterMetricVerboseResponse) GetResponse 

func (m *RegisterMetricVerboseResponse) GetResponse() *RegisterMetricResponse

func (*RegisterMetricVerboseResponse) ProtoMessage 

func (*RegisterMetricVerboseResponse) ProtoMessage()

func (*RegisterMetricVerboseResponse) Reset 

func (m *RegisterMetricVerboseResponse) Reset()

func (*RegisterMetricVerboseResponse) String 

func (m *RegisterMetricVerboseResponse) String() string

func (*RegisterMetricVerboseResponse) XXX_DiscardUnknown 

func (m *RegisterMetricVerboseResponse) XXX_DiscardUnknown()

func (*RegisterMetricVerboseResponse) XXX_Marshal 

func (m *RegisterMetricVerboseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterMetricVerboseResponse) XXX_Merge 

func (m *RegisterMetricVerboseResponse) XXX_Merge(src proto.Message)

func (*RegisterMetricVerboseResponse) XXX_Size 

func (m *RegisterMetricVerboseResponse) XXX_Size() int

func (*RegisterMetricVerboseResponse) XXX_Unmarshal 

func (m *RegisterMetricVerboseResponse) XXX_Unmarshal(b []byte) error

type RegisterMetricsResponse 

type RegisterMetricsResponse struct {
	Responses            []*RegisterMetricVerboseResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*RegisterMetricsResponse) Descriptor 

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

func (*RegisterMetricsResponse) GetResponses 

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

func (*RegisterMetricsResponse) ProtoMessage 

func (*RegisterMetricsResponse) ProtoMessage()

func (*RegisterMetricsResponse) Reset 

func (m *RegisterMetricsResponse) Reset()

func (*RegisterMetricsResponse) String 

func (m *RegisterMetricsResponse) String() string

func (*RegisterMetricsResponse) XXX_DiscardUnknown 

func (m *RegisterMetricsResponse) XXX_DiscardUnknown()

func (*RegisterMetricsResponse) XXX_Marshal 

func (m *RegisterMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterMetricsResponse) XXX_Merge 

func (m *RegisterMetricsResponse) XXX_Merge(src proto.Message)

func (*RegisterMetricsResponse) XXX_Size 

func (m *RegisterMetricsResponse) XXX_Size() int

func (*RegisterMetricsResponse) XXX_Unmarshal 

func (m *RegisterMetricsResponse) XXX_Unmarshal(b []byte) error

type UnimplementedDataRegistryServiceServer 

type UnimplementedDataRegistryServiceServer struct {
}

UnimplementedDataRegistryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataRegistryServiceServer) CreateOrUpdateMetric 

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

func (*UnimplementedDataRegistryServiceServer) CreateOrUpdateMetrics 

func (*UnimplementedDataRegistryServiceServer) CreateOrUpdateMetrics(srv DataRegistryService_CreateOrUpdateMetricsServer) error

func (*UnimplementedDataRegistryServiceServer) GetMetric 

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

func (*UnimplementedDataRegistryServiceServer) RegisterDefinition 

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

func (*UnimplementedDataRegistryServiceServer) UpdateDefinition 

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

func (*UnimplementedDataRegistryServiceServer) UpdateMetric 

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

type UpdateMetricRequest 

type UpdateMetricRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	// Metadata for the datapoint
	MetadataFields       *_struct.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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*UpdateMetricRequest) Descriptor 

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

func (*UpdateMetricRequest) GetInstanceId 

func (m *UpdateMetricRequest) GetInstanceId() string

func (*UpdateMetricRequest) GetMetadataFields 

func (m *UpdateMetricRequest) GetMetadataFields() *_struct.Struct

func (*UpdateMetricRequest) GetTimestamp 

func (m *UpdateMetricRequest) GetTimestamp() int64

func (*UpdateMetricRequest) GetUpdateMode 

func (m *UpdateMetricRequest) GetUpdateMode() UpdateMode

func (*UpdateMetricRequest) ProtoMessage 

func (*UpdateMetricRequest) ProtoMessage()

func (*UpdateMetricRequest) Reset 

func (m *UpdateMetricRequest) Reset()

func (*UpdateMetricRequest) String 

func (m *UpdateMetricRequest) String() string

func (*UpdateMetricRequest) XXX_DiscardUnknown 

func (m *UpdateMetricRequest) XXX_DiscardUnknown()

func (*UpdateMetricRequest) XXX_Marshal 

func (m *UpdateMetricRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateMetricRequest) XXX_Merge 

func (m *UpdateMetricRequest) XXX_Merge(src proto.Message)

func (*UpdateMetricRequest) XXX_Size 

func (m *UpdateMetricRequest) XXX_Size() int

func (*UpdateMetricRequest) XXX_Unmarshal 

func (m *UpdateMetricRequest) XXX_Unmarshal(b []byte) error

type UpdateMode 

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

func (UpdateMode) EnumDescriptor 

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

func (UpdateMode) String 

func (x UpdateMode) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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