v1

package
v0.88.9 Latest Latest
Warning

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

 Go to latest Published: Apr 11, 2024 License: Apache-2.0 Imports: 18 Imported by: 2

Documentation

Overview

Package monitoring/v1 contains the API used to monitor deployments.

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (

	// FormatText defines the log format to be text
	FormatText = "text"
	// FormatJson defines the log format to be json.
	// In JSON format, log lines are encoded as a single line JSON object.
	FormatJSON = "json"
)
View Source 
const (
	// MetricsServerTypeDBServer should be set in GetDeploymentUsageMetricsRequest to indicate
	// that metrics are being requested for DBServers
	MetricsServerTypeDBServer = "Dbserver"
	// MetricsServerTypeCoordinator should be set in GetDeploymentUsageMetricsRequest to indicate
	// that metrics are being requested for Coordinators
	MetricsServerTypeCoordinator = "Coordinator"
	// MetricsServerTypeSingle should be set in GetDeploymentUsageMetricsRequest to indicate
	// that metrics are being requested for Single server
	MetricsServerTypeSingle = "Single"

	// MetricTypeCPU should be set in GetDeploymentUsageMetricsRequest when CPU metrics
	// are being requested
	MetricTypeCPU = "cpu"
	// MetricTypeMemory should be set in GetDeploymentUsageMetricsRequest when Memory metrics
	// are being requested
	MetricTypeMemory = "memory"
	// MetricTypeDisk should be set in GetDeploymentUsageMetricsRequest when Disk metrics
	// are being requested
	MetricTypeDisk = "disk"
)
View Source 
const (

	// PermissionLogsGet is needed for gettings logs from a deployment.
	PermissionLogsGet = "monitoring.logs.get"
	// PermissionLogsGet is needed for gettings metrics from a deployment.
	PermissionMetricsGet = "monitoring.metrics.get"
)
View Source 
const (
	// ServerRoleAgents defines the role filter for agents
	ServerRoleAgents = "agents"
	// ServerRoleCoordinators defines the role filter for coordinators
	ServerRoleCoordinators = "coordinators"
	// ServerRoleDBServers defines the role filter for dbservers
	ServerRoleDBServers = "dbservers"
	// ServerRoleSingles defines the role filter for singles
	ServerRoleSingles = "singles"
)
View Source 
const (
	// APIID contains identifier of this API
	APIID = "monitoring/v1"
	// APIMajorVersion contains major version of this API
	APIMajorVersion = 1
	// APIMinorVersion contains minor version of this API
	APIMinorVersion = 4
	// APIPatchVersion contains patch version of this API
	APIPatchVersion = 0
)

Variables

View Source 
var (
	ErrInvalidLengthMonitoring        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMonitoring          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMonitoring = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterMonitoringServiceHandler 

func RegisterMonitoringServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterMonitoringServiceHandler registers the http handlers for service MonitoringService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterMonitoringServiceHandlerClient 

func RegisterMonitoringServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MonitoringServiceClient) error

RegisterMonitoringServiceHandlerClient registers the http handlers for service MonitoringService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MonitoringServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MonitoringServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MonitoringServiceClient" to call the correct interceptors.

func RegisterMonitoringServiceHandlerFromEndpoint 

func RegisterMonitoringServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterMonitoringServiceHandlerFromEndpoint is same as RegisterMonitoringServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterMonitoringServiceHandlerServer 

func RegisterMonitoringServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MonitoringServiceServer) error

RegisterMonitoringServiceHandlerServer registers the http handlers for service MonitoringService to "mux". UnaryRPC :call MonitoringServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterMonitoringServiceServer 

func RegisterMonitoringServiceServer(s *grpc.Server, srv MonitoringServiceServer)

Types

type DeploymentLogsChunk 

type DeploymentLogsChunk struct {
	// Chunk of bytes from the logs
	Chunk                []byte   `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeploymentLogsChunk) Descriptor 

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

func (*DeploymentLogsChunk) GetChunk 

func (m *DeploymentLogsChunk) GetChunk() []byte

func (*DeploymentLogsChunk) Marshal 

func (m *DeploymentLogsChunk) Marshal() (dAtA []byte, err error)

func (*DeploymentLogsChunk) MarshalTo 

func (m *DeploymentLogsChunk) MarshalTo(dAtA []byte) (int, error)

func (*DeploymentLogsChunk) MarshalToSizedBuffer 

func (m *DeploymentLogsChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeploymentLogsChunk) ProtoMessage 

func (*DeploymentLogsChunk) ProtoMessage()

func (*DeploymentLogsChunk) Reset 

func (m *DeploymentLogsChunk) Reset()

func (*DeploymentLogsChunk) Size 

func (m *DeploymentLogsChunk) Size() (n int)

func (*DeploymentLogsChunk) String 

func (m *DeploymentLogsChunk) String() string

func (*DeploymentLogsChunk) Unmarshal 

func (m *DeploymentLogsChunk) Unmarshal(dAtA []byte) error

func (*DeploymentLogsChunk) XXX_DiscardUnknown 

func (m *DeploymentLogsChunk) XXX_DiscardUnknown()

func (*DeploymentLogsChunk) XXX_Marshal 

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

func (*DeploymentLogsChunk) XXX_Merge 

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

func (*DeploymentLogsChunk) XXX_Size 

func (m *DeploymentLogsChunk) XXX_Size() int

func (*DeploymentLogsChunk) XXX_Unmarshal 

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

type DeploymentMetrics added in v0.84.0 

type DeploymentMetrics struct {
	// Contains a list of timeseries metrics for each server (of type specified in the request).
	Metrics              []*DeploymentMetrics_Timeseries `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

DeploymentMetrics contains the deployment metrics

func (*DeploymentMetrics) Descriptor added in v0.84.0 

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

func (*DeploymentMetrics) GetMetrics added in v0.84.0 

func (m *DeploymentMetrics) GetMetrics() []*DeploymentMetrics_Timeseries

func (*DeploymentMetrics) Marshal added in v0.84.0 

func (m *DeploymentMetrics) Marshal() (dAtA []byte, err error)

func (*DeploymentMetrics) MarshalTo added in v0.84.0 

func (m *DeploymentMetrics) MarshalTo(dAtA []byte) (int, error)

func (*DeploymentMetrics) MarshalToSizedBuffer added in v0.84.0 

func (m *DeploymentMetrics) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeploymentMetrics) ProtoMessage added in v0.84.0 

func (*DeploymentMetrics) ProtoMessage()

func (*DeploymentMetrics) Reset added in v0.84.0 

func (m *DeploymentMetrics) Reset()

func (*DeploymentMetrics) Size added in v0.84.0 

func (m *DeploymentMetrics) Size() (n int)

func (*DeploymentMetrics) String added in v0.84.0 

func (m *DeploymentMetrics) String() string

func (*DeploymentMetrics) Unmarshal added in v0.84.0 

func (m *DeploymentMetrics) Unmarshal(dAtA []byte) error

func (*DeploymentMetrics) XXX_DiscardUnknown added in v0.84.0 

func (m *DeploymentMetrics) XXX_DiscardUnknown()

func (*DeploymentMetrics) XXX_Marshal added in v0.84.0 

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

func (*DeploymentMetrics) XXX_Merge added in v0.84.0 

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

func (*DeploymentMetrics) XXX_Size added in v0.84.0 

func (m *DeploymentMetrics) XXX_Size() int

func (*DeploymentMetrics) XXX_Unmarshal added in v0.84.0 

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

type DeploymentMetrics_Sample added in v0.84.0 

type DeploymentMetrics_Sample struct {
	// Timestamp at which this sample is captured.
	Timestamp *types.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Value of the given sample.
	Value                float32  `protobuf:"fixed32,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Sample defines a single data point. It contains the value of the sample and the timestamp at which it was captured.

func (*DeploymentMetrics_Sample) Descriptor added in v0.84.0 

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

func (*DeploymentMetrics_Sample) GetTimestamp added in v0.84.0 

func (m *DeploymentMetrics_Sample) GetTimestamp() *types.Timestamp

func (*DeploymentMetrics_Sample) GetValue added in v0.84.0 

func (m *DeploymentMetrics_Sample) GetValue() float32

func (*DeploymentMetrics_Sample) Marshal added in v0.84.0 

func (m *DeploymentMetrics_Sample) Marshal() (dAtA []byte, err error)

func (*DeploymentMetrics_Sample) MarshalTo added in v0.84.0 

func (m *DeploymentMetrics_Sample) MarshalTo(dAtA []byte) (int, error)

func (*DeploymentMetrics_Sample) MarshalToSizedBuffer added in v0.84.0 

func (m *DeploymentMetrics_Sample) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeploymentMetrics_Sample) ProtoMessage added in v0.84.0 

func (*DeploymentMetrics_Sample) ProtoMessage()

func (*DeploymentMetrics_Sample) Reset added in v0.84.0 

func (m *DeploymentMetrics_Sample) Reset()

func (*DeploymentMetrics_Sample) Size added in v0.84.0 

func (m *DeploymentMetrics_Sample) Size() (n int)

func (*DeploymentMetrics_Sample) String added in v0.84.0 

func (m *DeploymentMetrics_Sample) String() string

func (*DeploymentMetrics_Sample) Unmarshal added in v0.84.0 

func (m *DeploymentMetrics_Sample) Unmarshal(dAtA []byte) error

func (*DeploymentMetrics_Sample) XXX_DiscardUnknown added in v0.84.0 

func (m *DeploymentMetrics_Sample) XXX_DiscardUnknown()

func (*DeploymentMetrics_Sample) XXX_Marshal added in v0.84.0 

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

func (*DeploymentMetrics_Sample) XXX_Merge added in v0.84.0 

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

func (*DeploymentMetrics_Sample) XXX_Size added in v0.84.0 

func (m *DeploymentMetrics_Sample) XXX_Size() int

func (*DeploymentMetrics_Sample) XXX_Unmarshal added in v0.84.0 

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

type DeploymentMetrics_Timeseries added in v0.84.0 

type DeploymentMetrics_Timeseries struct {
	// ID of the server.
	ServerId string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	// List of metric samples for the server identified by the server_id.
	Samples              []*DeploymentMetrics_Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

A timeseries contains a list of samples recorded at different (regular) intervals for a single database server identified by server_id.

func (*DeploymentMetrics_Timeseries) Descriptor added in v0.84.0 

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

func (*DeploymentMetrics_Timeseries) GetSamples added in v0.84.0 

func (m *DeploymentMetrics_Timeseries) GetSamples() []*DeploymentMetrics_Sample

func (*DeploymentMetrics_Timeseries) GetServerId added in v0.84.0 

func (m *DeploymentMetrics_Timeseries) GetServerId() string

func (*DeploymentMetrics_Timeseries) Marshal added in v0.84.0 

func (m *DeploymentMetrics_Timeseries) Marshal() (dAtA []byte, err error)

func (*DeploymentMetrics_Timeseries) MarshalTo added in v0.84.0 

func (m *DeploymentMetrics_Timeseries) MarshalTo(dAtA []byte) (int, error)

func (*DeploymentMetrics_Timeseries) MarshalToSizedBuffer added in v0.84.0 

func (m *DeploymentMetrics_Timeseries) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeploymentMetrics_Timeseries) ProtoMessage added in v0.84.0 

func (*DeploymentMetrics_Timeseries) ProtoMessage()

func (*DeploymentMetrics_Timeseries) Reset added in v0.84.0 

func (m *DeploymentMetrics_Timeseries) Reset()

func (*DeploymentMetrics_Timeseries) Size added in v0.84.0 

func (m *DeploymentMetrics_Timeseries) Size() (n int)

func (*DeploymentMetrics_Timeseries) String added in v0.84.0 

func (m *DeploymentMetrics_Timeseries) String() string

func (*DeploymentMetrics_Timeseries) Unmarshal added in v0.84.0 

func (m *DeploymentMetrics_Timeseries) Unmarshal(dAtA []byte) error

func (*DeploymentMetrics_Timeseries) XXX_DiscardUnknown added in v0.84.0 

func (m *DeploymentMetrics_Timeseries) XXX_DiscardUnknown()

func (*DeploymentMetrics_Timeseries) XXX_Marshal added in v0.84.0 

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

func (*DeploymentMetrics_Timeseries) XXX_Merge added in v0.84.0 

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

func (*DeploymentMetrics_Timeseries) XXX_Size added in v0.84.0 

func (m *DeploymentMetrics_Timeseries) XXX_Size() int

func (*DeploymentMetrics_Timeseries) XXX_Unmarshal added in v0.84.0 

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

type GetDeploymentLogsRequest 

type GetDeploymentLogsRequest struct {
	// Identifier of the deployment to get the logs from.
	DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	// If set, limit logs to servers of this role.
	Role string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	// Formatting for log messages.
	// The possible values are text and json, with default value being text.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// If set limits logs to the server with this ID.
	ServerId string `protobuf:"bytes,4,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	// The start time for the query. Defaults to one hour ago.
	StartAt *types.Timestamp `protobuf:"bytes,100,opt,name=start_at,json=startAt,proto3" json:"start_at,omitempty"`
	// The end time for the query. Defaults to now.
	EndAt *types.Timestamp `protobuf:"bytes,101,opt,name=end_at,json=endAt,proto3" json:"end_at,omitempty"`
	// Limit the number of log lines. Defaults to 1000.
	Limit                int32    `protobuf:"varint,102,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetDeploymentLogsRequest contains request arguments for GetDeploymentLogs.

func (*GetDeploymentLogsRequest) Descriptor 

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

func (*GetDeploymentLogsRequest) GetDeploymentId 

func (m *GetDeploymentLogsRequest) GetDeploymentId() string

func (*GetDeploymentLogsRequest) GetEndAt added in v0.43.1 

func (m *GetDeploymentLogsRequest) GetEndAt() *types.Timestamp

func (*GetDeploymentLogsRequest) GetFormat added in v0.43.6 

func (m *GetDeploymentLogsRequest) GetFormat() string

func (*GetDeploymentLogsRequest) GetLimit added in v0.43.1 

func (m *GetDeploymentLogsRequest) GetLimit() int32

func (*GetDeploymentLogsRequest) GetRole 

func (m *GetDeploymentLogsRequest) GetRole() string

func (*GetDeploymentLogsRequest) GetServerId added in v0.46.1 

func (m *GetDeploymentLogsRequest) GetServerId() string

func (*GetDeploymentLogsRequest) GetStartAt added in v0.43.1 

func (m *GetDeploymentLogsRequest) GetStartAt() *types.Timestamp

func (*GetDeploymentLogsRequest) Marshal 

func (m *GetDeploymentLogsRequest) Marshal() (dAtA []byte, err error)

func (*GetDeploymentLogsRequest) MarshalTo 

func (m *GetDeploymentLogsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetDeploymentLogsRequest) MarshalToSizedBuffer 

func (m *GetDeploymentLogsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDeploymentLogsRequest) ProtoMessage 

func (*GetDeploymentLogsRequest) ProtoMessage()

func (*GetDeploymentLogsRequest) Reset 

func (m *GetDeploymentLogsRequest) Reset()

func (*GetDeploymentLogsRequest) Size 

func (m *GetDeploymentLogsRequest) Size() (n int)

func (*GetDeploymentLogsRequest) String 

func (m *GetDeploymentLogsRequest) String() string

func (*GetDeploymentLogsRequest) Unmarshal 

func (m *GetDeploymentLogsRequest) Unmarshal(dAtA []byte) error

func (*GetDeploymentLogsRequest) XXX_DiscardUnknown 

func (m *GetDeploymentLogsRequest) XXX_DiscardUnknown()

func (*GetDeploymentLogsRequest) XXX_Marshal 

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

func (*GetDeploymentLogsRequest) XXX_Merge 

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

func (*GetDeploymentLogsRequest) XXX_Size 

func (m *GetDeploymentLogsRequest) XXX_Size() int

func (*GetDeploymentLogsRequest) XXX_Unmarshal 

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

type GetDeploymentMetricsRequest added in v0.84.0 

type GetDeploymentMetricsRequest struct {
	// ID of the deployment for which metrics are being requested.
	// This is a required field.
	DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	// Start time for the query.
	// Note: maximum allowed range is 1 week.
	// This is a required field.
	StartAt *types.Timestamp `protobuf:"bytes,2,opt,name=start_at,json=startAt,proto3" json:"start_at,omitempty"`
	// The end time for the query.
	// Note: maximum allowed range is 1 week.
	// This is a required field.
	EndAt *types.Timestamp `protobuf:"bytes,3,opt,name=end_at,json=endAt,proto3" json:"end_at,omitempty"`
	// The type of server for which metrics are being requested.
	// Should be one of the following values:
	// - Dbserver
	// - Coordinator
	// - Single
	ServerType string `protobuf:"bytes,4,opt,name=server_type,json=serverType,proto3" json:"server_type,omitempty"`
	// The type of metric being requested.
	// Should be one of the following values:
	// - cpu
	// - memory
	// - disk
	MetricType           string   `protobuf:"bytes,5,opt,name=metric_type,json=metricType,proto3" json:"metric_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for getting deployment metrics

func (*GetDeploymentMetricsRequest) Descriptor added in v0.84.0 

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

func (*GetDeploymentMetricsRequest) GetDeploymentId added in v0.84.0 

func (m *GetDeploymentMetricsRequest) GetDeploymentId() string

func (*GetDeploymentMetricsRequest) GetEndAt added in v0.84.0 

func (m *GetDeploymentMetricsRequest) GetEndAt() *types.Timestamp

func (*GetDeploymentMetricsRequest) GetMetricType added in v0.84.0 

func (m *GetDeploymentMetricsRequest) GetMetricType() string

func (*GetDeploymentMetricsRequest) GetServerType added in v0.84.0 

func (m *GetDeploymentMetricsRequest) GetServerType() string

func (*GetDeploymentMetricsRequest) GetStartAt added in v0.84.0 

func (m *GetDeploymentMetricsRequest) GetStartAt() *types.Timestamp

func (*GetDeploymentMetricsRequest) Marshal added in v0.84.0 

func (m *GetDeploymentMetricsRequest) Marshal() (dAtA []byte, err error)

func (*GetDeploymentMetricsRequest) MarshalTo added in v0.84.0 

func (m *GetDeploymentMetricsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetDeploymentMetricsRequest) MarshalToSizedBuffer added in v0.84.0 

func (m *GetDeploymentMetricsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDeploymentMetricsRequest) ProtoMessage added in v0.84.0 

func (*GetDeploymentMetricsRequest) ProtoMessage()

func (*GetDeploymentMetricsRequest) Reset added in v0.84.0 

func (m *GetDeploymentMetricsRequest) Reset()

func (*GetDeploymentMetricsRequest) Size added in v0.84.0 

func (m *GetDeploymentMetricsRequest) Size() (n int)

func (*GetDeploymentMetricsRequest) String added in v0.84.0 

func (m *GetDeploymentMetricsRequest) String() string

func (*GetDeploymentMetricsRequest) Unmarshal added in v0.84.0 

func (m *GetDeploymentMetricsRequest) Unmarshal(dAtA []byte) error

func (*GetDeploymentMetricsRequest) XXX_DiscardUnknown added in v0.84.0 

func (m *GetDeploymentMetricsRequest) XXX_DiscardUnknown()

func (*GetDeploymentMetricsRequest) XXX_Marshal added in v0.84.0 

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

func (*GetDeploymentMetricsRequest) XXX_Merge added in v0.84.0 

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

func (*GetDeploymentMetricsRequest) XXX_Size added in v0.84.0 

func (m *GetDeploymentMetricsRequest) XXX_Size() int

func (*GetDeploymentMetricsRequest) XXX_Unmarshal added in v0.84.0 

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

type MonitoringServiceClient 

type MonitoringServiceClient interface {
	// Get the current API version of this service.
	// Required permissions:
	// - None
	GetAPIVersion(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*v1.Version, error)
	// Fetch all logs of the deployment that matches the given request.
	// Required permissions:
	// - monitoring.logs.get on the deployment identified by the given deployment ID.
	GetDeploymentLogs(ctx context.Context, in *GetDeploymentLogsRequest, opts ...grpc.CallOption) (MonitoringService_GetDeploymentLogsClient, error)
	// Get the usage metrics for the deployment based on the given request.
	// Note: Only at most 1 week worth of data may be requested.
	// Required permissions:
	// - monitoring.metrics.get on the deployment identified by the given deployment ID.
	GetDeploymentUsageMetrics(ctx context.Context, in *GetDeploymentMetricsRequest, opts ...grpc.CallOption) (*DeploymentMetrics, error)
}

MonitoringServiceClient is the client API for MonitoringService service.

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

func NewMonitoringServiceClient 

func NewMonitoringServiceClient(cc *grpc.ClientConn) MonitoringServiceClient

type MonitoringServiceServer 

type MonitoringServiceServer interface {
	// Get the current API version of this service.
	// Required permissions:
	// - None
	GetAPIVersion(context.Context, *v1.Empty) (*v1.Version, error)
	// Fetch all logs of the deployment that matches the given request.
	// Required permissions:
	// - monitoring.logs.get on the deployment identified by the given deployment ID.
	GetDeploymentLogs(*GetDeploymentLogsRequest, MonitoringService_GetDeploymentLogsServer) error
	// Get the usage metrics for the deployment based on the given request.
	// Note: Only at most 1 week worth of data may be requested.
	// Required permissions:
	// - monitoring.metrics.get on the deployment identified by the given deployment ID.
	GetDeploymentUsageMetrics(context.Context, *GetDeploymentMetricsRequest) (*DeploymentMetrics, error)
}

MonitoringServiceServer is the server API for MonitoringService service.

type MonitoringService_GetDeploymentLogsClient 

type MonitoringService_GetDeploymentLogsClient interface {
	Recv() (*DeploymentLogsChunk, error)
	grpc.ClientStream
}

type MonitoringService_GetDeploymentLogsServer 

type MonitoringService_GetDeploymentLogsServer interface {
	Send(*DeploymentLogsChunk) error
	grpc.ServerStream
}

type UnimplementedMonitoringServiceServer 

type UnimplementedMonitoringServiceServer struct {
}

UnimplementedMonitoringServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMonitoringServiceServer) GetAPIVersion 

func (*UnimplementedMonitoringServiceServer) GetAPIVersion(ctx context.Context, req *v1.Empty) (*v1.Version, error)

func (*UnimplementedMonitoringServiceServer) GetDeploymentLogs 

func (*UnimplementedMonitoringServiceServer) GetDeploymentLogs(req *GetDeploymentLogsRequest, srv MonitoringService_GetDeploymentLogsServer) error

func (*UnimplementedMonitoringServiceServer) GetDeploymentUsageMetrics added in v0.84.0 

func (*UnimplementedMonitoringServiceServer) GetDeploymentUsageMetrics(ctx context.Context, req *GetDeploymentMetricsRequest) (*DeploymentMetrics, error)

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.