serverpb

package
v2.11.1+incompatible Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2020 License: AGPL-3.0 Imports: 22 Imported by: 0

Documentation

Overview

Package serverpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	DistributionMethod_name = map[int32]string{
		0: "DISTRIBUTION_METHOD_INVALID",
		1: "DOCKER",
		2: "OVF",
		3: "AMI",
	}
	DistributionMethod_value = map[string]int32{
		"DISTRIBUTION_METHOD_INVALID": 0,
		"DOCKER":                      1,
		"OVF":                         2,
		"AMI":                         3,
	}
)

Enum value maps for DistributionMethod.

View Source 
var File_serverpb_server_proto protoreflect.FileDescriptor

Functions

func RegisterServerHandler 

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

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

func RegisterServerHandlerClient 

func RegisterServerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ServerClient) error

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

func RegisterServerHandlerFromEndpoint 

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

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

func RegisterServerHandlerServer 

func RegisterServerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ServerServer) error

RegisterServerHandlerServer registers the http handlers for service Server to "mux". UnaryRPC :call ServerServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterServerHandlerFromEndpoint instead.

func RegisterServerServer 

func RegisterServerServer(s *grpc.Server, srv ServerServer)

Types

type AWSInstanceCheckRequest 

type AWSInstanceCheckRequest struct {

	// AWS EC2 instance ID (i-1234567890abcdef0).
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AWSInstanceCheckRequest) Descriptor deprecated 

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

Deprecated: Use AWSInstanceCheckRequest.ProtoReflect.Descriptor instead.

func (*AWSInstanceCheckRequest) GetInstanceId 

func (x *AWSInstanceCheckRequest) GetInstanceId() string

func (*AWSInstanceCheckRequest) ProtoMessage 

func (*AWSInstanceCheckRequest) ProtoMessage()

func (*AWSInstanceCheckRequest) ProtoReflect 

func (x *AWSInstanceCheckRequest) ProtoReflect() protoreflect.Message

func (*AWSInstanceCheckRequest) Reset 

func (x *AWSInstanceCheckRequest) Reset()

func (*AWSInstanceCheckRequest) String 

func (x *AWSInstanceCheckRequest) String() string

func (*AWSInstanceCheckRequest) Validate 

func (this *AWSInstanceCheckRequest) Validate() error

type AWSInstanceCheckResponse 

type AWSInstanceCheckResponse struct {
	// contains filtered or unexported fields
}

func (*AWSInstanceCheckResponse) Descriptor deprecated 

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

Deprecated: Use AWSInstanceCheckResponse.ProtoReflect.Descriptor instead.

func (*AWSInstanceCheckResponse) ProtoMessage 

func (*AWSInstanceCheckResponse) ProtoMessage()

func (*AWSInstanceCheckResponse) ProtoReflect 

func (x *AWSInstanceCheckResponse) ProtoReflect() protoreflect.Message

func (*AWSInstanceCheckResponse) Reset 

func (x *AWSInstanceCheckResponse) Reset()

func (*AWSInstanceCheckResponse) String 

func (x *AWSInstanceCheckResponse) String() string

func (*AWSInstanceCheckResponse) Validate 

func (this *AWSInstanceCheckResponse) Validate() error

type ChangeSettingsRequest 

type ChangeSettingsRequest struct {
	EnableTelemetry    bool                `protobuf:"varint,1,opt,name=enable_telemetry,json=enableTelemetry,proto3" json:"enable_telemetry,omitempty"`
	DisableTelemetry   bool                `protobuf:"varint,2,opt,name=disable_telemetry,json=disableTelemetry,proto3" json:"disable_telemetry,omitempty"`
	MetricsResolutions *MetricsResolutions `protobuf:"bytes,3,opt,name=metrics_resolutions,json=metricsResolutions,proto3" json:"metrics_resolutions,omitempty"`
	// A number of full days for Prometheus and QAN data retention. Should have a suffix in JSON: 2592000s, 43200m, 720h.
	DataRetention *duration.Duration `protobuf:"bytes,4,opt,name=data_retention,json=dataRetention,proto3" json:"data_retention,omitempty"`
	SshKey        string             `protobuf:"bytes,5,opt,name=ssh_key,json=sshKey,proto3" json:"ssh_key,omitempty"`
	AwsPartitions []string           `protobuf:"bytes,6,rep,name=aws_partitions,json=awsPartitions,proto3" json:"aws_partitions,omitempty"`
	// Prometheus AlertManager URL (e.g., https://username:password@1.2.3.4/path).
	AlertManagerUrl         string `protobuf:"bytes,7,opt,name=alert_manager_url,json=alertManagerUrl,proto3" json:"alert_manager_url,omitempty"`
	RemoveAlertManagerUrl   bool   `` /* 129-byte string literal not displayed */
	AlertManagerRules       string `protobuf:"bytes,9,opt,name=alert_manager_rules,json=alertManagerRules,proto3" json:"alert_manager_rules,omitempty"`
	RemoveAlertManagerRules bool   `` /* 136-byte string literal not displayed */
	// Enable Security Threat Tool
	EnableStt bool `protobuf:"varint,11,opt,name=enable_stt,json=enableStt,proto3" json:"enable_stt,omitempty"`
	// Disable Security Threat Tool
	DisableStt bool `protobuf:"varint,12,opt,name=disable_stt,json=disableStt,proto3" json:"disable_stt,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeSettingsRequest) Descriptor deprecated 

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

Deprecated: Use ChangeSettingsRequest.ProtoReflect.Descriptor instead.

func (*ChangeSettingsRequest) GetAlertManagerRules 

func (x *ChangeSettingsRequest) GetAlertManagerRules() string

func (*ChangeSettingsRequest) GetAlertManagerUrl 

func (x *ChangeSettingsRequest) GetAlertManagerUrl() string

func (*ChangeSettingsRequest) GetAwsPartitions 

func (x *ChangeSettingsRequest) GetAwsPartitions() []string

func (*ChangeSettingsRequest) GetDataRetention 

func (x *ChangeSettingsRequest) GetDataRetention() *duration.Duration

func (*ChangeSettingsRequest) GetDisableStt 

func (x *ChangeSettingsRequest) GetDisableStt() bool

func (*ChangeSettingsRequest) GetDisableTelemetry 

func (x *ChangeSettingsRequest) GetDisableTelemetry() bool

func (*ChangeSettingsRequest) GetEnableStt 

func (x *ChangeSettingsRequest) GetEnableStt() bool

func (*ChangeSettingsRequest) GetEnableTelemetry 

func (x *ChangeSettingsRequest) GetEnableTelemetry() bool

func (*ChangeSettingsRequest) GetMetricsResolutions 

func (x *ChangeSettingsRequest) GetMetricsResolutions() *MetricsResolutions

func (*ChangeSettingsRequest) GetRemoveAlertManagerRules 

func (x *ChangeSettingsRequest) GetRemoveAlertManagerRules() bool

func (*ChangeSettingsRequest) GetRemoveAlertManagerUrl 

func (x *ChangeSettingsRequest) GetRemoveAlertManagerUrl() bool

func (*ChangeSettingsRequest) GetSshKey 

func (x *ChangeSettingsRequest) GetSshKey() string

func (*ChangeSettingsRequest) ProtoMessage 

func (*ChangeSettingsRequest) ProtoMessage()

func (*ChangeSettingsRequest) ProtoReflect 

func (x *ChangeSettingsRequest) ProtoReflect() protoreflect.Message

func (*ChangeSettingsRequest) Reset 

func (x *ChangeSettingsRequest) Reset()

func (*ChangeSettingsRequest) String 

func (x *ChangeSettingsRequest) String() string

func (*ChangeSettingsRequest) Validate 

func (this *ChangeSettingsRequest) Validate() error

type ChangeSettingsResponse 

type ChangeSettingsResponse struct {
	Settings *Settings `protobuf:"bytes,1,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeSettingsResponse) Descriptor deprecated 

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

Deprecated: Use ChangeSettingsResponse.ProtoReflect.Descriptor instead.

func (*ChangeSettingsResponse) GetSettings 

func (x *ChangeSettingsResponse) GetSettings() *Settings

func (*ChangeSettingsResponse) ProtoMessage 

func (*ChangeSettingsResponse) ProtoMessage()

func (*ChangeSettingsResponse) ProtoReflect 

func (x *ChangeSettingsResponse) ProtoReflect() protoreflect.Message

func (*ChangeSettingsResponse) Reset 

func (x *ChangeSettingsResponse) Reset()

func (*ChangeSettingsResponse) String 

func (x *ChangeSettingsResponse) String() string

func (*ChangeSettingsResponse) Validate 

func (this *ChangeSettingsResponse) Validate() error

type CheckUpdatesRequest 

type CheckUpdatesRequest struct {

	// If false, cached information may be returned.
	Force bool `protobuf:"varint,1,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckUpdatesRequest) Descriptor deprecated 

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

Deprecated: Use CheckUpdatesRequest.ProtoReflect.Descriptor instead.

func (*CheckUpdatesRequest) GetForce 

func (x *CheckUpdatesRequest) GetForce() bool

func (*CheckUpdatesRequest) ProtoMessage 

func (*CheckUpdatesRequest) ProtoMessage()

func (*CheckUpdatesRequest) ProtoReflect 

func (x *CheckUpdatesRequest) ProtoReflect() protoreflect.Message

func (*CheckUpdatesRequest) Reset 

func (x *CheckUpdatesRequest) Reset()

func (*CheckUpdatesRequest) String 

func (x *CheckUpdatesRequest) String() string

func (*CheckUpdatesRequest) Validate 

func (this *CheckUpdatesRequest) Validate() error

type CheckUpdatesResponse 

type CheckUpdatesResponse struct {

	// Currently installed PMM Server version.
	Installed *VersionInfo `protobuf:"bytes,1,opt,name=installed,proto3" json:"installed,omitempty"`
	// Latest available PMM Server version.
	Latest *VersionInfo `protobuf:"bytes,2,opt,name=latest,proto3" json:"latest,omitempty"`
	// True if there is a PMM Server update available.
	UpdateAvailable bool `protobuf:"varint,3,opt,name=update_available,json=updateAvailable,proto3" json:"update_available,omitempty"`
	// Latest available PMM Server release announcement URL.
	LatestNewsUrl string `protobuf:"bytes,4,opt,name=latest_news_url,json=latestNewsUrl,proto3" json:"latest_news_url,omitempty"`
	// Last check time.
	LastCheck *timestamp.Timestamp `protobuf:"bytes,5,opt,name=last_check,json=lastCheck,proto3" json:"last_check,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckUpdatesResponse) Descriptor deprecated 

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

Deprecated: Use CheckUpdatesResponse.ProtoReflect.Descriptor instead.

func (*CheckUpdatesResponse) GetInstalled 

func (x *CheckUpdatesResponse) GetInstalled() *VersionInfo

func (*CheckUpdatesResponse) GetLastCheck 

func (x *CheckUpdatesResponse) GetLastCheck() *timestamp.Timestamp

func (*CheckUpdatesResponse) GetLatest 

func (x *CheckUpdatesResponse) GetLatest() *VersionInfo

func (*CheckUpdatesResponse) GetLatestNewsUrl 

func (x *CheckUpdatesResponse) GetLatestNewsUrl() string

func (*CheckUpdatesResponse) GetUpdateAvailable 

func (x *CheckUpdatesResponse) GetUpdateAvailable() bool

func (*CheckUpdatesResponse) ProtoMessage 

func (*CheckUpdatesResponse) ProtoMessage()

func (*CheckUpdatesResponse) ProtoReflect 

func (x *CheckUpdatesResponse) ProtoReflect() protoreflect.Message

func (*CheckUpdatesResponse) Reset 

func (x *CheckUpdatesResponse) Reset()

func (*CheckUpdatesResponse) String 

func (x *CheckUpdatesResponse) String() string

func (*CheckUpdatesResponse) Validate 

func (this *CheckUpdatesResponse) Validate() error

type DistributionMethod 

type DistributionMethod int32

DistributionMethod defines PMM Server distribution method: Docker image, OVF/OVA, or AMI. 

const (
	DistributionMethod_DISTRIBUTION_METHOD_INVALID DistributionMethod = 0
	DistributionMethod_DOCKER                      DistributionMethod = 1
	DistributionMethod_OVF                         DistributionMethod = 2
	DistributionMethod_AMI                         DistributionMethod = 3
)

func (DistributionMethod) Descriptor 

func (DistributionMethod) Descriptor() protoreflect.EnumDescriptor

func (DistributionMethod) Enum 

func (x DistributionMethod) Enum() *DistributionMethod

func (DistributionMethod) EnumDescriptor deprecated 

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

Deprecated: Use DistributionMethod.Descriptor instead.

func (DistributionMethod) Number 

func (x DistributionMethod) Number() protoreflect.EnumNumber

func (DistributionMethod) String 

func (x DistributionMethod) String() string

func (DistributionMethod) Type 

func (DistributionMethod) Type() protoreflect.EnumType

type GetSettingsRequest 

type GetSettingsRequest struct {
	// contains filtered or unexported fields
}

func (*GetSettingsRequest) Descriptor deprecated 

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

Deprecated: Use GetSettingsRequest.ProtoReflect.Descriptor instead.

func (*GetSettingsRequest) ProtoMessage 

func (*GetSettingsRequest) ProtoMessage()

func (*GetSettingsRequest) ProtoReflect 

func (x *GetSettingsRequest) ProtoReflect() protoreflect.Message

func (*GetSettingsRequest) Reset 

func (x *GetSettingsRequest) Reset()

func (*GetSettingsRequest) String 

func (x *GetSettingsRequest) String() string

func (*GetSettingsRequest) Validate 

func (this *GetSettingsRequest) Validate() error

type GetSettingsResponse 

type GetSettingsResponse struct {
	Settings *Settings `protobuf:"bytes,1,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSettingsResponse) Descriptor deprecated 

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

Deprecated: Use GetSettingsResponse.ProtoReflect.Descriptor instead.

func (*GetSettingsResponse) GetSettings 

func (x *GetSettingsResponse) GetSettings() *Settings

func (*GetSettingsResponse) ProtoMessage 

func (*GetSettingsResponse) ProtoMessage()

func (*GetSettingsResponse) ProtoReflect 

func (x *GetSettingsResponse) ProtoReflect() protoreflect.Message

func (*GetSettingsResponse) Reset 

func (x *GetSettingsResponse) Reset()

func (*GetSettingsResponse) String 

func (x *GetSettingsResponse) String() string

func (*GetSettingsResponse) Validate 

func (this *GetSettingsResponse) Validate() error

type MetricsResolutions 

type MetricsResolutions struct {

	// High resolution. Should have a suffix in JSON: 1s, 1m, 1h.
	Hr *duration.Duration `protobuf:"bytes,1,opt,name=hr,proto3" json:"hr,omitempty"`
	// Medium resolution. Should have a suffix in JSON: 1s, 1m, 1h.
	Mr *duration.Duration `protobuf:"bytes,2,opt,name=mr,proto3" json:"mr,omitempty"`
	// Low resolution. Should have a suffix in JSON: 1s, 1m, 1h.
	Lr *duration.Duration `protobuf:"bytes,3,opt,name=lr,proto3" json:"lr,omitempty"`
	// contains filtered or unexported fields
}

MetricsResolutions represents Prometheus exporters metrics resolutions.

func (*MetricsResolutions) Descriptor deprecated 

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

Deprecated: Use MetricsResolutions.ProtoReflect.Descriptor instead.

func (*MetricsResolutions) GetHr 

func (x *MetricsResolutions) GetHr() *duration.Duration

func (*MetricsResolutions) GetLr 

func (x *MetricsResolutions) GetLr() *duration.Duration

func (*MetricsResolutions) GetMr 

func (x *MetricsResolutions) GetMr() *duration.Duration

func (*MetricsResolutions) ProtoMessage 

func (*MetricsResolutions) ProtoMessage()

func (*MetricsResolutions) ProtoReflect 

func (x *MetricsResolutions) ProtoReflect() protoreflect.Message

func (*MetricsResolutions) Reset 

func (x *MetricsResolutions) Reset()

func (*MetricsResolutions) String 

func (x *MetricsResolutions) String() string

func (*MetricsResolutions) Validate 

func (this *MetricsResolutions) Validate() error

type PlatformSignInRequest 

type PlatformSignInRequest struct {

	// Existing Percona Platform user's email.
	Email string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	// Existing Percona Platform user's password.
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*PlatformSignInRequest) Descriptor deprecated 

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

Deprecated: Use PlatformSignInRequest.ProtoReflect.Descriptor instead.

func (*PlatformSignInRequest) GetEmail 

func (x *PlatformSignInRequest) GetEmail() string

func (*PlatformSignInRequest) GetPassword 

func (x *PlatformSignInRequest) GetPassword() string

func (*PlatformSignInRequest) ProtoMessage 

func (*PlatformSignInRequest) ProtoMessage()

func (*PlatformSignInRequest) ProtoReflect 

func (x *PlatformSignInRequest) ProtoReflect() protoreflect.Message

func (*PlatformSignInRequest) Reset 

func (x *PlatformSignInRequest) Reset()

func (*PlatformSignInRequest) String 

func (x *PlatformSignInRequest) String() string

func (*PlatformSignInRequest) Validate 

func (this *PlatformSignInRequest) Validate() error

type PlatformSignInResponse 

type PlatformSignInResponse struct {
	// contains filtered or unexported fields
}

func (*PlatformSignInResponse) Descriptor deprecated 

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

Deprecated: Use PlatformSignInResponse.ProtoReflect.Descriptor instead.

func (*PlatformSignInResponse) ProtoMessage 

func (*PlatformSignInResponse) ProtoMessage()

func (*PlatformSignInResponse) ProtoReflect 

func (x *PlatformSignInResponse) ProtoReflect() protoreflect.Message

func (*PlatformSignInResponse) Reset 

func (x *PlatformSignInResponse) Reset()

func (*PlatformSignInResponse) String 

func (x *PlatformSignInResponse) String() string

func (*PlatformSignInResponse) Validate 

func (this *PlatformSignInResponse) Validate() error

type PlatformSignOutRequest 

type PlatformSignOutRequest struct {
	// contains filtered or unexported fields
}

func (*PlatformSignOutRequest) Descriptor deprecated 

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

Deprecated: Use PlatformSignOutRequest.ProtoReflect.Descriptor instead.

func (*PlatformSignOutRequest) ProtoMessage 

func (*PlatformSignOutRequest) ProtoMessage()

func (*PlatformSignOutRequest) ProtoReflect 

func (x *PlatformSignOutRequest) ProtoReflect() protoreflect.Message

func (*PlatformSignOutRequest) Reset 

func (x *PlatformSignOutRequest) Reset()

func (*PlatformSignOutRequest) String 

func (x *PlatformSignOutRequest) String() string

func (*PlatformSignOutRequest) Validate 

func (this *PlatformSignOutRequest) Validate() error

type PlatformSignOutResponse 

type PlatformSignOutResponse struct {
	// contains filtered or unexported fields
}

func (*PlatformSignOutResponse) Descriptor deprecated 

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

Deprecated: Use PlatformSignOutResponse.ProtoReflect.Descriptor instead.

func (*PlatformSignOutResponse) ProtoMessage 

func (*PlatformSignOutResponse) ProtoMessage()

func (*PlatformSignOutResponse) ProtoReflect 

func (x *PlatformSignOutResponse) ProtoReflect() protoreflect.Message

func (*PlatformSignOutResponse) Reset 

func (x *PlatformSignOutResponse) Reset()

func (*PlatformSignOutResponse) String 

func (x *PlatformSignOutResponse) String() string

func (*PlatformSignOutResponse) Validate 

func (this *PlatformSignOutResponse) Validate() error

type PlatformSignUpRequest 

type PlatformSignUpRequest struct {

	// New Percona Platform user's email.
	Email string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	// New Percona Platform user's password.
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*PlatformSignUpRequest) Descriptor deprecated 

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

Deprecated: Use PlatformSignUpRequest.ProtoReflect.Descriptor instead.

func (*PlatformSignUpRequest) GetEmail 

func (x *PlatformSignUpRequest) GetEmail() string

func (*PlatformSignUpRequest) GetPassword 

func (x *PlatformSignUpRequest) GetPassword() string

func (*PlatformSignUpRequest) ProtoMessage 

func (*PlatformSignUpRequest) ProtoMessage()

func (*PlatformSignUpRequest) ProtoReflect 

func (x *PlatformSignUpRequest) ProtoReflect() protoreflect.Message

func (*PlatformSignUpRequest) Reset 

func (x *PlatformSignUpRequest) Reset()

func (*PlatformSignUpRequest) String 

func (x *PlatformSignUpRequest) String() string

func (*PlatformSignUpRequest) Validate 

func (this *PlatformSignUpRequest) Validate() error

type PlatformSignUpResponse 

type PlatformSignUpResponse struct {
	// contains filtered or unexported fields
}

func (*PlatformSignUpResponse) Descriptor deprecated 

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

Deprecated: Use PlatformSignUpResponse.ProtoReflect.Descriptor instead.

func (*PlatformSignUpResponse) ProtoMessage 

func (*PlatformSignUpResponse) ProtoMessage()

func (*PlatformSignUpResponse) ProtoReflect 

func (x *PlatformSignUpResponse) ProtoReflect() protoreflect.Message

func (*PlatformSignUpResponse) Reset 

func (x *PlatformSignUpResponse) Reset()

func (*PlatformSignUpResponse) String 

func (x *PlatformSignUpResponse) String() string

func (*PlatformSignUpResponse) Validate 

func (this *PlatformSignUpResponse) Validate() error

type ReadinessRequest 

type ReadinessRequest struct {
	// contains filtered or unexported fields
}

func (*ReadinessRequest) Descriptor deprecated 

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

Deprecated: Use ReadinessRequest.ProtoReflect.Descriptor instead.

func (*ReadinessRequest) ProtoMessage 

func (*ReadinessRequest) ProtoMessage()

func (*ReadinessRequest) ProtoReflect 

func (x *ReadinessRequest) ProtoReflect() protoreflect.Message

func (*ReadinessRequest) Reset 

func (x *ReadinessRequest) Reset()

func (*ReadinessRequest) String 

func (x *ReadinessRequest) String() string

func (*ReadinessRequest) Validate 

func (this *ReadinessRequest) Validate() error

type ReadinessResponse 

type ReadinessResponse struct {
	// contains filtered or unexported fields
}

func (*ReadinessResponse) Descriptor deprecated 

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

Deprecated: Use ReadinessResponse.ProtoReflect.Descriptor instead.

func (*ReadinessResponse) ProtoMessage 

func (*ReadinessResponse) ProtoMessage()

func (*ReadinessResponse) ProtoReflect 

func (x *ReadinessResponse) ProtoReflect() protoreflect.Message

func (*ReadinessResponse) Reset 

func (x *ReadinessResponse) Reset()

func (*ReadinessResponse) String 

func (x *ReadinessResponse) String() string

func (*ReadinessResponse) Validate 

func (this *ReadinessResponse) Validate() error

type ServerClient 

type ServerClient interface {
	// Version returns PMM Server versions.
	Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
	// Readiness returns an error when some PMM Server component is not ready yet or is being restarted.
	// It can be used as for Docker health check or Kubernetes readiness probe.
	Readiness(ctx context.Context, in *ReadinessRequest, opts ...grpc.CallOption) (*ReadinessResponse, error)
	// CheckUpdates checks PMM Server updates availability.
	CheckUpdates(ctx context.Context, in *CheckUpdatesRequest, opts ...grpc.CallOption) (*CheckUpdatesResponse, error)
	// StartUpdate starts PMM Server update.
	StartUpdate(ctx context.Context, in *StartUpdateRequest, opts ...grpc.CallOption) (*StartUpdateResponse, error)
	// UpdateStatus returns PMM Server update status.
	UpdateStatus(ctx context.Context, in *UpdateStatusRequest, opts ...grpc.CallOption) (*UpdateStatusResponse, error)
	// GetSettings returns current PMM Server settings.
	GetSettings(ctx context.Context, in *GetSettingsRequest, opts ...grpc.CallOption) (*GetSettingsResponse, error)
	// ChangeSettings changes PMM Server settings.
	ChangeSettings(ctx context.Context, in *ChangeSettingsRequest, opts ...grpc.CallOption) (*ChangeSettingsResponse, error)
	// AWSInstanceCheck checks AWS EC2 instance ID.
	AWSInstanceCheck(ctx context.Context, in *AWSInstanceCheckRequest, opts ...grpc.CallOption) (*AWSInstanceCheckResponse, error)
	// PlatformSignUp creates a new Percona Platform user.
	PlatformSignUp(ctx context.Context, in *PlatformSignUpRequest, opts ...grpc.CallOption) (*PlatformSignUpResponse, error)
	// PlatformSignIn links that PMM instance to Percona Platform user.
	PlatformSignIn(ctx context.Context, in *PlatformSignInRequest, opts ...grpc.CallOption) (*PlatformSignInResponse, error)
	// PlatformSignOut logouts this PMM instance from Percona Platform account.
	PlatformSignOut(ctx context.Context, in *PlatformSignOutRequest, opts ...grpc.CallOption) (*PlatformSignOutResponse, error)
}

ServerClient is the client API for Server service.

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

func NewServerClient 

func NewServerClient(cc grpc.ClientConnInterface) ServerClient

type ServerServer 

type ServerServer interface {
	// Version returns PMM Server versions.
	Version(context.Context, *VersionRequest) (*VersionResponse, error)
	// Readiness returns an error when some PMM Server component is not ready yet or is being restarted.
	// It can be used as for Docker health check or Kubernetes readiness probe.
	Readiness(context.Context, *ReadinessRequest) (*ReadinessResponse, error)
	// CheckUpdates checks PMM Server updates availability.
	CheckUpdates(context.Context, *CheckUpdatesRequest) (*CheckUpdatesResponse, error)
	// StartUpdate starts PMM Server update.
	StartUpdate(context.Context, *StartUpdateRequest) (*StartUpdateResponse, error)
	// UpdateStatus returns PMM Server update status.
	UpdateStatus(context.Context, *UpdateStatusRequest) (*UpdateStatusResponse, error)
	// GetSettings returns current PMM Server settings.
	GetSettings(context.Context, *GetSettingsRequest) (*GetSettingsResponse, error)
	// ChangeSettings changes PMM Server settings.
	ChangeSettings(context.Context, *ChangeSettingsRequest) (*ChangeSettingsResponse, error)
	// AWSInstanceCheck checks AWS EC2 instance ID.
	AWSInstanceCheck(context.Context, *AWSInstanceCheckRequest) (*AWSInstanceCheckResponse, error)
	// PlatformSignUp creates a new Percona Platform user.
	PlatformSignUp(context.Context, *PlatformSignUpRequest) (*PlatformSignUpResponse, error)
	// PlatformSignIn links that PMM instance to Percona Platform user.
	PlatformSignIn(context.Context, *PlatformSignInRequest) (*PlatformSignInResponse, error)
	// PlatformSignOut logouts this PMM instance from Percona Platform account.
	PlatformSignOut(context.Context, *PlatformSignOutRequest) (*PlatformSignOutResponse, error)
}

ServerServer is the server API for Server service.

type Settings 

type Settings struct {
	UpdatesDisabled    bool                `protobuf:"varint,1,opt,name=updates_disabled,json=updatesDisabled,proto3" json:"updates_disabled,omitempty"`
	TelemetryEnabled   bool                `protobuf:"varint,2,opt,name=telemetry_enabled,json=telemetryEnabled,proto3" json:"telemetry_enabled,omitempty"`
	MetricsResolutions *MetricsResolutions `protobuf:"bytes,3,opt,name=metrics_resolutions,json=metricsResolutions,proto3" json:"metrics_resolutions,omitempty"`
	DataRetention      *duration.Duration  `protobuf:"bytes,4,opt,name=data_retention,json=dataRetention,proto3" json:"data_retention,omitempty"`
	SshKey             string              `protobuf:"bytes,5,opt,name=ssh_key,json=sshKey,proto3" json:"ssh_key,omitempty"`
	AwsPartitions      []string            `protobuf:"bytes,6,rep,name=aws_partitions,json=awsPartitions,proto3" json:"aws_partitions,omitempty"`
	// Prometheus AlertManager URL (e.g., https://username:password@1.2.3.4/path).
	AlertManagerUrl   string `protobuf:"bytes,7,opt,name=alert_manager_url,json=alertManagerUrl,proto3" json:"alert_manager_url,omitempty"`
	AlertManagerRules string `protobuf:"bytes,8,opt,name=alert_manager_rules,json=alertManagerRules,proto3" json:"alert_manager_rules,omitempty"`
	// Security Threat Tool enabled
	SttEnabled bool `protobuf:"varint,9,opt,name=stt_enabled,json=sttEnabled,proto3" json:"stt_enabled,omitempty"`
	// Percona Platform user's email, if this PMM instance is linked to the Platform.
	PlatformEmail string `protobuf:"bytes,10,opt,name=platform_email,json=platformEmail,proto3" json:"platform_email,omitempty"`
	// DBaaS enabled
	DbaasEnabled bool `protobuf:"varint,11,opt,name=dbaas_enabled,json=dbaasEnabled,proto3" json:"dbaas_enabled,omitempty"`
	// contains filtered or unexported fields
}

Settings represents PMM Server settings.

func (*Settings) Descriptor deprecated 

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

Deprecated: Use Settings.ProtoReflect.Descriptor instead.

func (*Settings) GetAlertManagerRules 

func (x *Settings) GetAlertManagerRules() string

func (*Settings) GetAlertManagerUrl 

func (x *Settings) GetAlertManagerUrl() string

func (*Settings) GetAwsPartitions 

func (x *Settings) GetAwsPartitions() []string

func (*Settings) GetDataRetention 

func (x *Settings) GetDataRetention() *duration.Duration

func (*Settings) GetDbaasEnabled 

func (x *Settings) GetDbaasEnabled() bool

func (*Settings) GetMetricsResolutions 

func (x *Settings) GetMetricsResolutions() *MetricsResolutions

func (*Settings) GetPlatformEmail 

func (x *Settings) GetPlatformEmail() string

func (*Settings) GetSshKey 

func (x *Settings) GetSshKey() string

func (*Settings) GetSttEnabled 

func (x *Settings) GetSttEnabled() bool

func (*Settings) GetTelemetryEnabled 

func (x *Settings) GetTelemetryEnabled() bool

func (*Settings) GetUpdatesDisabled 

func (x *Settings) GetUpdatesDisabled() bool

func (*Settings) ProtoMessage 

func (*Settings) ProtoMessage()

func (*Settings) ProtoReflect 

func (x *Settings) ProtoReflect() protoreflect.Message

func (*Settings) Reset 

func (x *Settings) Reset()

func (*Settings) String 

func (x *Settings) String() string

func (*Settings) Validate 

func (this *Settings) Validate() error

type StartUpdateRequest 

type StartUpdateRequest struct {
	// contains filtered or unexported fields
}

func (*StartUpdateRequest) Descriptor deprecated 

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

Deprecated: Use StartUpdateRequest.ProtoReflect.Descriptor instead.

func (*StartUpdateRequest) ProtoMessage 

func (*StartUpdateRequest) ProtoMessage()

func (*StartUpdateRequest) ProtoReflect 

func (x *StartUpdateRequest) ProtoReflect() protoreflect.Message

func (*StartUpdateRequest) Reset 

func (x *StartUpdateRequest) Reset()

func (*StartUpdateRequest) String 

func (x *StartUpdateRequest) String() string

func (*StartUpdateRequest) Validate 

func (this *StartUpdateRequest) Validate() error

type StartUpdateResponse 

type StartUpdateResponse struct {

	// Authentication token for getting update statuses.
	AuthToken string `protobuf:"bytes,1,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
	// Progress log offset.
	LogOffset uint32 `protobuf:"varint,2,opt,name=log_offset,json=logOffset,proto3" json:"log_offset,omitempty"`
	// contains filtered or unexported fields
}

func (*StartUpdateResponse) Descriptor deprecated 

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

Deprecated: Use StartUpdateResponse.ProtoReflect.Descriptor instead.

func (*StartUpdateResponse) GetAuthToken 

func (x *StartUpdateResponse) GetAuthToken() string

func (*StartUpdateResponse) GetLogOffset 

func (x *StartUpdateResponse) GetLogOffset() uint32

func (*StartUpdateResponse) ProtoMessage 

func (*StartUpdateResponse) ProtoMessage()

func (*StartUpdateResponse) ProtoReflect 

func (x *StartUpdateResponse) ProtoReflect() protoreflect.Message

func (*StartUpdateResponse) Reset 

func (x *StartUpdateResponse) Reset()

func (*StartUpdateResponse) String 

func (x *StartUpdateResponse) String() string

func (*StartUpdateResponse) Validate 

func (this *StartUpdateResponse) Validate() error

type UnimplementedServerServer 

type UnimplementedServerServer struct {
}

UnimplementedServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedServerServer) AWSInstanceCheck 

func (*UnimplementedServerServer) AWSInstanceCheck(context.Context, *AWSInstanceCheckRequest) (*AWSInstanceCheckResponse, error)

func (*UnimplementedServerServer) ChangeSettings 

func (*UnimplementedServerServer) ChangeSettings(context.Context, *ChangeSettingsRequest) (*ChangeSettingsResponse, error)

func (*UnimplementedServerServer) CheckUpdates 

func (*UnimplementedServerServer) CheckUpdates(context.Context, *CheckUpdatesRequest) (*CheckUpdatesResponse, error)

func (*UnimplementedServerServer) GetSettings 

func (*UnimplementedServerServer) GetSettings(context.Context, *GetSettingsRequest) (*GetSettingsResponse, error)

func (*UnimplementedServerServer) PlatformSignIn 

func (*UnimplementedServerServer) PlatformSignIn(context.Context, *PlatformSignInRequest) (*PlatformSignInResponse, error)

func (*UnimplementedServerServer) PlatformSignOut 

func (*UnimplementedServerServer) PlatformSignOut(context.Context, *PlatformSignOutRequest) (*PlatformSignOutResponse, error)

func (*UnimplementedServerServer) PlatformSignUp 

func (*UnimplementedServerServer) PlatformSignUp(context.Context, *PlatformSignUpRequest) (*PlatformSignUpResponse, error)

func (*UnimplementedServerServer) Readiness 

func (*UnimplementedServerServer) Readiness(context.Context, *ReadinessRequest) (*ReadinessResponse, error)

func (*UnimplementedServerServer) StartUpdate 

func (*UnimplementedServerServer) StartUpdate(context.Context, *StartUpdateRequest) (*StartUpdateResponse, error)

func (*UnimplementedServerServer) UpdateStatus 

func (*UnimplementedServerServer) UpdateStatus(context.Context, *UpdateStatusRequest) (*UpdateStatusResponse, error)

func (*UnimplementedServerServer) Version 

func (*UnimplementedServerServer) Version(context.Context, *VersionRequest) (*VersionResponse, error)

type UpdateStatusRequest 

type UpdateStatusRequest struct {

	// Authentication token.
	AuthToken string `protobuf:"bytes,1,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
	// Progress log offset.
	LogOffset uint32 `protobuf:"varint,2,opt,name=log_offset,json=logOffset,proto3" json:"log_offset,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateStatusRequest) Descriptor deprecated 

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

Deprecated: Use UpdateStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateStatusRequest) GetAuthToken 

func (x *UpdateStatusRequest) GetAuthToken() string

func (*UpdateStatusRequest) GetLogOffset 

func (x *UpdateStatusRequest) GetLogOffset() uint32

func (*UpdateStatusRequest) ProtoMessage 

func (*UpdateStatusRequest) ProtoMessage()

func (*UpdateStatusRequest) ProtoReflect 

func (x *UpdateStatusRequest) ProtoReflect() protoreflect.Message

func (*UpdateStatusRequest) Reset 

func (x *UpdateStatusRequest) Reset()

func (*UpdateStatusRequest) String 

func (x *UpdateStatusRequest) String() string

func (*UpdateStatusRequest) Validate 

func (this *UpdateStatusRequest) Validate() error

type UpdateStatusResponse 

type UpdateStatusResponse struct {

	// Progress log lines.
	LogLines []string `protobuf:"bytes,1,rep,name=log_lines,json=logLines,proto3" json:"log_lines,omitempty"`
	// Progress log offset for the next request.
	LogOffset uint32 `protobuf:"varint,2,opt,name=log_offset,json=logOffset,proto3" json:"log_offset,omitempty"`
	// True when update is done.
	Done bool `protobuf:"varint,3,opt,name=done,proto3" json:"done,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateStatusResponse) Descriptor deprecated 

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

Deprecated: Use UpdateStatusResponse.ProtoReflect.Descriptor instead.

func (*UpdateStatusResponse) GetDone 

func (x *UpdateStatusResponse) GetDone() bool

func (*UpdateStatusResponse) GetLogLines 

func (x *UpdateStatusResponse) GetLogLines() []string

func (*UpdateStatusResponse) GetLogOffset 

func (x *UpdateStatusResponse) GetLogOffset() uint32

func (*UpdateStatusResponse) ProtoMessage 

func (*UpdateStatusResponse) ProtoMessage()

func (*UpdateStatusResponse) ProtoReflect 

func (x *UpdateStatusResponse) ProtoReflect() protoreflect.Message

func (*UpdateStatusResponse) Reset 

func (x *UpdateStatusResponse) Reset()

func (*UpdateStatusResponse) String 

func (x *UpdateStatusResponse) String() string

func (*UpdateStatusResponse) Validate 

func (this *UpdateStatusResponse) Validate() error

type VersionInfo 

type VersionInfo struct {

	// User-visible version.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Full version for debugging.
	FullVersion string `protobuf:"bytes,2,opt,name=full_version,json=fullVersion,proto3" json:"full_version,omitempty"`
	// Build or release date.
	Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

VersionInfo describes component version, or PMM Server as a whole.

func (*VersionInfo) Descriptor deprecated 

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

Deprecated: Use VersionInfo.ProtoReflect.Descriptor instead.

func (*VersionInfo) GetFullVersion 

func (x *VersionInfo) GetFullVersion() string

func (*VersionInfo) GetTimestamp 

func (x *VersionInfo) GetTimestamp() *timestamp.Timestamp

func (*VersionInfo) GetVersion 

func (x *VersionInfo) GetVersion() string

func (*VersionInfo) ProtoMessage 

func (*VersionInfo) ProtoMessage()

func (*VersionInfo) ProtoReflect 

func (x *VersionInfo) ProtoReflect() protoreflect.Message

func (*VersionInfo) Reset 

func (x *VersionInfo) Reset()

func (*VersionInfo) String 

func (x *VersionInfo) String() string

func (*VersionInfo) Validate 

func (this *VersionInfo) Validate() error

type VersionRequest 

type VersionRequest struct {

	// Dummy parameter for internal testing. Do not use.
	Dummy string `protobuf:"bytes,1,opt,name=dummy,proto3" json:"dummy,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionRequest) Descriptor deprecated 

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

Deprecated: Use VersionRequest.ProtoReflect.Descriptor instead.

func (*VersionRequest) GetDummy 

func (x *VersionRequest) GetDummy() string

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) ProtoReflect 

func (x *VersionRequest) ProtoReflect() protoreflect.Message

func (*VersionRequest) Reset 

func (x *VersionRequest) Reset()

func (*VersionRequest) String 

func (x *VersionRequest) String() string

func (*VersionRequest) Validate 

func (this *VersionRequest) Validate() error

type VersionResponse 

type VersionResponse struct {

	// PMM Server version.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Detailed PMM Server version information.
	Server *VersionInfo `protobuf:"bytes,2,opt,name=server,proto3" json:"server,omitempty"`
	// pmm-managed version information for debugging.
	Managed *VersionInfo `protobuf:"bytes,3,opt,name=managed,proto3" json:"managed,omitempty"`
	// PMM Server distribution method.
	DistributionMethod DistributionMethod `` // TODO Versions and statuses of Grafana, Prometheus, PostgreSQL, qan-api2, ClickHouse, pmm-agent, etc.
	/* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*VersionResponse) Descriptor deprecated 

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetDistributionMethod 

func (x *VersionResponse) GetDistributionMethod() DistributionMethod

func (*VersionResponse) GetManaged 

func (x *VersionResponse) GetManaged() *VersionInfo

func (*VersionResponse) GetServer 

func (x *VersionResponse) GetServer() *VersionInfo

func (*VersionResponse) GetVersion 

func (x *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect 

func (x *VersionResponse) ProtoReflect() protoreflect.Message

func (*VersionResponse) Reset 

func (x *VersionResponse) Reset()

func (*VersionResponse) String 

func (x *VersionResponse) String() string

func (*VersionResponse) Validate 

func (this *VersionResponse) Validate() error

Source Files

View all Source files

Directories

Path Synopsis
json
client
client/server

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.