serverpb

package
v2.2.2+incompatible Latest Latest
Warning

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

 Go to latest Published: Jan 31, 2020 License: AGPL-3.0 Imports: 18 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",
}
View Source 
var DistributionMethod_value = map[string]int32{
	"DISTRIBUTION_METHOD_INVALID": 0,
	"DOCKER":                      1,
	"OVF":                         2,
	"AMI":                         3,
}

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.

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

func (*AWSInstanceCheckRequest) Descriptor 

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

func (*AWSInstanceCheckRequest) GetInstanceId 

func (m *AWSInstanceCheckRequest) GetInstanceId() string

func (*AWSInstanceCheckRequest) ProtoMessage 

func (*AWSInstanceCheckRequest) ProtoMessage()

func (*AWSInstanceCheckRequest) Reset 

func (m *AWSInstanceCheckRequest) Reset()

func (*AWSInstanceCheckRequest) String 

func (m *AWSInstanceCheckRequest) String() string

func (*AWSInstanceCheckRequest) Validate 

func (this *AWSInstanceCheckRequest) Validate() error

func (*AWSInstanceCheckRequest) XXX_DiscardUnknown 

func (m *AWSInstanceCheckRequest) XXX_DiscardUnknown()

func (*AWSInstanceCheckRequest) XXX_Marshal 

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

func (*AWSInstanceCheckRequest) XXX_Merge 

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

func (*AWSInstanceCheckRequest) XXX_Size 

func (m *AWSInstanceCheckRequest) XXX_Size() int

func (*AWSInstanceCheckRequest) XXX_Unmarshal 

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

type AWSInstanceCheckResponse 

type AWSInstanceCheckResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AWSInstanceCheckResponse) Descriptor 

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

func (*AWSInstanceCheckResponse) ProtoMessage 

func (*AWSInstanceCheckResponse) ProtoMessage()

func (*AWSInstanceCheckResponse) Reset 

func (m *AWSInstanceCheckResponse) Reset()

func (*AWSInstanceCheckResponse) String 

func (m *AWSInstanceCheckResponse) String() string

func (*AWSInstanceCheckResponse) Validate 

func (this *AWSInstanceCheckResponse) Validate() error

func (*AWSInstanceCheckResponse) XXX_DiscardUnknown 

func (m *AWSInstanceCheckResponse) XXX_DiscardUnknown()

func (*AWSInstanceCheckResponse) XXX_Marshal 

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

func (*AWSInstanceCheckResponse) XXX_Merge 

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

func (*AWSInstanceCheckResponse) XXX_Size 

func (m *AWSInstanceCheckResponse) XXX_Size() int

func (*AWSInstanceCheckResponse) XXX_Unmarshal 

func (m *AWSInstanceCheckResponse) XXX_Unmarshal(b []byte) 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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ChangeSettingsRequest) Descriptor 

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

func (*ChangeSettingsRequest) GetAwsPartitions 

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

func (*ChangeSettingsRequest) GetDataRetention 

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

func (*ChangeSettingsRequest) GetDisableTelemetry 

func (m *ChangeSettingsRequest) GetDisableTelemetry() bool

func (*ChangeSettingsRequest) GetEnableTelemetry 

func (m *ChangeSettingsRequest) GetEnableTelemetry() bool

func (*ChangeSettingsRequest) GetMetricsResolutions 

func (m *ChangeSettingsRequest) GetMetricsResolutions() *MetricsResolutions

func (*ChangeSettingsRequest) GetSshKey 

func (m *ChangeSettingsRequest) GetSshKey() string

func (*ChangeSettingsRequest) ProtoMessage 

func (*ChangeSettingsRequest) ProtoMessage()

func (*ChangeSettingsRequest) Reset 

func (m *ChangeSettingsRequest) Reset()

func (*ChangeSettingsRequest) String 

func (m *ChangeSettingsRequest) String() string

func (*ChangeSettingsRequest) Validate 

func (this *ChangeSettingsRequest) Validate() error

func (*ChangeSettingsRequest) XXX_DiscardUnknown 

func (m *ChangeSettingsRequest) XXX_DiscardUnknown()

func (*ChangeSettingsRequest) XXX_Marshal 

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

func (*ChangeSettingsRequest) XXX_Merge 

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

func (*ChangeSettingsRequest) XXX_Size 

func (m *ChangeSettingsRequest) XXX_Size() int

func (*ChangeSettingsRequest) XXX_Unmarshal 

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

type ChangeSettingsResponse 

type ChangeSettingsResponse struct {
	Settings             *Settings `protobuf:"bytes,1,opt,name=settings,proto3" json:"settings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ChangeSettingsResponse) Descriptor 

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

func (*ChangeSettingsResponse) GetSettings 

func (m *ChangeSettingsResponse) GetSettings() *Settings

func (*ChangeSettingsResponse) ProtoMessage 

func (*ChangeSettingsResponse) ProtoMessage()

func (*ChangeSettingsResponse) Reset 

func (m *ChangeSettingsResponse) Reset()

func (*ChangeSettingsResponse) String 

func (m *ChangeSettingsResponse) String() string

func (*ChangeSettingsResponse) Validate 

func (this *ChangeSettingsResponse) Validate() error

func (*ChangeSettingsResponse) XXX_DiscardUnknown 

func (m *ChangeSettingsResponse) XXX_DiscardUnknown()

func (*ChangeSettingsResponse) XXX_Marshal 

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

func (*ChangeSettingsResponse) XXX_Merge 

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

func (*ChangeSettingsResponse) XXX_Size 

func (m *ChangeSettingsResponse) XXX_Size() int

func (*ChangeSettingsResponse) XXX_Unmarshal 

func (m *ChangeSettingsResponse) XXX_Unmarshal(b []byte) 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckUpdatesRequest) Descriptor 

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

func (*CheckUpdatesRequest) GetForce 

func (m *CheckUpdatesRequest) GetForce() bool

func (*CheckUpdatesRequest) ProtoMessage 

func (*CheckUpdatesRequest) ProtoMessage()

func (*CheckUpdatesRequest) Reset 

func (m *CheckUpdatesRequest) Reset()

func (*CheckUpdatesRequest) String 

func (m *CheckUpdatesRequest) String() string

func (*CheckUpdatesRequest) Validate 

func (this *CheckUpdatesRequest) Validate() error

func (*CheckUpdatesRequest) XXX_DiscardUnknown 

func (m *CheckUpdatesRequest) XXX_DiscardUnknown()

func (*CheckUpdatesRequest) XXX_Marshal 

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

func (*CheckUpdatesRequest) XXX_Merge 

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

func (*CheckUpdatesRequest) XXX_Size 

func (m *CheckUpdatesRequest) XXX_Size() int

func (*CheckUpdatesRequest) XXX_Unmarshal 

func (m *CheckUpdatesRequest) XXX_Unmarshal(b []byte) 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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*CheckUpdatesResponse) Descriptor 

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

func (*CheckUpdatesResponse) GetInstalled 

func (m *CheckUpdatesResponse) GetInstalled() *VersionInfo

func (*CheckUpdatesResponse) GetLastCheck 

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

func (*CheckUpdatesResponse) GetLatest 

func (m *CheckUpdatesResponse) GetLatest() *VersionInfo

func (*CheckUpdatesResponse) GetLatestNewsUrl 

func (m *CheckUpdatesResponse) GetLatestNewsUrl() string

func (*CheckUpdatesResponse) GetUpdateAvailable 

func (m *CheckUpdatesResponse) GetUpdateAvailable() bool

func (*CheckUpdatesResponse) ProtoMessage 

func (*CheckUpdatesResponse) ProtoMessage()

func (*CheckUpdatesResponse) Reset 

func (m *CheckUpdatesResponse) Reset()

func (*CheckUpdatesResponse) String 

func (m *CheckUpdatesResponse) String() string

func (*CheckUpdatesResponse) Validate 

func (this *CheckUpdatesResponse) Validate() error

func (*CheckUpdatesResponse) XXX_DiscardUnknown 

func (m *CheckUpdatesResponse) XXX_DiscardUnknown()

func (*CheckUpdatesResponse) XXX_Marshal 

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

func (*CheckUpdatesResponse) XXX_Merge 

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

func (*CheckUpdatesResponse) XXX_Size 

func (m *CheckUpdatesResponse) XXX_Size() int

func (*CheckUpdatesResponse) XXX_Unmarshal 

func (m *CheckUpdatesResponse) XXX_Unmarshal(b []byte) 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) EnumDescriptor 

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

func (DistributionMethod) String 

func (x DistributionMethod) String() string

type GetSettingsRequest 

type GetSettingsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSettingsRequest) Descriptor 

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

func (*GetSettingsRequest) ProtoMessage 

func (*GetSettingsRequest) ProtoMessage()

func (*GetSettingsRequest) Reset 

func (m *GetSettingsRequest) Reset()

func (*GetSettingsRequest) String 

func (m *GetSettingsRequest) String() string

func (*GetSettingsRequest) Validate 

func (this *GetSettingsRequest) Validate() error

func (*GetSettingsRequest) XXX_DiscardUnknown 

func (m *GetSettingsRequest) XXX_DiscardUnknown()

func (*GetSettingsRequest) XXX_Marshal 

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

func (*GetSettingsRequest) XXX_Merge 

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

func (*GetSettingsRequest) XXX_Size 

func (m *GetSettingsRequest) XXX_Size() int

func (*GetSettingsRequest) XXX_Unmarshal 

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

type GetSettingsResponse 

type GetSettingsResponse struct {
	Settings             *Settings `protobuf:"bytes,1,opt,name=settings,proto3" json:"settings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetSettingsResponse) Descriptor 

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

func (*GetSettingsResponse) GetSettings 

func (m *GetSettingsResponse) GetSettings() *Settings

func (*GetSettingsResponse) ProtoMessage 

func (*GetSettingsResponse) ProtoMessage()

func (*GetSettingsResponse) Reset 

func (m *GetSettingsResponse) Reset()

func (*GetSettingsResponse) String 

func (m *GetSettingsResponse) String() string

func (*GetSettingsResponse) Validate 

func (this *GetSettingsResponse) Validate() error

func (*GetSettingsResponse) XXX_DiscardUnknown 

func (m *GetSettingsResponse) XXX_DiscardUnknown()

func (*GetSettingsResponse) XXX_Marshal 

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

func (*GetSettingsResponse) XXX_Merge 

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

func (*GetSettingsResponse) XXX_Size 

func (m *GetSettingsResponse) XXX_Size() int

func (*GetSettingsResponse) XXX_Unmarshal 

func (m *GetSettingsResponse) XXX_Unmarshal(b []byte) 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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

MetricsResolutions represents Prometheus exporters metrics resolutions.

func (*MetricsResolutions) Descriptor 

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

func (*MetricsResolutions) GetHr 

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

func (*MetricsResolutions) GetLr 

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

func (*MetricsResolutions) GetMr 

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

func (*MetricsResolutions) ProtoMessage 

func (*MetricsResolutions) ProtoMessage()

func (*MetricsResolutions) Reset 

func (m *MetricsResolutions) Reset()

func (*MetricsResolutions) String 

func (m *MetricsResolutions) String() string

func (*MetricsResolutions) Validate 

func (this *MetricsResolutions) Validate() error

func (*MetricsResolutions) XXX_DiscardUnknown 

func (m *MetricsResolutions) XXX_DiscardUnknown()

func (*MetricsResolutions) XXX_Marshal 

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

func (*MetricsResolutions) XXX_Merge 

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

func (*MetricsResolutions) XXX_Size 

func (m *MetricsResolutions) XXX_Size() int

func (*MetricsResolutions) XXX_Unmarshal 

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

type ReadinessRequest 

type ReadinessRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadinessRequest) Descriptor 

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

func (*ReadinessRequest) ProtoMessage 

func (*ReadinessRequest) ProtoMessage()

func (*ReadinessRequest) Reset 

func (m *ReadinessRequest) Reset()

func (*ReadinessRequest) String 

func (m *ReadinessRequest) String() string

func (*ReadinessRequest) Validate 

func (this *ReadinessRequest) Validate() error

func (*ReadinessRequest) XXX_DiscardUnknown 

func (m *ReadinessRequest) XXX_DiscardUnknown()

func (*ReadinessRequest) XXX_Marshal 

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

func (*ReadinessRequest) XXX_Merge 

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

func (*ReadinessRequest) XXX_Size 

func (m *ReadinessRequest) XXX_Size() int

func (*ReadinessRequest) XXX_Unmarshal 

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

type ReadinessResponse 

type ReadinessResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadinessResponse) Descriptor 

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

func (*ReadinessResponse) ProtoMessage 

func (*ReadinessResponse) ProtoMessage()

func (*ReadinessResponse) Reset 

func (m *ReadinessResponse) Reset()

func (*ReadinessResponse) String 

func (m *ReadinessResponse) String() string

func (*ReadinessResponse) Validate 

func (this *ReadinessResponse) Validate() error

func (*ReadinessResponse) XXX_DiscardUnknown 

func (m *ReadinessResponse) XXX_DiscardUnknown()

func (*ReadinessResponse) XXX_Marshal 

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

func (*ReadinessResponse) XXX_Merge 

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

func (*ReadinessResponse) XXX_Size 

func (m *ReadinessResponse) XXX_Size() int

func (*ReadinessResponse) XXX_Unmarshal 

func (m *ReadinessResponse) XXX_Unmarshal(b []byte) 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)
}

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.ClientConn) 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)
}

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

Settings represents PMM Server settings.

func (*Settings) Descriptor 

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

func (*Settings) GetAwsPartitions 

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

func (*Settings) GetDataRetention 

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

func (*Settings) GetMetricsResolutions 

func (m *Settings) GetMetricsResolutions() *MetricsResolutions

func (*Settings) GetSshKey 

func (m *Settings) GetSshKey() string

func (*Settings) GetTelemetryEnabled 

func (m *Settings) GetTelemetryEnabled() bool

func (*Settings) GetUpdatesDisabled 

func (m *Settings) GetUpdatesDisabled() bool

func (*Settings) ProtoMessage 

func (*Settings) ProtoMessage()

func (*Settings) Reset 

func (m *Settings) Reset()

func (*Settings) String 

func (m *Settings) String() string

func (*Settings) Validate 

func (this *Settings) Validate() error

func (*Settings) XXX_DiscardUnknown 

func (m *Settings) XXX_DiscardUnknown()

func (*Settings) XXX_Marshal 

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

func (*Settings) XXX_Merge 

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

func (*Settings) XXX_Size 

func (m *Settings) XXX_Size() int

func (*Settings) XXX_Unmarshal 

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

type StartUpdateRequest 

type StartUpdateRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartUpdateRequest) Descriptor 

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

func (*StartUpdateRequest) ProtoMessage 

func (*StartUpdateRequest) ProtoMessage()

func (*StartUpdateRequest) Reset 

func (m *StartUpdateRequest) Reset()

func (*StartUpdateRequest) String 

func (m *StartUpdateRequest) String() string

func (*StartUpdateRequest) Validate 

func (this *StartUpdateRequest) Validate() error

func (*StartUpdateRequest) XXX_DiscardUnknown 

func (m *StartUpdateRequest) XXX_DiscardUnknown()

func (*StartUpdateRequest) XXX_Marshal 

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

func (*StartUpdateRequest) XXX_Merge 

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

func (*StartUpdateRequest) XXX_Size 

func (m *StartUpdateRequest) XXX_Size() int

func (*StartUpdateRequest) XXX_Unmarshal 

func (m *StartUpdateRequest) XXX_Unmarshal(b []byte) 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartUpdateResponse) Descriptor 

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

func (*StartUpdateResponse) GetAuthToken 

func (m *StartUpdateResponse) GetAuthToken() string

func (*StartUpdateResponse) GetLogOffset 

func (m *StartUpdateResponse) GetLogOffset() uint32

func (*StartUpdateResponse) ProtoMessage 

func (*StartUpdateResponse) ProtoMessage()

func (*StartUpdateResponse) Reset 

func (m *StartUpdateResponse) Reset()

func (*StartUpdateResponse) String 

func (m *StartUpdateResponse) String() string

func (*StartUpdateResponse) Validate 

func (this *StartUpdateResponse) Validate() error

func (*StartUpdateResponse) XXX_DiscardUnknown 

func (m *StartUpdateResponse) XXX_DiscardUnknown()

func (*StartUpdateResponse) XXX_Marshal 

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

func (*StartUpdateResponse) XXX_Merge 

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

func (*StartUpdateResponse) XXX_Size 

func (m *StartUpdateResponse) XXX_Size() int

func (*StartUpdateResponse) XXX_Unmarshal 

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

type UnimplementedServerServer 

type UnimplementedServerServer struct {
}

UnimplementedServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedServerServer) AWSInstanceCheck 

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

func (*UnimplementedServerServer) ChangeSettings 

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

func (*UnimplementedServerServer) CheckUpdates 

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

func (*UnimplementedServerServer) GetSettings 

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

func (*UnimplementedServerServer) Readiness 

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

func (*UnimplementedServerServer) StartUpdate 

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

func (*UnimplementedServerServer) UpdateStatus 

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

func (*UnimplementedServerServer) Version 

func (*UnimplementedServerServer) Version(ctx context.Context, req *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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateStatusRequest) Descriptor 

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

func (*UpdateStatusRequest) GetAuthToken 

func (m *UpdateStatusRequest) GetAuthToken() string

func (*UpdateStatusRequest) GetLogOffset 

func (m *UpdateStatusRequest) GetLogOffset() uint32

func (*UpdateStatusRequest) ProtoMessage 

func (*UpdateStatusRequest) ProtoMessage()

func (*UpdateStatusRequest) Reset 

func (m *UpdateStatusRequest) Reset()

func (*UpdateStatusRequest) String 

func (m *UpdateStatusRequest) String() string

func (*UpdateStatusRequest) Validate 

func (this *UpdateStatusRequest) Validate() error

func (*UpdateStatusRequest) XXX_DiscardUnknown 

func (m *UpdateStatusRequest) XXX_DiscardUnknown()

func (*UpdateStatusRequest) XXX_Marshal 

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

func (*UpdateStatusRequest) XXX_Merge 

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

func (*UpdateStatusRequest) XXX_Size 

func (m *UpdateStatusRequest) XXX_Size() int

func (*UpdateStatusRequest) XXX_Unmarshal 

func (m *UpdateStatusRequest) XXX_Unmarshal(b []byte) 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateStatusResponse) Descriptor 

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

func (*UpdateStatusResponse) GetDone 

func (m *UpdateStatusResponse) GetDone() bool

func (*UpdateStatusResponse) GetLogLines 

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

func (*UpdateStatusResponse) GetLogOffset 

func (m *UpdateStatusResponse) GetLogOffset() uint32

func (*UpdateStatusResponse) ProtoMessage 

func (*UpdateStatusResponse) ProtoMessage()

func (*UpdateStatusResponse) Reset 

func (m *UpdateStatusResponse) Reset()

func (*UpdateStatusResponse) String 

func (m *UpdateStatusResponse) String() string

func (*UpdateStatusResponse) Validate 

func (this *UpdateStatusResponse) Validate() error

func (*UpdateStatusResponse) XXX_DiscardUnknown 

func (m *UpdateStatusResponse) XXX_DiscardUnknown()

func (*UpdateStatusResponse) XXX_Marshal 

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

func (*UpdateStatusResponse) XXX_Merge 

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

func (*UpdateStatusResponse) XXX_Size 

func (m *UpdateStatusResponse) XXX_Size() int

func (*UpdateStatusResponse) XXX_Unmarshal 

func (m *UpdateStatusResponse) XXX_Unmarshal(b []byte) 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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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

func (*VersionInfo) Descriptor 

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

func (*VersionInfo) GetFullVersion 

func (m *VersionInfo) GetFullVersion() string

func (*VersionInfo) GetTimestamp 

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

func (*VersionInfo) GetVersion 

func (m *VersionInfo) GetVersion() string

func (*VersionInfo) ProtoMessage 

func (*VersionInfo) ProtoMessage()

func (*VersionInfo) Reset 

func (m *VersionInfo) Reset()

func (*VersionInfo) String 

func (m *VersionInfo) String() string

func (*VersionInfo) Validate 

func (this *VersionInfo) Validate() error

func (*VersionInfo) XXX_DiscardUnknown 

func (m *VersionInfo) XXX_DiscardUnknown()

func (*VersionInfo) XXX_Marshal 

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

func (*VersionInfo) XXX_Merge 

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

func (*VersionInfo) XXX_Size 

func (m *VersionInfo) XXX_Size() int

func (*VersionInfo) XXX_Unmarshal 

func (m *VersionInfo) XXX_Unmarshal(b []byte) 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VersionRequest) Descriptor 

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

func (*VersionRequest) GetDummy 

func (m *VersionRequest) GetDummy() string

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) Reset 

func (m *VersionRequest) Reset()

func (*VersionRequest) String 

func (m *VersionRequest) String() string

func (*VersionRequest) Validate 

func (this *VersionRequest) Validate() error

func (*VersionRequest) XXX_DiscardUnknown 

func (m *VersionRequest) XXX_DiscardUnknown()

func (*VersionRequest) XXX_Marshal 

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

func (*VersionRequest) XXX_Merge 

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

func (*VersionRequest) XXX_Size 

func (m *VersionRequest) XXX_Size() int

func (*VersionRequest) XXX_Unmarshal 

func (m *VersionRequest) XXX_Unmarshal(b []byte) 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 `` /* 147-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*VersionResponse) Descriptor 

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

func (*VersionResponse) GetDistributionMethod 

func (m *VersionResponse) GetDistributionMethod() DistributionMethod

func (*VersionResponse) GetManaged 

func (m *VersionResponse) GetManaged() *VersionInfo

func (*VersionResponse) GetServer 

func (m *VersionResponse) GetServer() *VersionInfo

func (*VersionResponse) GetVersion 

func (m *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) Reset 

func (m *VersionResponse) Reset()

func (*VersionResponse) String 

func (m *VersionResponse) String() string

func (*VersionResponse) Validate 

func (this *VersionResponse) Validate() error

func (*VersionResponse) XXX_DiscardUnknown 

func (m *VersionResponse) XXX_DiscardUnknown()

func (*VersionResponse) XXX_Marshal 

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

func (*VersionResponse) XXX_Merge 

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

func (*VersionResponse) XXX_Size 

func (m *VersionResponse) XXX_Size() int

func (*VersionResponse) XXX_Unmarshal 

func (m *VersionResponse) XXX_Unmarshal(b []byte) 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.