Documentation ¶
Index ¶
- Variables
- func RegisterAuthServiceServer(s *grpc.Server, srv AuthServiceServer)
- func RegisterGatewaySaverServiceServer(s *grpc.Server, srv GatewaySaverServiceServer)
- func RegisterMlEngineServiceServer(s *grpc.Server, srv MlEngineServiceServer)
- func RegisterProviderServiceServer(s *grpc.Server, srv ProviderServiceServer)
- type AuthServiceClient
- type AuthServiceServer
- type ForecastHeader
- func (*ForecastHeader) Descriptor() ([]byte, []int)deprecated
- func (x *ForecastHeader) GetForecastPeriod() *duration.Duration
- func (x *ForecastHeader) GetName() string
- func (x *ForecastHeader) GetNamespace() string
- func (x *ForecastHeader) GetResource() enums.ResourceType
- func (*ForecastHeader) ProtoMessage()
- func (x *ForecastHeader) ProtoReflect() protoreflect.Message
- func (x *ForecastHeader) Reset()
- func (x *ForecastHeader) String() string
- type GatewaySaverServiceClient
- type GatewaySaverServiceServer
- type Header
- type MlEngineServiceClient
- type MlEngineServiceServer
- type ProviderServiceClient
- type ProviderServiceServer
- type ReqAddCluster
- func (*ReqAddCluster) Descriptor() ([]byte, []int)deprecated
- func (x *ReqAddCluster) GetClientName() string
- func (x *ReqAddCluster) GetCluster() *events.Cluster
- func (*ReqAddCluster) ProtoMessage()
- func (x *ReqAddCluster) ProtoReflect() protoreflect.Message
- func (x *ReqAddCluster) Reset()
- func (x *ReqAddCluster) String() string
- type ReqAddResource
- type ReqCreateClient
- type ReqDeleteClient
- func (*ReqDeleteClient) Descriptor() ([]byte, []int)deprecated
- func (x *ReqDeleteClient) GetApiKey() string
- func (m *ReqDeleteClient) GetClientData() isReqDeleteClient_ClientData
- func (x *ReqDeleteClient) GetClusterId() string
- func (x *ReqDeleteClient) GetDeleteType() enums.DeleteType
- func (x *ReqDeleteClient) GetName() string
- func (x *ReqDeleteClient) GetPublicId() string
- func (*ReqDeleteClient) ProtoMessage()
- func (x *ReqDeleteClient) ProtoReflect() protoreflect.Message
- func (x *ReqDeleteClient) Reset()
- func (x *ReqDeleteClient) String() string
- type ReqDeleteClient_ApiKey
- type ReqDeleteClient_ClusterId
- type ReqDeleteClient_Name
- type ReqDeleteClient_PublicId
- type ReqDeleteCluster
- func (*ReqDeleteCluster) Descriptor() ([]byte, []int)deprecated
- func (m *ReqDeleteCluster) GetClusterData() isReqDeleteCluster_ClusterData
- func (x *ReqDeleteCluster) GetClusterId() string
- func (x *ReqDeleteCluster) GetDeleteType() enums.DeleteType
- func (x *ReqDeleteCluster) GetName() string
- func (*ReqDeleteCluster) ProtoMessage()
- func (x *ReqDeleteCluster) ProtoReflect() protoreflect.Message
- func (x *ReqDeleteCluster) Reset()
- func (x *ReqDeleteCluster) String() string
- type ReqDeleteCluster_ClusterId
- type ReqDeleteCluster_Name
- type ReqDeleteResource
- func (*ReqDeleteResource) Descriptor() ([]byte, []int)deprecated
- func (x *ReqDeleteResource) GetDeleteType() enums.DeleteType
- func (x *ReqDeleteResource) GetTargetRef() *ReqDeleteResource_ResourceData
- func (*ReqDeleteResource) ProtoMessage()
- func (x *ReqDeleteResource) ProtoReflect() protoreflect.Message
- func (x *ReqDeleteResource) Reset()
- func (x *ReqDeleteResource) String() string
- type ReqDeleteResource_ResourceData
- func (*ReqDeleteResource_ResourceData) Descriptor() ([]byte, []int)deprecated
- func (x *ReqDeleteResource_ResourceData) GetClusterId() string
- func (x *ReqDeleteResource_ResourceData) GetName() string
- func (x *ReqDeleteResource_ResourceData) GetNamespace() string
- func (*ReqDeleteResource_ResourceData) ProtoMessage()
- func (x *ReqDeleteResource_ResourceData) ProtoReflect() protoreflect.Message
- func (x *ReqDeleteResource_ResourceData) Reset()
- func (x *ReqDeleteResource_ResourceData) String() string
- type ReqForecastMetrics
- func (*ReqForecastMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *ReqForecastMetrics) GetForecastHeader() *ForecastHeader
- func (x *ReqForecastMetrics) GetHeader() *Header
- func (*ReqForecastMetrics) ProtoMessage()
- func (x *ReqForecastMetrics) ProtoReflect() protoreflect.Message
- func (x *ReqForecastMetrics) Reset()
- func (x *ReqForecastMetrics) String() string
- type ReqGenerateToken
- func (*ReqGenerateToken) Descriptor() ([]byte, []int)deprecated
- func (m *ReqGenerateToken) GetClientData() isReqGenerateToken_ClientData
- func (x *ReqGenerateToken) GetClusterId() string
- func (x *ReqGenerateToken) GetExtDuration() *duration.Duration
- func (x *ReqGenerateToken) GetName() string
- func (x *ReqGenerateToken) GetPublicId() string
- func (*ReqGenerateToken) ProtoMessage()
- func (x *ReqGenerateToken) ProtoReflect() protoreflect.Message
- func (x *ReqGenerateToken) Reset()
- func (x *ReqGenerateToken) String() string
- type ReqGenerateToken_ClusterId
- type ReqGenerateToken_Name
- type ReqGenerateToken_PublicId
- type ReqGetClientData
- func (*ReqGetClientData) Descriptor() ([]byte, []int)deprecated
- func (x *ReqGetClientData) GetApiKey() string
- func (m *ReqGetClientData) GetClientData() isReqGetClientData_ClientData
- func (x *ReqGetClientData) GetClusterId() string
- func (x *ReqGetClientData) GetName() string
- func (x *ReqGetClientData) GetPublicId() string
- func (*ReqGetClientData) ProtoMessage()
- func (x *ReqGetClientData) ProtoReflect() protoreflect.Message
- func (x *ReqGetClientData) Reset()
- func (x *ReqGetClientData) String() string
- type ReqGetClientData_ApiKey
- type ReqGetClientData_ClusterId
- type ReqGetClientData_Name
- type ReqGetClientData_PublicId
- type ReqGetCluster
- func (*ReqGetCluster) Descriptor() ([]byte, []int)deprecated
- func (m *ReqGetCluster) GetClusterData() isReqGetCluster_ClusterData
- func (x *ReqGetCluster) GetClusterId() string
- func (x *ReqGetCluster) GetName() string
- func (*ReqGetCluster) ProtoMessage()
- func (x *ReqGetCluster) ProtoReflect() protoreflect.Message
- func (x *ReqGetCluster) Reset()
- func (x *ReqGetCluster) String() string
- type ReqGetCluster_ClusterId
- type ReqGetCluster_Name
- type ReqGetMetrics
- func (*ReqGetMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *ReqGetMetrics) GetCluster() string
- func (x *ReqGetMetrics) GetHistory() *events.History
- func (x *ReqGetMetrics) GetName() string
- func (x *ReqGetMetrics) GetNamespace() string
- func (m *ReqGetMetrics) GetQuery() isReqGetMetrics_Query
- func (x *ReqGetMetrics) GetResource() enums.ResourceType
- func (x *ReqGetMetrics) GetStepDuration() *duration.Duration
- func (x *ReqGetMetrics) GetTimeWindow() *duration.Duration
- func (*ReqGetMetrics) ProtoMessage()
- func (x *ReqGetMetrics) ProtoReflect() protoreflect.Message
- func (x *ReqGetMetrics) Reset()
- func (x *ReqGetMetrics) String() string
- type ReqGetMetricsOffset
- func (*ReqGetMetricsOffset) Descriptor() ([]byte, []int)deprecated
- func (x *ReqGetMetricsOffset) GetHeader() *Header
- func (*ReqGetMetricsOffset) ProtoMessage()
- func (x *ReqGetMetricsOffset) ProtoReflect() protoreflect.Message
- func (x *ReqGetMetricsOffset) Reset()
- func (x *ReqGetMetricsOffset) String() string
- type ReqGetMetrics_History
- type ReqGetPredictMetric
- func (*ReqGetPredictMetric) Descriptor() ([]byte, []int)deprecated
- func (x *ReqGetPredictMetric) GetForecastHorizon() uint64
- func (x *ReqGetPredictMetric) GetObservations() []*commonproto.Item
- func (*ReqGetPredictMetric) ProtoMessage()
- func (x *ReqGetPredictMetric) ProtoReflect() protoreflect.Message
- func (x *ReqGetPredictMetric) Reset()
- func (x *ReqGetPredictMetric) String() string
- type ReqGetResources
- func (*ReqGetResources) Descriptor() ([]byte, []int)deprecated
- func (x *ReqGetResources) GetClusterId() string
- func (x *ReqGetResources) GetName() string
- func (x *ReqGetResources) GetNamespace() string
- func (m *ReqGetResources) GetResourceData() isReqGetResources_ResourceData
- func (*ReqGetResources) ProtoMessage()
- func (x *ReqGetResources) ProtoReflect() protoreflect.Message
- func (x *ReqGetResources) Reset()
- func (x *ReqGetResources) String() string
- type ReqGetResources_ClusterId
- type ReqGetResources_Name
- type ReqGetResources_Namespace
- type ReqInvalidateAllTokens
- func (*ReqInvalidateAllTokens) Descriptor() ([]byte, []int)deprecated
- func (x *ReqInvalidateAllTokens) GetBites() uint32
- func (m *ReqInvalidateAllTokens) GetClientData() isReqInvalidateAllTokens_ClientData
- func (x *ReqInvalidateAllTokens) GetClusterId() string
- func (x *ReqInvalidateAllTokens) GetName() string
- func (x *ReqInvalidateAllTokens) GetPublicId() string
- func (*ReqInvalidateAllTokens) ProtoMessage()
- func (x *ReqInvalidateAllTokens) ProtoReflect() protoreflect.Message
- func (x *ReqInvalidateAllTokens) Reset()
- func (x *ReqInvalidateAllTokens) String() string
- type ReqInvalidateAllTokens_ClusterId
- type ReqInvalidateAllTokens_Name
- type ReqInvalidateAllTokens_PublicId
- type ReqPing
- type ReqRawQueryMetrics
- func (*ReqRawQueryMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *ReqRawQueryMetrics) GetCluster() string
- func (x *ReqRawQueryMetrics) GetName() string
- func (x *ReqRawQueryMetrics) GetNamespace() string
- func (x *ReqRawQueryMetrics) GetRaw() *events.RawQuery
- func (x *ReqRawQueryMetrics) GetStepDuration() *duration.Duration
- func (*ReqRawQueryMetrics) ProtoMessage()
- func (x *ReqRawQueryMetrics) ProtoReflect() protoreflect.Message
- func (x *ReqRawQueryMetrics) Reset()
- func (x *ReqRawQueryMetrics) String() string
- type ReqRefreshToken
- func (*ReqRefreshToken) Descriptor() ([]byte, []int)deprecated
- func (m *ReqRefreshToken) GetClientData() isReqRefreshToken_ClientData
- func (x *ReqRefreshToken) GetClusterId() string
- func (x *ReqRefreshToken) GetExtDuration() *duration.Duration
- func (x *ReqRefreshToken) GetName() string
- func (x *ReqRefreshToken) GetPublicId() string
- func (x *ReqRefreshToken) GetToken() string
- func (*ReqRefreshToken) ProtoMessage()
- func (x *ReqRefreshToken) ProtoReflect() protoreflect.Message
- func (x *ReqRefreshToken) Reset()
- func (x *ReqRefreshToken) String() string
- type ReqRefreshToken_ClusterId
- type ReqRefreshToken_Name
- type ReqRefreshToken_PublicId
- type ReqSendMetrics
- func (*ReqSendMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *ReqSendMetrics) GetHeader() *Header
- func (x *ReqSendMetrics) GetMetricValues() []*commonproto.MetricValue
- func (x *ReqSendMetrics) GetMetricsOffset() uint64
- func (*ReqSendMetrics) ProtoMessage()
- func (x *ReqSendMetrics) ProtoReflect() protoreflect.Message
- func (x *ReqSendMetrics) Reset()
- func (x *ReqSendMetrics) String() string
- type ReqUpdateClient
- type ReqUpdateCluster
- func (*ReqUpdateCluster) Descriptor() ([]byte, []int)deprecated
- func (x *ReqUpdateCluster) GetClientName() string
- func (x *ReqUpdateCluster) GetCluster() *events.Cluster
- func (*ReqUpdateCluster) ProtoMessage()
- func (x *ReqUpdateCluster) ProtoReflect() protoreflect.Message
- func (x *ReqUpdateCluster) Reset()
- func (x *ReqUpdateCluster) String() string
- type ReqUpdateResource
- func (*ReqUpdateResource) Descriptor() ([]byte, []int)deprecated
- func (x *ReqUpdateResource) GetResource() *events.Resource
- func (*ReqUpdateResource) ProtoMessage()
- func (x *ReqUpdateResource) ProtoReflect() protoreflect.Message
- func (x *ReqUpdateResource) Reset()
- func (x *ReqUpdateResource) String() string
- type ResAddCluster
- type ResAddResource
- type ResCreateClient
- type ResDeleteClient
- type ResDeleteCluster
- type ResDeleteResource
- type ResGenerateToken
- type ResGetClientData
- type ResGetCluster
- type ResGetMetrics
- type ResGetMetricsOffset
- func (*ResGetMetricsOffset) Descriptor() ([]byte, []int)deprecated
- func (x *ResGetMetricsOffset) GetCurrentOffset() uint64
- func (*ResGetMetricsOffset) ProtoMessage()
- func (x *ResGetMetricsOffset) ProtoReflect() protoreflect.Message
- func (x *ResGetMetricsOffset) Reset()
- func (x *ResGetMetricsOffset) String() string
- type ResGetPredictMetric
- func (*ResGetPredictMetric) Descriptor() ([]byte, []int)deprecated
- func (x *ResGetPredictMetric) GetResultMetric() int64
- func (*ResGetPredictMetric) ProtoMessage()
- func (x *ResGetPredictMetric) ProtoReflect() protoreflect.Message
- func (x *ResGetPredictMetric) Reset()
- func (x *ResGetPredictMetric) String() string
- type ResGetResources
- type ResInvalidateAllTokens
- func (*ResInvalidateAllTokens) Descriptor() ([]byte, []int)deprecated
- func (x *ResInvalidateAllTokens) GetRsaKey() []byte
- func (*ResInvalidateAllTokens) ProtoMessage()
- func (x *ResInvalidateAllTokens) ProtoReflect() protoreflect.Message
- func (x *ResInvalidateAllTokens) Reset()
- func (x *ResInvalidateAllTokens) String() string
- type ResPong
- type ResRawQueryMetrics
- func (*ResRawQueryMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *ResRawQueryMetrics) GetMetricValues() []*commonproto.RawMetricValue
- func (*ResRawQueryMetrics) ProtoMessage()
- func (x *ResRawQueryMetrics) ProtoReflect() protoreflect.Message
- func (x *ResRawQueryMetrics) Reset()
- func (x *ResRawQueryMetrics) String() string
- type ResRefreshToken
- type ResSendMetrics
- type ResUpdateClient
- type ResUpdateCluster
- type ResUpdateResource
- type UnimplementedAuthServiceServer
- func (*UnimplementedAuthServiceServer) AddCluster(context.Context, *ReqAddCluster) (*ResAddCluster, error)
- func (*UnimplementedAuthServiceServer) AddResource(context.Context, *ReqAddResource) (*ResAddResource, error)
- func (*UnimplementedAuthServiceServer) CreateClient(context.Context, *ReqCreateClient) (*ResCreateClient, error)
- func (*UnimplementedAuthServiceServer) DeleteClient(context.Context, *ReqDeleteClient) (*ResDeleteClient, error)
- func (*UnimplementedAuthServiceServer) DeleteCluster(context.Context, *ReqDeleteCluster) (*ResDeleteCluster, error)
- func (*UnimplementedAuthServiceServer) DeleteResource(context.Context, *ReqDeleteResource) (*ResDeleteResource, error)
- func (*UnimplementedAuthServiceServer) GenerateToken(context.Context, *ReqGenerateToken) (*ResGenerateToken, error)
- func (*UnimplementedAuthServiceServer) GetClientData(context.Context, *ReqGetClientData) (*ResGetClientData, error)
- func (*UnimplementedAuthServiceServer) GetCluster(context.Context, *ReqGetCluster) (*ResGetCluster, error)
- func (*UnimplementedAuthServiceServer) GetResources(context.Context, *ReqGetResources) (*ResGetResources, error)
- func (*UnimplementedAuthServiceServer) InvalidateAllTokens(context.Context, *ReqInvalidateAllTokens) (*ResInvalidateAllTokens, error)
- func (*UnimplementedAuthServiceServer) RefreshToken(context.Context, *ReqRefreshToken) (*ResRefreshToken, error)
- func (*UnimplementedAuthServiceServer) UpdateClient(context.Context, *ReqUpdateClient) (*ResUpdateClient, error)
- func (*UnimplementedAuthServiceServer) UpdateCluster(context.Context, *ReqUpdateCluster) (*ResUpdateCluster, error)
- func (*UnimplementedAuthServiceServer) UpdateResource(context.Context, *ReqUpdateResource) (*ResUpdateResource, error)
- type UnimplementedGatewaySaverServiceServer
- type UnimplementedMlEngineServiceServer
- type UnimplementedProviderServiceServer
- func (*UnimplementedProviderServiceServer) GetMetrics(context.Context, *ReqGetMetrics) (*ResGetMetrics, error)
- func (*UnimplementedProviderServiceServer) GetRawQueryMetrics(context.Context, *ReqRawQueryMetrics) (*ResRawQueryMetrics, error)
- func (*UnimplementedProviderServiceServer) Ping(context.Context, *ReqPing) (*ResPong, error)
Constants ¶
This section is empty.
Variables ¶
var File_proto_services_auth_proto protoreflect.FileDescriptor
var File_proto_services_gateway_saver_proto protoreflect.FileDescriptor
var File_proto_services_ml_engine_proto protoreflect.FileDescriptor
var File_proto_services_provider_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAuthServiceServer ¶
func RegisterAuthServiceServer(s *grpc.Server, srv AuthServiceServer)
func RegisterGatewaySaverServiceServer ¶
func RegisterGatewaySaverServiceServer(s *grpc.Server, srv GatewaySaverServiceServer)
func RegisterMlEngineServiceServer ¶
func RegisterMlEngineServiceServer(s *grpc.Server, srv MlEngineServiceServer)
func RegisterProviderServiceServer ¶
func RegisterProviderServiceServer(s *grpc.Server, srv ProviderServiceServer)
Types ¶
type AuthServiceClient ¶
type AuthServiceClient interface { // TODO: add methods for get lists of any objects with optional filters and pagination... // client API CreateClient(ctx context.Context, in *ReqCreateClient, opts ...grpc.CallOption) (*ResCreateClient, error) UpdateClient(ctx context.Context, in *ReqUpdateClient, opts ...grpc.CallOption) (*ResUpdateClient, error) DeleteClient(ctx context.Context, in *ReqDeleteClient, opts ...grpc.CallOption) (*ResDeleteClient, error) GetClientData(ctx context.Context, in *ReqGetClientData, opts ...grpc.CallOption) (*ResGetClientData, error) // cluster API AddCluster(ctx context.Context, in *ReqAddCluster, opts ...grpc.CallOption) (*ResAddCluster, error) UpdateCluster(ctx context.Context, in *ReqUpdateCluster, opts ...grpc.CallOption) (*ResUpdateCluster, error) DeleteCluster(ctx context.Context, in *ReqDeleteCluster, opts ...grpc.CallOption) (*ResDeleteCluster, error) GetCluster(ctx context.Context, in *ReqGetCluster, opts ...grpc.CallOption) (*ResGetCluster, error) // resource API AddResource(ctx context.Context, in *ReqAddResource, opts ...grpc.CallOption) (*ResAddResource, error) UpdateResource(ctx context.Context, in *ReqUpdateResource, opts ...grpc.CallOption) (*ResUpdateResource, error) DeleteResource(ctx context.Context, in *ReqDeleteResource, opts ...grpc.CallOption) (*ResDeleteResource, error) GetResources(ctx context.Context, in *ReqGetResources, opts ...grpc.CallOption) (*ResGetResources, error) // token API GenerateToken(ctx context.Context, in *ReqGenerateToken, opts ...grpc.CallOption) (*ResGenerateToken, error) RefreshToken(ctx context.Context, in *ReqRefreshToken, opts ...grpc.CallOption) (*ResRefreshToken, error) InvalidateAllTokens(ctx context.Context, in *ReqInvalidateAllTokens, opts ...grpc.CallOption) (*ResInvalidateAllTokens, error) }
AuthServiceClient is the client API for AuthService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAuthServiceClient ¶
func NewAuthServiceClient(cc grpc.ClientConnInterface) AuthServiceClient
type AuthServiceServer ¶
type AuthServiceServer interface { // TODO: add methods for get lists of any objects with optional filters and pagination... // client API CreateClient(context.Context, *ReqCreateClient) (*ResCreateClient, error) UpdateClient(context.Context, *ReqUpdateClient) (*ResUpdateClient, error) DeleteClient(context.Context, *ReqDeleteClient) (*ResDeleteClient, error) GetClientData(context.Context, *ReqGetClientData) (*ResGetClientData, error) // cluster API AddCluster(context.Context, *ReqAddCluster) (*ResAddCluster, error) UpdateCluster(context.Context, *ReqUpdateCluster) (*ResUpdateCluster, error) DeleteCluster(context.Context, *ReqDeleteCluster) (*ResDeleteCluster, error) GetCluster(context.Context, *ReqGetCluster) (*ResGetCluster, error) // resource API AddResource(context.Context, *ReqAddResource) (*ResAddResource, error) UpdateResource(context.Context, *ReqUpdateResource) (*ResUpdateResource, error) DeleteResource(context.Context, *ReqDeleteResource) (*ResDeleteResource, error) GetResources(context.Context, *ReqGetResources) (*ResGetResources, error) // token API GenerateToken(context.Context, *ReqGenerateToken) (*ResGenerateToken, error) RefreshToken(context.Context, *ReqRefreshToken) (*ResRefreshToken, error) InvalidateAllTokens(context.Context, *ReqInvalidateAllTokens) (*ResInvalidateAllTokens, error) }
AuthServiceServer is the server API for AuthService service.
type ForecastHeader ¶
type ForecastHeader struct { Resource enums.ResourceType `protobuf:"varint,1,opt,name=resource,proto3,enum=enums.ResourceType" json:"resource,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` ForecastPeriod *duration.Duration `protobuf:"bytes,4,opt,name=forecastPeriod,proto3" json:"forecastPeriod,omitempty"` // contains filtered or unexported fields }
func (*ForecastHeader) Descriptor
deprecated
func (*ForecastHeader) Descriptor() ([]byte, []int)
Deprecated: Use ForecastHeader.ProtoReflect.Descriptor instead.
func (*ForecastHeader) GetForecastPeriod ¶
func (x *ForecastHeader) GetForecastPeriod() *duration.Duration
func (*ForecastHeader) GetName ¶
func (x *ForecastHeader) GetName() string
func (*ForecastHeader) GetNamespace ¶
func (x *ForecastHeader) GetNamespace() string
func (*ForecastHeader) GetResource ¶
func (x *ForecastHeader) GetResource() enums.ResourceType
func (*ForecastHeader) ProtoMessage ¶
func (*ForecastHeader) ProtoMessage()
func (*ForecastHeader) ProtoReflect ¶
func (x *ForecastHeader) ProtoReflect() protoreflect.Message
func (*ForecastHeader) Reset ¶
func (x *ForecastHeader) Reset()
func (*ForecastHeader) String ¶
func (x *ForecastHeader) String() string
type GatewaySaverServiceClient ¶
type GatewaySaverServiceClient interface { GetMetricsOffset(ctx context.Context, in *ReqGetMetricsOffset, opts ...grpc.CallOption) (*ResGetMetricsOffset, error) SendMetrics(ctx context.Context, in *ReqSendMetrics, opts ...grpc.CallOption) (*ResSendMetrics, error) }
GatewaySaverServiceClient is the client API for GatewaySaverService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewGatewaySaverServiceClient ¶
func NewGatewaySaverServiceClient(cc grpc.ClientConnInterface) GatewaySaverServiceClient
type GatewaySaverServiceServer ¶
type GatewaySaverServiceServer interface { GetMetricsOffset(context.Context, *ReqGetMetricsOffset) (*ResGetMetricsOffset, error) SendMetrics(context.Context, *ReqSendMetrics) (*ResSendMetrics, error) }
GatewaySaverServiceServer is the server API for GatewaySaverService service.
type Header ¶
type Header struct { ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty" faker:"uuidHyphenated"` // @gotags: faker:"uuidHyphenated" // contains filtered or unexported fields }
func (*Header) Descriptor
deprecated
func (*Header) GetClusterId ¶
func (*Header) ProtoMessage ¶
func (*Header) ProtoMessage()
func (*Header) ProtoReflect ¶
func (x *Header) ProtoReflect() protoreflect.Message
type MlEngineServiceClient ¶
type MlEngineServiceClient interface {
GetPredictMetric(ctx context.Context, in *ReqGetPredictMetric, opts ...grpc.CallOption) (*ResGetPredictMetric, error)
}
MlEngineServiceClient is the client API for MlEngineService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMlEngineServiceClient ¶
func NewMlEngineServiceClient(cc grpc.ClientConnInterface) MlEngineServiceClient
type MlEngineServiceServer ¶
type MlEngineServiceServer interface {
GetPredictMetric(context.Context, *ReqGetPredictMetric) (*ResGetPredictMetric, error)
}
MlEngineServiceServer is the server API for MlEngineService service.
type ProviderServiceClient ¶
type ProviderServiceClient interface { Ping(ctx context.Context, in *ReqPing, opts ...grpc.CallOption) (*ResPong, error) GetMetrics(ctx context.Context, in *ReqGetMetrics, opts ...grpc.CallOption) (*ResGetMetrics, error) GetRawQueryMetrics(ctx context.Context, in *ReqRawQueryMetrics, opts ...grpc.CallOption) (*ResRawQueryMetrics, error) }
ProviderServiceClient is the client API for ProviderService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewProviderServiceClient ¶
func NewProviderServiceClient(cc grpc.ClientConnInterface) ProviderServiceClient
type ProviderServiceServer ¶
type ProviderServiceServer interface { Ping(context.Context, *ReqPing) (*ResPong, error) GetMetrics(context.Context, *ReqGetMetrics) (*ResGetMetrics, error) GetRawQueryMetrics(context.Context, *ReqRawQueryMetrics) (*ResRawQueryMetrics, error) }
ProviderServiceServer is the server API for ProviderService service.
type ReqAddCluster ¶
type ReqAddCluster struct { Cluster *events.Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` ClientName string `protobuf:"bytes,2,opt,name=client_name,json=clientName,proto3" json:"client_name,omitempty"` // contains filtered or unexported fields }
func (*ReqAddCluster) Descriptor
deprecated
func (*ReqAddCluster) Descriptor() ([]byte, []int)
Deprecated: Use ReqAddCluster.ProtoReflect.Descriptor instead.
func (*ReqAddCluster) GetClientName ¶
func (x *ReqAddCluster) GetClientName() string
func (*ReqAddCluster) GetCluster ¶
func (x *ReqAddCluster) GetCluster() *events.Cluster
func (*ReqAddCluster) ProtoMessage ¶
func (*ReqAddCluster) ProtoMessage()
func (*ReqAddCluster) ProtoReflect ¶
func (x *ReqAddCluster) ProtoReflect() protoreflect.Message
func (*ReqAddCluster) Reset ¶
func (x *ReqAddCluster) Reset()
func (*ReqAddCluster) String ¶
func (x *ReqAddCluster) String() string
type ReqAddResource ¶
type ReqAddResource struct { Resource *events.Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` // contains filtered or unexported fields }
func (*ReqAddResource) Descriptor
deprecated
func (*ReqAddResource) Descriptor() ([]byte, []int)
Deprecated: Use ReqAddResource.ProtoReflect.Descriptor instead.
func (*ReqAddResource) GetResource ¶
func (x *ReqAddResource) GetResource() *events.Resource
func (*ReqAddResource) ProtoMessage ¶
func (*ReqAddResource) ProtoMessage()
func (*ReqAddResource) ProtoReflect ¶
func (x *ReqAddResource) ProtoReflect() protoreflect.Message
func (*ReqAddResource) Reset ¶
func (x *ReqAddResource) Reset()
func (*ReqAddResource) String ¶
func (x *ReqAddResource) String() string
type ReqCreateClient ¶
type ReqCreateClient struct { Client *events.Client `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` // contains filtered or unexported fields }
func (*ReqCreateClient) Descriptor
deprecated
func (*ReqCreateClient) Descriptor() ([]byte, []int)
Deprecated: Use ReqCreateClient.ProtoReflect.Descriptor instead.
func (*ReqCreateClient) GetClient ¶
func (x *ReqCreateClient) GetClient() *events.Client
func (*ReqCreateClient) ProtoMessage ¶
func (*ReqCreateClient) ProtoMessage()
func (*ReqCreateClient) ProtoReflect ¶
func (x *ReqCreateClient) ProtoReflect() protoreflect.Message
func (*ReqCreateClient) Reset ¶
func (x *ReqCreateClient) Reset()
func (*ReqCreateClient) String ¶
func (x *ReqCreateClient) String() string
type ReqDeleteClient ¶
type ReqDeleteClient struct { // Types that are assignable to ClientData: // *ReqDeleteClient_Name // *ReqDeleteClient_PublicId // *ReqDeleteClient_ClusterId // *ReqDeleteClient_ApiKey ClientData isReqDeleteClient_ClientData `protobuf_oneof:"ClientData"` DeleteType enums.DeleteType `protobuf:"varint,5,opt,name=delete_type,json=deleteType,proto3,enum=enums.DeleteType" json:"delete_type,omitempty"` // contains filtered or unexported fields }
func (*ReqDeleteClient) Descriptor
deprecated
func (*ReqDeleteClient) Descriptor() ([]byte, []int)
Deprecated: Use ReqDeleteClient.ProtoReflect.Descriptor instead.
func (*ReqDeleteClient) GetApiKey ¶
func (x *ReqDeleteClient) GetApiKey() string
func (*ReqDeleteClient) GetClientData ¶
func (m *ReqDeleteClient) GetClientData() isReqDeleteClient_ClientData
func (*ReqDeleteClient) GetClusterId ¶
func (x *ReqDeleteClient) GetClusterId() string
func (*ReqDeleteClient) GetDeleteType ¶
func (x *ReqDeleteClient) GetDeleteType() enums.DeleteType
func (*ReqDeleteClient) GetName ¶
func (x *ReqDeleteClient) GetName() string
func (*ReqDeleteClient) GetPublicId ¶
func (x *ReqDeleteClient) GetPublicId() string
func (*ReqDeleteClient) ProtoMessage ¶
func (*ReqDeleteClient) ProtoMessage()
func (*ReqDeleteClient) ProtoReflect ¶
func (x *ReqDeleteClient) ProtoReflect() protoreflect.Message
func (*ReqDeleteClient) Reset ¶
func (x *ReqDeleteClient) Reset()
func (*ReqDeleteClient) String ¶
func (x *ReqDeleteClient) String() string
type ReqDeleteClient_ApiKey ¶
type ReqDeleteClient_ApiKey struct {
ApiKey string `protobuf:"bytes,4,opt,name=api_key,json=apiKey,proto3,oneof"`
}
type ReqDeleteClient_ClusterId ¶
type ReqDeleteClient_ClusterId struct {
ClusterId string `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3,oneof"`
}
type ReqDeleteClient_Name ¶
type ReqDeleteClient_Name struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3,oneof"`
}
type ReqDeleteClient_PublicId ¶
type ReqDeleteClient_PublicId struct {
PublicId string `protobuf:"bytes,2,opt,name=public_id,json=publicId,proto3,oneof"`
}
type ReqDeleteCluster ¶
type ReqDeleteCluster struct { // Types that are assignable to ClusterData: // *ReqDeleteCluster_Name // *ReqDeleteCluster_ClusterId ClusterData isReqDeleteCluster_ClusterData `protobuf_oneof:"ClusterData"` DeleteType enums.DeleteType `protobuf:"varint,3,opt,name=delete_type,json=deleteType,proto3,enum=enums.DeleteType" json:"delete_type,omitempty"` // contains filtered or unexported fields }
func (*ReqDeleteCluster) Descriptor
deprecated
func (*ReqDeleteCluster) Descriptor() ([]byte, []int)
Deprecated: Use ReqDeleteCluster.ProtoReflect.Descriptor instead.
func (*ReqDeleteCluster) GetClusterData ¶
func (m *ReqDeleteCluster) GetClusterData() isReqDeleteCluster_ClusterData
func (*ReqDeleteCluster) GetClusterId ¶
func (x *ReqDeleteCluster) GetClusterId() string
func (*ReqDeleteCluster) GetDeleteType ¶
func (x *ReqDeleteCluster) GetDeleteType() enums.DeleteType
func (*ReqDeleteCluster) GetName ¶
func (x *ReqDeleteCluster) GetName() string
func (*ReqDeleteCluster) ProtoMessage ¶
func (*ReqDeleteCluster) ProtoMessage()
func (*ReqDeleteCluster) ProtoReflect ¶
func (x *ReqDeleteCluster) ProtoReflect() protoreflect.Message
func (*ReqDeleteCluster) Reset ¶
func (x *ReqDeleteCluster) Reset()
func (*ReqDeleteCluster) String ¶
func (x *ReqDeleteCluster) String() string
type ReqDeleteCluster_ClusterId ¶
type ReqDeleteCluster_ClusterId struct {
ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3,oneof"`
}
type ReqDeleteCluster_Name ¶
type ReqDeleteCluster_Name struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3,oneof"`
}
type ReqDeleteResource ¶
type ReqDeleteResource struct { TargetRef *ReqDeleteResource_ResourceData `protobuf:"bytes,4,opt,name=target_ref,json=targetRef,proto3" json:"target_ref,omitempty" validate:"required"` // @gotags: validate:"required" DeleteType enums.DeleteType `` // @gotags: validate:"required" /* 134-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ReqDeleteResource) Descriptor
deprecated
func (*ReqDeleteResource) Descriptor() ([]byte, []int)
Deprecated: Use ReqDeleteResource.ProtoReflect.Descriptor instead.
func (*ReqDeleteResource) GetDeleteType ¶
func (x *ReqDeleteResource) GetDeleteType() enums.DeleteType
func (*ReqDeleteResource) GetTargetRef ¶
func (x *ReqDeleteResource) GetTargetRef() *ReqDeleteResource_ResourceData
func (*ReqDeleteResource) ProtoMessage ¶
func (*ReqDeleteResource) ProtoMessage()
func (*ReqDeleteResource) ProtoReflect ¶
func (x *ReqDeleteResource) ProtoReflect() protoreflect.Message
func (*ReqDeleteResource) Reset ¶
func (x *ReqDeleteResource) Reset()
func (*ReqDeleteResource) String ¶
func (x *ReqDeleteResource) String() string
type ReqDeleteResource_ResourceData ¶
type ReqDeleteResource_ResourceData struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" validate:"required,ascii"` // @gotags: validate:"required,ascii" ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty" validate:"required,ascii"` // @gotags: validate:"required,ascii" Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty" validate:"required,ascii"` // @gotags: validate:"required,ascii" // contains filtered or unexported fields }
func (*ReqDeleteResource_ResourceData) Descriptor
deprecated
func (*ReqDeleteResource_ResourceData) Descriptor() ([]byte, []int)
Deprecated: Use ReqDeleteResource_ResourceData.ProtoReflect.Descriptor instead.
func (*ReqDeleteResource_ResourceData) GetClusterId ¶
func (x *ReqDeleteResource_ResourceData) GetClusterId() string
func (*ReqDeleteResource_ResourceData) GetName ¶
func (x *ReqDeleteResource_ResourceData) GetName() string
func (*ReqDeleteResource_ResourceData) GetNamespace ¶
func (x *ReqDeleteResource_ResourceData) GetNamespace() string
func (*ReqDeleteResource_ResourceData) ProtoMessage ¶
func (*ReqDeleteResource_ResourceData) ProtoMessage()
func (*ReqDeleteResource_ResourceData) ProtoReflect ¶
func (x *ReqDeleteResource_ResourceData) ProtoReflect() protoreflect.Message
func (*ReqDeleteResource_ResourceData) Reset ¶
func (x *ReqDeleteResource_ResourceData) Reset()
func (*ReqDeleteResource_ResourceData) String ¶
func (x *ReqDeleteResource_ResourceData) String() string
type ReqForecastMetrics ¶
type ReqForecastMetrics struct { Header *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` ForecastHeader *ForecastHeader `protobuf:"bytes,2,opt,name=forecast_header,json=forecastHeader,proto3" json:"forecast_header,omitempty"` // contains filtered or unexported fields }
func (*ReqForecastMetrics) Descriptor
deprecated
func (*ReqForecastMetrics) Descriptor() ([]byte, []int)
Deprecated: Use ReqForecastMetrics.ProtoReflect.Descriptor instead.
func (*ReqForecastMetrics) GetForecastHeader ¶
func (x *ReqForecastMetrics) GetForecastHeader() *ForecastHeader
func (*ReqForecastMetrics) GetHeader ¶
func (x *ReqForecastMetrics) GetHeader() *Header
func (*ReqForecastMetrics) ProtoMessage ¶
func (*ReqForecastMetrics) ProtoMessage()
func (*ReqForecastMetrics) ProtoReflect ¶
func (x *ReqForecastMetrics) ProtoReflect() protoreflect.Message
func (*ReqForecastMetrics) Reset ¶
func (x *ReqForecastMetrics) Reset()
func (*ReqForecastMetrics) String ¶
func (x *ReqForecastMetrics) String() string
type ReqGenerateToken ¶
type ReqGenerateToken struct { // Types that are assignable to ClientData: // *ReqGenerateToken_Name // *ReqGenerateToken_PublicId // *ReqGenerateToken_ClusterId ClientData isReqGenerateToken_ClientData `protobuf_oneof:"ClientData"` ExtDuration *duration.Duration `protobuf:"bytes,4,opt,name=ext_duration,json=extDuration,proto3" json:"ext_duration,omitempty"` // contains filtered or unexported fields }
func (*ReqGenerateToken) Descriptor
deprecated
func (*ReqGenerateToken) Descriptor() ([]byte, []int)
Deprecated: Use ReqGenerateToken.ProtoReflect.Descriptor instead.
func (*ReqGenerateToken) GetClientData ¶
func (m *ReqGenerateToken) GetClientData() isReqGenerateToken_ClientData
func (*ReqGenerateToken) GetClusterId ¶
func (x *ReqGenerateToken) GetClusterId() string
func (*ReqGenerateToken) GetExtDuration ¶
func (x *ReqGenerateToken) GetExtDuration() *duration.Duration
func (*ReqGenerateToken) GetName ¶
func (x *ReqGenerateToken) GetName() string
func (*ReqGenerateToken) GetPublicId ¶
func (x *ReqGenerateToken) GetPublicId() string
func (*ReqGenerateToken) ProtoMessage ¶
func (*ReqGenerateToken) ProtoMessage()
func (*ReqGenerateToken) ProtoReflect ¶
func (x *ReqGenerateToken) ProtoReflect() protoreflect.Message
func (*ReqGenerateToken) Reset ¶
func (x *ReqGenerateToken) Reset()
func (*ReqGenerateToken) String ¶
func (x *ReqGenerateToken) String() string
type ReqGenerateToken_ClusterId ¶
type ReqGenerateToken_ClusterId struct {
ClusterId string `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3,oneof"`
}
type ReqGenerateToken_Name ¶
type ReqGenerateToken_Name struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3,oneof"`
}
type ReqGenerateToken_PublicId ¶
type ReqGenerateToken_PublicId struct {
PublicId string `protobuf:"bytes,2,opt,name=public_id,json=publicId,proto3,oneof"`
}
type ReqGetClientData ¶
type ReqGetClientData struct { // Types that are assignable to ClientData: // *ReqGetClientData_Name // *ReqGetClientData_PublicId // *ReqGetClientData_ClusterId // *ReqGetClientData_ApiKey ClientData isReqGetClientData_ClientData `protobuf_oneof:"ClientData"` // contains filtered or unexported fields }
func (*ReqGetClientData) Descriptor
deprecated
func (*ReqGetClientData) Descriptor() ([]byte, []int)
Deprecated: Use ReqGetClientData.ProtoReflect.Descriptor instead.
func (*ReqGetClientData) GetApiKey ¶
func (x *ReqGetClientData) GetApiKey() string
func (*ReqGetClientData) GetClientData ¶
func (m *ReqGetClientData) GetClientData() isReqGetClientData_ClientData
func (*ReqGetClientData) GetClusterId ¶
func (x *ReqGetClientData) GetClusterId() string
func (*ReqGetClientData) GetName ¶
func (x *ReqGetClientData) GetName() string
func (*ReqGetClientData) GetPublicId ¶
func (x *ReqGetClientData) GetPublicId() string
func (*ReqGetClientData) ProtoMessage ¶
func (*ReqGetClientData) ProtoMessage()
func (*ReqGetClientData) ProtoReflect ¶
func (x *ReqGetClientData) ProtoReflect() protoreflect.Message
func (*ReqGetClientData) Reset ¶
func (x *ReqGetClientData) Reset()
func (*ReqGetClientData) String ¶
func (x *ReqGetClientData) String() string
type ReqGetClientData_ApiKey ¶
type ReqGetClientData_ApiKey struct {
ApiKey string `protobuf:"bytes,4,opt,name=api_key,json=apiKey,proto3,oneof"`
}
type ReqGetClientData_ClusterId ¶
type ReqGetClientData_ClusterId struct {
ClusterId string `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3,oneof"`
}
type ReqGetClientData_Name ¶
type ReqGetClientData_Name struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3,oneof"`
}
type ReqGetClientData_PublicId ¶
type ReqGetClientData_PublicId struct {
PublicId string `protobuf:"bytes,2,opt,name=public_id,json=publicId,proto3,oneof"`
}
type ReqGetCluster ¶
type ReqGetCluster struct { // Types that are assignable to ClusterData: // *ReqGetCluster_Name // *ReqGetCluster_ClusterId ClusterData isReqGetCluster_ClusterData `protobuf_oneof:"ClusterData"` // contains filtered or unexported fields }
func (*ReqGetCluster) Descriptor
deprecated
func (*ReqGetCluster) Descriptor() ([]byte, []int)
Deprecated: Use ReqGetCluster.ProtoReflect.Descriptor instead.
func (*ReqGetCluster) GetClusterData ¶
func (m *ReqGetCluster) GetClusterData() isReqGetCluster_ClusterData
func (*ReqGetCluster) GetClusterId ¶
func (x *ReqGetCluster) GetClusterId() string
func (*ReqGetCluster) GetName ¶
func (x *ReqGetCluster) GetName() string
func (*ReqGetCluster) ProtoMessage ¶
func (*ReqGetCluster) ProtoMessage()
func (*ReqGetCluster) ProtoReflect ¶
func (x *ReqGetCluster) ProtoReflect() protoreflect.Message
func (*ReqGetCluster) Reset ¶
func (x *ReqGetCluster) Reset()
func (*ReqGetCluster) String ¶
func (x *ReqGetCluster) String() string
type ReqGetCluster_ClusterId ¶
type ReqGetCluster_ClusterId struct {
ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3,oneof"`
}
type ReqGetCluster_Name ¶
type ReqGetCluster_Name struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3,oneof"`
}
type ReqGetMetrics ¶
type ReqGetMetrics struct { Resource enums.ResourceType `protobuf:"varint,1,opt,name=resource,proto3,enum=enums.ResourceType" json:"resource,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` Cluster string `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"` StepDuration *duration.Duration `protobuf:"bytes,5,opt,name=stepDuration,proto3" json:"stepDuration,omitempty"` TimeWindow *duration.Duration `protobuf:"bytes,6,opt,name=timeWindow,proto3" json:"timeWindow,omitempty"` // Types that are assignable to Query: // *ReqGetMetrics_History Query isReqGetMetrics_Query `protobuf_oneof:"Query"` // contains filtered or unexported fields }
func (*ReqGetMetrics) Descriptor
deprecated
func (*ReqGetMetrics) Descriptor() ([]byte, []int)
Deprecated: Use ReqGetMetrics.ProtoReflect.Descriptor instead.
func (*ReqGetMetrics) GetCluster ¶
func (x *ReqGetMetrics) GetCluster() string
func (*ReqGetMetrics) GetHistory ¶
func (x *ReqGetMetrics) GetHistory() *events.History
func (*ReqGetMetrics) GetName ¶
func (x *ReqGetMetrics) GetName() string
func (*ReqGetMetrics) GetNamespace ¶
func (x *ReqGetMetrics) GetNamespace() string
func (*ReqGetMetrics) GetQuery ¶
func (m *ReqGetMetrics) GetQuery() isReqGetMetrics_Query
func (*ReqGetMetrics) GetResource ¶
func (x *ReqGetMetrics) GetResource() enums.ResourceType
func (*ReqGetMetrics) GetStepDuration ¶
func (x *ReqGetMetrics) GetStepDuration() *duration.Duration
func (*ReqGetMetrics) GetTimeWindow ¶
func (x *ReqGetMetrics) GetTimeWindow() *duration.Duration
func (*ReqGetMetrics) ProtoMessage ¶
func (*ReqGetMetrics) ProtoMessage()
func (*ReqGetMetrics) ProtoReflect ¶
func (x *ReqGetMetrics) ProtoReflect() protoreflect.Message
func (*ReqGetMetrics) Reset ¶
func (x *ReqGetMetrics) Reset()
func (*ReqGetMetrics) String ¶
func (x *ReqGetMetrics) String() string
type ReqGetMetricsOffset ¶
type ReqGetMetricsOffset struct { Header *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // contains filtered or unexported fields }
func (*ReqGetMetricsOffset) Descriptor
deprecated
func (*ReqGetMetricsOffset) Descriptor() ([]byte, []int)
Deprecated: Use ReqGetMetricsOffset.ProtoReflect.Descriptor instead.
func (*ReqGetMetricsOffset) GetHeader ¶
func (x *ReqGetMetricsOffset) GetHeader() *Header
func (*ReqGetMetricsOffset) ProtoMessage ¶
func (*ReqGetMetricsOffset) ProtoMessage()
func (*ReqGetMetricsOffset) ProtoReflect ¶
func (x *ReqGetMetricsOffset) ProtoReflect() protoreflect.Message
func (*ReqGetMetricsOffset) Reset ¶
func (x *ReqGetMetricsOffset) Reset()
func (*ReqGetMetricsOffset) String ¶
func (x *ReqGetMetricsOffset) String() string
type ReqGetMetrics_History ¶
type ReqGetPredictMetric ¶
type ReqGetPredictMetric struct { ForecastHorizon uint64 `protobuf:"varint,1,opt,name=forecast_horizon,json=forecastHorizon,proto3" json:"forecast_horizon,omitempty"` Observations []*commonproto.Item `protobuf:"bytes,2,rep,name=observations,proto3" json:"observations,omitempty"` // contains filtered or unexported fields }
func (*ReqGetPredictMetric) Descriptor
deprecated
func (*ReqGetPredictMetric) Descriptor() ([]byte, []int)
Deprecated: Use ReqGetPredictMetric.ProtoReflect.Descriptor instead.
func (*ReqGetPredictMetric) GetForecastHorizon ¶
func (x *ReqGetPredictMetric) GetForecastHorizon() uint64
func (*ReqGetPredictMetric) GetObservations ¶
func (x *ReqGetPredictMetric) GetObservations() []*commonproto.Item
func (*ReqGetPredictMetric) ProtoMessage ¶
func (*ReqGetPredictMetric) ProtoMessage()
func (*ReqGetPredictMetric) ProtoReflect ¶
func (x *ReqGetPredictMetric) ProtoReflect() protoreflect.Message
func (*ReqGetPredictMetric) Reset ¶
func (x *ReqGetPredictMetric) Reset()
func (*ReqGetPredictMetric) String ¶
func (x *ReqGetPredictMetric) String() string
type ReqGetResources ¶
type ReqGetResources struct { // Types that are assignable to ResourceData: // *ReqGetResources_Name // *ReqGetResources_ClusterId // *ReqGetResources_Namespace ResourceData isReqGetResources_ResourceData `protobuf_oneof:"ResourceData"` // contains filtered or unexported fields }
func (*ReqGetResources) Descriptor
deprecated
func (*ReqGetResources) Descriptor() ([]byte, []int)
Deprecated: Use ReqGetResources.ProtoReflect.Descriptor instead.
func (*ReqGetResources) GetClusterId ¶
func (x *ReqGetResources) GetClusterId() string
func (*ReqGetResources) GetName ¶
func (x *ReqGetResources) GetName() string
func (*ReqGetResources) GetNamespace ¶
func (x *ReqGetResources) GetNamespace() string
func (*ReqGetResources) GetResourceData ¶
func (m *ReqGetResources) GetResourceData() isReqGetResources_ResourceData
func (*ReqGetResources) ProtoMessage ¶
func (*ReqGetResources) ProtoMessage()
func (*ReqGetResources) ProtoReflect ¶
func (x *ReqGetResources) ProtoReflect() protoreflect.Message
func (*ReqGetResources) Reset ¶
func (x *ReqGetResources) Reset()
func (*ReqGetResources) String ¶
func (x *ReqGetResources) String() string
type ReqGetResources_ClusterId ¶
type ReqGetResources_ClusterId struct {
ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3,oneof"`
}
type ReqGetResources_Name ¶
type ReqGetResources_Name struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3,oneof"`
}
type ReqGetResources_Namespace ¶
type ReqGetResources_Namespace struct {
Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3,oneof"`
}
type ReqInvalidateAllTokens ¶
type ReqInvalidateAllTokens struct { // Types that are assignable to ClientData: // *ReqInvalidateAllTokens_Name // *ReqInvalidateAllTokens_PublicId // *ReqInvalidateAllTokens_ClusterId ClientData isReqInvalidateAllTokens_ClientData `protobuf_oneof:"ClientData"` Bites uint32 `protobuf:"varint,4,opt,name=bites,proto3" json:"bites,omitempty"` // contains filtered or unexported fields }
func (*ReqInvalidateAllTokens) Descriptor
deprecated
func (*ReqInvalidateAllTokens) Descriptor() ([]byte, []int)
Deprecated: Use ReqInvalidateAllTokens.ProtoReflect.Descriptor instead.
func (*ReqInvalidateAllTokens) GetBites ¶
func (x *ReqInvalidateAllTokens) GetBites() uint32
func (*ReqInvalidateAllTokens) GetClientData ¶
func (m *ReqInvalidateAllTokens) GetClientData() isReqInvalidateAllTokens_ClientData
func (*ReqInvalidateAllTokens) GetClusterId ¶
func (x *ReqInvalidateAllTokens) GetClusterId() string
func (*ReqInvalidateAllTokens) GetName ¶
func (x *ReqInvalidateAllTokens) GetName() string
func (*ReqInvalidateAllTokens) GetPublicId ¶
func (x *ReqInvalidateAllTokens) GetPublicId() string
func (*ReqInvalidateAllTokens) ProtoMessage ¶
func (*ReqInvalidateAllTokens) ProtoMessage()
func (*ReqInvalidateAllTokens) ProtoReflect ¶
func (x *ReqInvalidateAllTokens) ProtoReflect() protoreflect.Message
func (*ReqInvalidateAllTokens) Reset ¶
func (x *ReqInvalidateAllTokens) Reset()
func (*ReqInvalidateAllTokens) String ¶
func (x *ReqInvalidateAllTokens) String() string
type ReqInvalidateAllTokens_ClusterId ¶
type ReqInvalidateAllTokens_ClusterId struct {
ClusterId string `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3,oneof"`
}
type ReqInvalidateAllTokens_Name ¶
type ReqInvalidateAllTokens_Name struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3,oneof"`
}
type ReqInvalidateAllTokens_PublicId ¶
type ReqInvalidateAllTokens_PublicId struct {
PublicId string `protobuf:"bytes,2,opt,name=public_id,json=publicId,proto3,oneof"`
}
type ReqPing ¶
type ReqPing struct { Ping *commonproto.Ping `protobuf:"bytes,1,opt,name=ping,proto3" json:"ping,omitempty"` // contains filtered or unexported fields }
func (*ReqPing) Descriptor
deprecated
func (*ReqPing) GetPing ¶
func (x *ReqPing) GetPing() *commonproto.Ping
func (*ReqPing) ProtoMessage ¶
func (*ReqPing) ProtoMessage()
func (*ReqPing) ProtoReflect ¶
func (x *ReqPing) ProtoReflect() protoreflect.Message
type ReqRawQueryMetrics ¶
type ReqRawQueryMetrics struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Cluster string `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"` StepDuration *duration.Duration `protobuf:"bytes,4,opt,name=stepDuration,proto3" json:"stepDuration,omitempty"` Raw *events.RawQuery `protobuf:"bytes,5,opt,name=raw,proto3" json:"raw,omitempty"` // contains filtered or unexported fields }
func (*ReqRawQueryMetrics) Descriptor
deprecated
func (*ReqRawQueryMetrics) Descriptor() ([]byte, []int)
Deprecated: Use ReqRawQueryMetrics.ProtoReflect.Descriptor instead.
func (*ReqRawQueryMetrics) GetCluster ¶
func (x *ReqRawQueryMetrics) GetCluster() string
func (*ReqRawQueryMetrics) GetName ¶
func (x *ReqRawQueryMetrics) GetName() string
func (*ReqRawQueryMetrics) GetNamespace ¶
func (x *ReqRawQueryMetrics) GetNamespace() string
func (*ReqRawQueryMetrics) GetRaw ¶
func (x *ReqRawQueryMetrics) GetRaw() *events.RawQuery
func (*ReqRawQueryMetrics) GetStepDuration ¶
func (x *ReqRawQueryMetrics) GetStepDuration() *duration.Duration
func (*ReqRawQueryMetrics) ProtoMessage ¶
func (*ReqRawQueryMetrics) ProtoMessage()
func (*ReqRawQueryMetrics) ProtoReflect ¶
func (x *ReqRawQueryMetrics) ProtoReflect() protoreflect.Message
func (*ReqRawQueryMetrics) Reset ¶
func (x *ReqRawQueryMetrics) Reset()
func (*ReqRawQueryMetrics) String ¶
func (x *ReqRawQueryMetrics) String() string
type ReqRefreshToken ¶
type ReqRefreshToken struct { // Types that are assignable to ClientData: // *ReqRefreshToken_Name // *ReqRefreshToken_PublicId // *ReqRefreshToken_ClusterId ClientData isReqRefreshToken_ClientData `protobuf_oneof:"ClientData"` Token string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty" validate:"jwt"` // @gotags: validate:"jwt" ExtDuration *duration.Duration `protobuf:"bytes,5,opt,name=ext_duration,json=extDuration,proto3" json:"ext_duration,omitempty"` // contains filtered or unexported fields }
func (*ReqRefreshToken) Descriptor
deprecated
func (*ReqRefreshToken) Descriptor() ([]byte, []int)
Deprecated: Use ReqRefreshToken.ProtoReflect.Descriptor instead.
func (*ReqRefreshToken) GetClientData ¶
func (m *ReqRefreshToken) GetClientData() isReqRefreshToken_ClientData
func (*ReqRefreshToken) GetClusterId ¶
func (x *ReqRefreshToken) GetClusterId() string
func (*ReqRefreshToken) GetExtDuration ¶
func (x *ReqRefreshToken) GetExtDuration() *duration.Duration
func (*ReqRefreshToken) GetName ¶
func (x *ReqRefreshToken) GetName() string
func (*ReqRefreshToken) GetPublicId ¶
func (x *ReqRefreshToken) GetPublicId() string
func (*ReqRefreshToken) GetToken ¶
func (x *ReqRefreshToken) GetToken() string
func (*ReqRefreshToken) ProtoMessage ¶
func (*ReqRefreshToken) ProtoMessage()
func (*ReqRefreshToken) ProtoReflect ¶
func (x *ReqRefreshToken) ProtoReflect() protoreflect.Message
func (*ReqRefreshToken) Reset ¶
func (x *ReqRefreshToken) Reset()
func (*ReqRefreshToken) String ¶
func (x *ReqRefreshToken) String() string
type ReqRefreshToken_ClusterId ¶
type ReqRefreshToken_ClusterId struct {
ClusterId string `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3,oneof"`
}
type ReqRefreshToken_Name ¶
type ReqRefreshToken_Name struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3,oneof"`
}
type ReqRefreshToken_PublicId ¶
type ReqRefreshToken_PublicId struct {
PublicId string `protobuf:"bytes,2,opt,name=public_id,json=publicId,proto3,oneof"`
}
type ReqSendMetrics ¶
type ReqSendMetrics struct { Header *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` MetricsOffset uint64 `protobuf:"varint,2,opt,name=metrics_offset,json=metricsOffset,proto3" json:"metrics_offset,omitempty" faker:"unixTime"` // @gotags: faker:"unixTime" MetricValues []*commonproto.MetricValue `protobuf:"bytes,3,rep,name=metric_values,json=metricValues,proto3" json:"metric_values,omitempty" faker:"metricsSlice"` // @gotags: faker:"metricsSlice" // contains filtered or unexported fields }
func (*ReqSendMetrics) Descriptor
deprecated
func (*ReqSendMetrics) Descriptor() ([]byte, []int)
Deprecated: Use ReqSendMetrics.ProtoReflect.Descriptor instead.
func (*ReqSendMetrics) GetHeader ¶
func (x *ReqSendMetrics) GetHeader() *Header
func (*ReqSendMetrics) GetMetricValues ¶
func (x *ReqSendMetrics) GetMetricValues() []*commonproto.MetricValue
func (*ReqSendMetrics) GetMetricsOffset ¶
func (x *ReqSendMetrics) GetMetricsOffset() uint64
func (*ReqSendMetrics) ProtoMessage ¶
func (*ReqSendMetrics) ProtoMessage()
func (*ReqSendMetrics) ProtoReflect ¶
func (x *ReqSendMetrics) ProtoReflect() protoreflect.Message
func (*ReqSendMetrics) Reset ¶
func (x *ReqSendMetrics) Reset()
func (*ReqSendMetrics) String ¶
func (x *ReqSendMetrics) String() string
type ReqUpdateClient ¶
type ReqUpdateClient struct { Client *events.Client `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` // contains filtered or unexported fields }
func (*ReqUpdateClient) Descriptor
deprecated
func (*ReqUpdateClient) Descriptor() ([]byte, []int)
Deprecated: Use ReqUpdateClient.ProtoReflect.Descriptor instead.
func (*ReqUpdateClient) GetClient ¶
func (x *ReqUpdateClient) GetClient() *events.Client
func (*ReqUpdateClient) ProtoMessage ¶
func (*ReqUpdateClient) ProtoMessage()
func (*ReqUpdateClient) ProtoReflect ¶
func (x *ReqUpdateClient) ProtoReflect() protoreflect.Message
func (*ReqUpdateClient) Reset ¶
func (x *ReqUpdateClient) Reset()
func (*ReqUpdateClient) String ¶
func (x *ReqUpdateClient) String() string
type ReqUpdateCluster ¶
type ReqUpdateCluster struct { Cluster *events.Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` ClientName string `protobuf:"bytes,2,opt,name=client_name,json=clientName,proto3" json:"client_name,omitempty"` // contains filtered or unexported fields }
func (*ReqUpdateCluster) Descriptor
deprecated
func (*ReqUpdateCluster) Descriptor() ([]byte, []int)
Deprecated: Use ReqUpdateCluster.ProtoReflect.Descriptor instead.
func (*ReqUpdateCluster) GetClientName ¶
func (x *ReqUpdateCluster) GetClientName() string
func (*ReqUpdateCluster) GetCluster ¶
func (x *ReqUpdateCluster) GetCluster() *events.Cluster
func (*ReqUpdateCluster) ProtoMessage ¶
func (*ReqUpdateCluster) ProtoMessage()
func (*ReqUpdateCluster) ProtoReflect ¶
func (x *ReqUpdateCluster) ProtoReflect() protoreflect.Message
func (*ReqUpdateCluster) Reset ¶
func (x *ReqUpdateCluster) Reset()
func (*ReqUpdateCluster) String ¶
func (x *ReqUpdateCluster) String() string
type ReqUpdateResource ¶
type ReqUpdateResource struct { Resource *events.Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` // contains filtered or unexported fields }
func (*ReqUpdateResource) Descriptor
deprecated
func (*ReqUpdateResource) Descriptor() ([]byte, []int)
Deprecated: Use ReqUpdateResource.ProtoReflect.Descriptor instead.
func (*ReqUpdateResource) GetResource ¶
func (x *ReqUpdateResource) GetResource() *events.Resource
func (*ReqUpdateResource) ProtoMessage ¶
func (*ReqUpdateResource) ProtoMessage()
func (*ReqUpdateResource) ProtoReflect ¶
func (x *ReqUpdateResource) ProtoReflect() protoreflect.Message
func (*ReqUpdateResource) Reset ¶
func (x *ReqUpdateResource) Reset()
func (*ReqUpdateResource) String ¶
func (x *ReqUpdateResource) String() string
type ResAddCluster ¶
type ResAddCluster struct {
// contains filtered or unexported fields
}
func (*ResAddCluster) Descriptor
deprecated
func (*ResAddCluster) Descriptor() ([]byte, []int)
Deprecated: Use ResAddCluster.ProtoReflect.Descriptor instead.
func (*ResAddCluster) ProtoMessage ¶
func (*ResAddCluster) ProtoMessage()
func (*ResAddCluster) ProtoReflect ¶
func (x *ResAddCluster) ProtoReflect() protoreflect.Message
func (*ResAddCluster) Reset ¶
func (x *ResAddCluster) Reset()
func (*ResAddCluster) String ¶
func (x *ResAddCluster) String() string
type ResAddResource ¶
type ResAddResource struct {
// contains filtered or unexported fields
}
func (*ResAddResource) Descriptor
deprecated
func (*ResAddResource) Descriptor() ([]byte, []int)
Deprecated: Use ResAddResource.ProtoReflect.Descriptor instead.
func (*ResAddResource) ProtoMessage ¶
func (*ResAddResource) ProtoMessage()
func (*ResAddResource) ProtoReflect ¶
func (x *ResAddResource) ProtoReflect() protoreflect.Message
func (*ResAddResource) Reset ¶
func (x *ResAddResource) Reset()
func (*ResAddResource) String ¶
func (x *ResAddResource) String() string
type ResCreateClient ¶
type ResCreateClient struct { PublicId string `protobuf:"bytes,1,opt,name=public_id,json=publicId,proto3" json:"public_id,omitempty"` // contains filtered or unexported fields }
func (*ResCreateClient) Descriptor
deprecated
func (*ResCreateClient) Descriptor() ([]byte, []int)
Deprecated: Use ResCreateClient.ProtoReflect.Descriptor instead.
func (*ResCreateClient) GetPublicId ¶
func (x *ResCreateClient) GetPublicId() string
func (*ResCreateClient) ProtoMessage ¶
func (*ResCreateClient) ProtoMessage()
func (*ResCreateClient) ProtoReflect ¶
func (x *ResCreateClient) ProtoReflect() protoreflect.Message
func (*ResCreateClient) Reset ¶
func (x *ResCreateClient) Reset()
func (*ResCreateClient) String ¶
func (x *ResCreateClient) String() string
type ResDeleteClient ¶
type ResDeleteClient struct {
// contains filtered or unexported fields
}
func (*ResDeleteClient) Descriptor
deprecated
func (*ResDeleteClient) Descriptor() ([]byte, []int)
Deprecated: Use ResDeleteClient.ProtoReflect.Descriptor instead.
func (*ResDeleteClient) ProtoMessage ¶
func (*ResDeleteClient) ProtoMessage()
func (*ResDeleteClient) ProtoReflect ¶
func (x *ResDeleteClient) ProtoReflect() protoreflect.Message
func (*ResDeleteClient) Reset ¶
func (x *ResDeleteClient) Reset()
func (*ResDeleteClient) String ¶
func (x *ResDeleteClient) String() string
type ResDeleteCluster ¶
type ResDeleteCluster struct {
// contains filtered or unexported fields
}
func (*ResDeleteCluster) Descriptor
deprecated
func (*ResDeleteCluster) Descriptor() ([]byte, []int)
Deprecated: Use ResDeleteCluster.ProtoReflect.Descriptor instead.
func (*ResDeleteCluster) ProtoMessage ¶
func (*ResDeleteCluster) ProtoMessage()
func (*ResDeleteCluster) ProtoReflect ¶
func (x *ResDeleteCluster) ProtoReflect() protoreflect.Message
func (*ResDeleteCluster) Reset ¶
func (x *ResDeleteCluster) Reset()
func (*ResDeleteCluster) String ¶
func (x *ResDeleteCluster) String() string
type ResDeleteResource ¶
type ResDeleteResource struct {
// contains filtered or unexported fields
}
func (*ResDeleteResource) Descriptor
deprecated
func (*ResDeleteResource) Descriptor() ([]byte, []int)
Deprecated: Use ResDeleteResource.ProtoReflect.Descriptor instead.
func (*ResDeleteResource) ProtoMessage ¶
func (*ResDeleteResource) ProtoMessage()
func (*ResDeleteResource) ProtoReflect ¶
func (x *ResDeleteResource) ProtoReflect() protoreflect.Message
func (*ResDeleteResource) Reset ¶
func (x *ResDeleteResource) Reset()
func (*ResDeleteResource) String ¶
func (x *ResDeleteResource) String() string
type ResGenerateToken ¶
type ResGenerateToken struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
func (*ResGenerateToken) Descriptor
deprecated
func (*ResGenerateToken) Descriptor() ([]byte, []int)
Deprecated: Use ResGenerateToken.ProtoReflect.Descriptor instead.
func (*ResGenerateToken) GetToken ¶
func (x *ResGenerateToken) GetToken() string
func (*ResGenerateToken) ProtoMessage ¶
func (*ResGenerateToken) ProtoMessage()
func (*ResGenerateToken) ProtoReflect ¶
func (x *ResGenerateToken) ProtoReflect() protoreflect.Message
func (*ResGenerateToken) Reset ¶
func (x *ResGenerateToken) Reset()
func (*ResGenerateToken) String ¶
func (x *ResGenerateToken) String() string
type ResGetClientData ¶
type ResGetClientData struct { Client *events.Client `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` // contains filtered or unexported fields }
func (*ResGetClientData) Descriptor
deprecated
func (*ResGetClientData) Descriptor() ([]byte, []int)
Deprecated: Use ResGetClientData.ProtoReflect.Descriptor instead.
func (*ResGetClientData) GetClient ¶
func (x *ResGetClientData) GetClient() *events.Client
func (*ResGetClientData) ProtoMessage ¶
func (*ResGetClientData) ProtoMessage()
func (*ResGetClientData) ProtoReflect ¶
func (x *ResGetClientData) ProtoReflect() protoreflect.Message
func (*ResGetClientData) Reset ¶
func (x *ResGetClientData) Reset()
func (*ResGetClientData) String ¶
func (x *ResGetClientData) String() string
type ResGetCluster ¶
type ResGetCluster struct { Cluster *events.Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` // contains filtered or unexported fields }
func (*ResGetCluster) Descriptor
deprecated
func (*ResGetCluster) Descriptor() ([]byte, []int)
Deprecated: Use ResGetCluster.ProtoReflect.Descriptor instead.
func (*ResGetCluster) GetCluster ¶
func (x *ResGetCluster) GetCluster() *events.Cluster
func (*ResGetCluster) ProtoMessage ¶
func (*ResGetCluster) ProtoMessage()
func (*ResGetCluster) ProtoReflect ¶
func (x *ResGetCluster) ProtoReflect() protoreflect.Message
func (*ResGetCluster) Reset ¶
func (x *ResGetCluster) Reset()
func (*ResGetCluster) String ¶
func (x *ResGetCluster) String() string
type ResGetMetrics ¶
type ResGetMetrics struct { MetricValues []*commonproto.MetricValue `protobuf:"bytes,1,rep,name=metric_values,json=metricValues,proto3" json:"metric_values,omitempty"` // contains filtered or unexported fields }
func (*ResGetMetrics) Descriptor
deprecated
func (*ResGetMetrics) Descriptor() ([]byte, []int)
Deprecated: Use ResGetMetrics.ProtoReflect.Descriptor instead.
func (*ResGetMetrics) GetMetricValues ¶
func (x *ResGetMetrics) GetMetricValues() []*commonproto.MetricValue
func (*ResGetMetrics) ProtoMessage ¶
func (*ResGetMetrics) ProtoMessage()
func (*ResGetMetrics) ProtoReflect ¶
func (x *ResGetMetrics) ProtoReflect() protoreflect.Message
func (*ResGetMetrics) Reset ¶
func (x *ResGetMetrics) Reset()
func (*ResGetMetrics) String ¶
func (x *ResGetMetrics) String() string
type ResGetMetricsOffset ¶
type ResGetMetricsOffset struct { CurrentOffset uint64 `protobuf:"varint,1,opt,name=current_offset,json=currentOffset,proto3" json:"current_offset,omitempty"` // contains filtered or unexported fields }
func (*ResGetMetricsOffset) Descriptor
deprecated
func (*ResGetMetricsOffset) Descriptor() ([]byte, []int)
Deprecated: Use ResGetMetricsOffset.ProtoReflect.Descriptor instead.
func (*ResGetMetricsOffset) GetCurrentOffset ¶
func (x *ResGetMetricsOffset) GetCurrentOffset() uint64
func (*ResGetMetricsOffset) ProtoMessage ¶
func (*ResGetMetricsOffset) ProtoMessage()
func (*ResGetMetricsOffset) ProtoReflect ¶
func (x *ResGetMetricsOffset) ProtoReflect() protoreflect.Message
func (*ResGetMetricsOffset) Reset ¶
func (x *ResGetMetricsOffset) Reset()
func (*ResGetMetricsOffset) String ¶
func (x *ResGetMetricsOffset) String() string
type ResGetPredictMetric ¶
type ResGetPredictMetric struct { ResultMetric int64 `protobuf:"varint,1,opt,name=result_metric,json=resultMetric,proto3" json:"result_metric,omitempty"` // contains filtered or unexported fields }
func (*ResGetPredictMetric) Descriptor
deprecated
func (*ResGetPredictMetric) Descriptor() ([]byte, []int)
Deprecated: Use ResGetPredictMetric.ProtoReflect.Descriptor instead.
func (*ResGetPredictMetric) GetResultMetric ¶
func (x *ResGetPredictMetric) GetResultMetric() int64
func (*ResGetPredictMetric) ProtoMessage ¶
func (*ResGetPredictMetric) ProtoMessage()
func (*ResGetPredictMetric) ProtoReflect ¶
func (x *ResGetPredictMetric) ProtoReflect() protoreflect.Message
func (*ResGetPredictMetric) Reset ¶
func (x *ResGetPredictMetric) Reset()
func (*ResGetPredictMetric) String ¶
func (x *ResGetPredictMetric) String() string
type ResGetResources ¶
type ResGetResources struct { Resources []*events.Resource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"` // contains filtered or unexported fields }
func (*ResGetResources) Descriptor
deprecated
func (*ResGetResources) Descriptor() ([]byte, []int)
Deprecated: Use ResGetResources.ProtoReflect.Descriptor instead.
func (*ResGetResources) GetResources ¶
func (x *ResGetResources) GetResources() []*events.Resource
func (*ResGetResources) ProtoMessage ¶
func (*ResGetResources) ProtoMessage()
func (*ResGetResources) ProtoReflect ¶
func (x *ResGetResources) ProtoReflect() protoreflect.Message
func (*ResGetResources) Reset ¶
func (x *ResGetResources) Reset()
func (*ResGetResources) String ¶
func (x *ResGetResources) String() string
type ResInvalidateAllTokens ¶
type ResInvalidateAllTokens struct { RsaKey []byte `protobuf:"bytes,1,opt,name=rsa_key,json=rsaKey,proto3" json:"rsa_key,omitempty"` // contains filtered or unexported fields }
func (*ResInvalidateAllTokens) Descriptor
deprecated
func (*ResInvalidateAllTokens) Descriptor() ([]byte, []int)
Deprecated: Use ResInvalidateAllTokens.ProtoReflect.Descriptor instead.
func (*ResInvalidateAllTokens) GetRsaKey ¶
func (x *ResInvalidateAllTokens) GetRsaKey() []byte
func (*ResInvalidateAllTokens) ProtoMessage ¶
func (*ResInvalidateAllTokens) ProtoMessage()
func (*ResInvalidateAllTokens) ProtoReflect ¶
func (x *ResInvalidateAllTokens) ProtoReflect() protoreflect.Message
func (*ResInvalidateAllTokens) Reset ¶
func (x *ResInvalidateAllTokens) Reset()
func (*ResInvalidateAllTokens) String ¶
func (x *ResInvalidateAllTokens) String() string
type ResPong ¶
type ResPong struct { Pong *commonproto.Pong `protobuf:"bytes,1,opt,name=pong,proto3" json:"pong,omitempty"` // contains filtered or unexported fields }
func (*ResPong) Descriptor
deprecated
func (*ResPong) GetPong ¶
func (x *ResPong) GetPong() *commonproto.Pong
func (*ResPong) ProtoMessage ¶
func (*ResPong) ProtoMessage()
func (*ResPong) ProtoReflect ¶
func (x *ResPong) ProtoReflect() protoreflect.Message
type ResRawQueryMetrics ¶
type ResRawQueryMetrics struct { MetricValues []*commonproto.RawMetricValue `protobuf:"bytes,1,rep,name=metric_values,json=metricValues,proto3" json:"metric_values,omitempty"` // contains filtered or unexported fields }
func (*ResRawQueryMetrics) Descriptor
deprecated
func (*ResRawQueryMetrics) Descriptor() ([]byte, []int)
Deprecated: Use ResRawQueryMetrics.ProtoReflect.Descriptor instead.
func (*ResRawQueryMetrics) GetMetricValues ¶
func (x *ResRawQueryMetrics) GetMetricValues() []*commonproto.RawMetricValue
func (*ResRawQueryMetrics) ProtoMessage ¶
func (*ResRawQueryMetrics) ProtoMessage()
func (*ResRawQueryMetrics) ProtoReflect ¶
func (x *ResRawQueryMetrics) ProtoReflect() protoreflect.Message
func (*ResRawQueryMetrics) Reset ¶
func (x *ResRawQueryMetrics) Reset()
func (*ResRawQueryMetrics) String ¶
func (x *ResRawQueryMetrics) String() string
type ResRefreshToken ¶
type ResRefreshToken struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
func (*ResRefreshToken) Descriptor
deprecated
func (*ResRefreshToken) Descriptor() ([]byte, []int)
Deprecated: Use ResRefreshToken.ProtoReflect.Descriptor instead.
func (*ResRefreshToken) GetToken ¶
func (x *ResRefreshToken) GetToken() string
func (*ResRefreshToken) ProtoMessage ¶
func (*ResRefreshToken) ProtoMessage()
func (*ResRefreshToken) ProtoReflect ¶
func (x *ResRefreshToken) ProtoReflect() protoreflect.Message
func (*ResRefreshToken) Reset ¶
func (x *ResRefreshToken) Reset()
func (*ResRefreshToken) String ¶
func (x *ResRefreshToken) String() string
type ResSendMetrics ¶
type ResSendMetrics struct {
// contains filtered or unexported fields
}
func (*ResSendMetrics) Descriptor
deprecated
func (*ResSendMetrics) Descriptor() ([]byte, []int)
Deprecated: Use ResSendMetrics.ProtoReflect.Descriptor instead.
func (*ResSendMetrics) ProtoMessage ¶
func (*ResSendMetrics) ProtoMessage()
func (*ResSendMetrics) ProtoReflect ¶
func (x *ResSendMetrics) ProtoReflect() protoreflect.Message
func (*ResSendMetrics) Reset ¶
func (x *ResSendMetrics) Reset()
func (*ResSendMetrics) String ¶
func (x *ResSendMetrics) String() string
type ResUpdateClient ¶
type ResUpdateClient struct {
// contains filtered or unexported fields
}
func (*ResUpdateClient) Descriptor
deprecated
func (*ResUpdateClient) Descriptor() ([]byte, []int)
Deprecated: Use ResUpdateClient.ProtoReflect.Descriptor instead.
func (*ResUpdateClient) ProtoMessage ¶
func (*ResUpdateClient) ProtoMessage()
func (*ResUpdateClient) ProtoReflect ¶
func (x *ResUpdateClient) ProtoReflect() protoreflect.Message
func (*ResUpdateClient) Reset ¶
func (x *ResUpdateClient) Reset()
func (*ResUpdateClient) String ¶
func (x *ResUpdateClient) String() string
type ResUpdateCluster ¶
type ResUpdateCluster struct {
// contains filtered or unexported fields
}
func (*ResUpdateCluster) Descriptor
deprecated
func (*ResUpdateCluster) Descriptor() ([]byte, []int)
Deprecated: Use ResUpdateCluster.ProtoReflect.Descriptor instead.
func (*ResUpdateCluster) ProtoMessage ¶
func (*ResUpdateCluster) ProtoMessage()
func (*ResUpdateCluster) ProtoReflect ¶
func (x *ResUpdateCluster) ProtoReflect() protoreflect.Message
func (*ResUpdateCluster) Reset ¶
func (x *ResUpdateCluster) Reset()
func (*ResUpdateCluster) String ¶
func (x *ResUpdateCluster) String() string
type ResUpdateResource ¶
type ResUpdateResource struct {
// contains filtered or unexported fields
}
func (*ResUpdateResource) Descriptor
deprecated
func (*ResUpdateResource) Descriptor() ([]byte, []int)
Deprecated: Use ResUpdateResource.ProtoReflect.Descriptor instead.
func (*ResUpdateResource) ProtoMessage ¶
func (*ResUpdateResource) ProtoMessage()
func (*ResUpdateResource) ProtoReflect ¶
func (x *ResUpdateResource) ProtoReflect() protoreflect.Message
func (*ResUpdateResource) Reset ¶
func (x *ResUpdateResource) Reset()
func (*ResUpdateResource) String ¶
func (x *ResUpdateResource) String() string
type UnimplementedAuthServiceServer ¶
type UnimplementedAuthServiceServer struct { }
UnimplementedAuthServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedAuthServiceServer) AddCluster ¶
func (*UnimplementedAuthServiceServer) AddCluster(context.Context, *ReqAddCluster) (*ResAddCluster, error)
func (*UnimplementedAuthServiceServer) AddResource ¶
func (*UnimplementedAuthServiceServer) AddResource(context.Context, *ReqAddResource) (*ResAddResource, error)
func (*UnimplementedAuthServiceServer) CreateClient ¶
func (*UnimplementedAuthServiceServer) CreateClient(context.Context, *ReqCreateClient) (*ResCreateClient, error)
func (*UnimplementedAuthServiceServer) DeleteClient ¶
func (*UnimplementedAuthServiceServer) DeleteClient(context.Context, *ReqDeleteClient) (*ResDeleteClient, error)
func (*UnimplementedAuthServiceServer) DeleteCluster ¶
func (*UnimplementedAuthServiceServer) DeleteCluster(context.Context, *ReqDeleteCluster) (*ResDeleteCluster, error)
func (*UnimplementedAuthServiceServer) DeleteResource ¶
func (*UnimplementedAuthServiceServer) DeleteResource(context.Context, *ReqDeleteResource) (*ResDeleteResource, error)
func (*UnimplementedAuthServiceServer) GenerateToken ¶
func (*UnimplementedAuthServiceServer) GenerateToken(context.Context, *ReqGenerateToken) (*ResGenerateToken, error)
func (*UnimplementedAuthServiceServer) GetClientData ¶
func (*UnimplementedAuthServiceServer) GetClientData(context.Context, *ReqGetClientData) (*ResGetClientData, error)
func (*UnimplementedAuthServiceServer) GetCluster ¶
func (*UnimplementedAuthServiceServer) GetCluster(context.Context, *ReqGetCluster) (*ResGetCluster, error)
func (*UnimplementedAuthServiceServer) GetResources ¶
func (*UnimplementedAuthServiceServer) GetResources(context.Context, *ReqGetResources) (*ResGetResources, error)
func (*UnimplementedAuthServiceServer) InvalidateAllTokens ¶
func (*UnimplementedAuthServiceServer) InvalidateAllTokens(context.Context, *ReqInvalidateAllTokens) (*ResInvalidateAllTokens, error)
func (*UnimplementedAuthServiceServer) RefreshToken ¶
func (*UnimplementedAuthServiceServer) RefreshToken(context.Context, *ReqRefreshToken) (*ResRefreshToken, error)
func (*UnimplementedAuthServiceServer) UpdateClient ¶
func (*UnimplementedAuthServiceServer) UpdateClient(context.Context, *ReqUpdateClient) (*ResUpdateClient, error)
func (*UnimplementedAuthServiceServer) UpdateCluster ¶
func (*UnimplementedAuthServiceServer) UpdateCluster(context.Context, *ReqUpdateCluster) (*ResUpdateCluster, error)
func (*UnimplementedAuthServiceServer) UpdateResource ¶
func (*UnimplementedAuthServiceServer) UpdateResource(context.Context, *ReqUpdateResource) (*ResUpdateResource, error)
type UnimplementedGatewaySaverServiceServer ¶
type UnimplementedGatewaySaverServiceServer struct { }
UnimplementedGatewaySaverServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedGatewaySaverServiceServer) GetMetricsOffset ¶
func (*UnimplementedGatewaySaverServiceServer) GetMetricsOffset(context.Context, *ReqGetMetricsOffset) (*ResGetMetricsOffset, error)
func (*UnimplementedGatewaySaverServiceServer) SendMetrics ¶
func (*UnimplementedGatewaySaverServiceServer) SendMetrics(context.Context, *ReqSendMetrics) (*ResSendMetrics, error)
type UnimplementedMlEngineServiceServer ¶
type UnimplementedMlEngineServiceServer struct { }
UnimplementedMlEngineServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedMlEngineServiceServer) GetPredictMetric ¶
func (*UnimplementedMlEngineServiceServer) GetPredictMetric(context.Context, *ReqGetPredictMetric) (*ResGetPredictMetric, error)
type UnimplementedProviderServiceServer ¶
type UnimplementedProviderServiceServer struct { }
UnimplementedProviderServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedProviderServiceServer) GetMetrics ¶
func (*UnimplementedProviderServiceServer) GetMetrics(context.Context, *ReqGetMetrics) (*ResGetMetrics, error)
func (*UnimplementedProviderServiceServer) GetRawQueryMetrics ¶
func (*UnimplementedProviderServiceServer) GetRawQueryMetrics(context.Context, *ReqRawQueryMetrics) (*ResRawQueryMetrics, error)