serverpb

package
v2.0.0-beta5+incompatible Latest Latest
Warning

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

 Go to latest Published: Jul 30, 2019 License: AGPL-3.0 Imports: 17 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

This section is empty.

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 RegisterServerServer 

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

Types

type ChangeSettingsRequest 

type ChangeSettingsRequest struct {
	MetricsResolutions   *MetricsResolutions `protobuf:"bytes,1,opt,name=metrics_resolutions,json=metricsResolutions,proto3" json:"metrics_resolutions,omitempty"`
	EnableTelemetry      bool                `protobuf:"varint,2,opt,name=enable_telemetry,json=enableTelemetry,proto3" json:"enable_telemetry,omitempty"`
	DisableTelemetry     bool                `protobuf:"varint,3,opt,name=disable_telemetry,json=disableTelemetry,proto3" json:"disable_telemetry,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ChangeSettingsRequest) Descriptor 

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

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

func (*CheckUpdatesRequest) Descriptor 

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

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.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// True if there is a PMM Server update available.
	UpdateAvailable bool `protobuf:"varint,2,opt,name=update_available,json=updateAvailable,proto3" json:"update_available,omitempty"`
	// Latest available PMM Server version.
	LatestVersion string `protobuf:"bytes,3,opt,name=latest_version,json=latestVersion,proto3" json:"latest_version,omitempty"`
	// Latest available PMM Server release date.
	LatestTimestamp *timestamp.Timestamp `protobuf:"bytes,4,opt,name=latest_timestamp,json=latestTimestamp,proto3" json:"latest_timestamp,omitempty"`
	// Latest available PMM Server release announcement URL.
	LatestNewsUrl        string   `protobuf:"bytes,5,opt,name=latest_news_url,json=latestNewsUrl,proto3" json:"latest_news_url,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckUpdatesResponse) Descriptor 

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

func (*CheckUpdatesResponse) GetLatestNewsUrl 

func (m *CheckUpdatesResponse) GetLatestNewsUrl() string

func (*CheckUpdatesResponse) GetLatestTimestamp 

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

func (*CheckUpdatesResponse) GetLatestVersion 

func (m *CheckUpdatesResponse) GetLatestVersion() string

func (*CheckUpdatesResponse) GetUpdateAvailable 

func (m *CheckUpdatesResponse) GetUpdateAvailable() bool

func (*CheckUpdatesResponse) GetVersion 

func (m *CheckUpdatesResponse) GetVersion() string

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 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. Suffix 's' is required in JSON: 1s, 60s, 300s.
	Hr *duration.Duration `protobuf:"bytes,1,opt,name=hr,proto3" json:"hr,omitempty"`
	// Medium resolution. Suffix 's' is required in JSON: 1s, 60s, 300s.
	Mr *duration.Duration `protobuf:"bytes,2,opt,name=mr,proto3" json:"mr,omitempty"`
	// Low resolution. Suffix 's' is required in JSON: 1s, 60s, 300s.
	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 version.
	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)
}

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

ServerServer is the server API for Server service.

type Settings 

type Settings struct {
	MetricsResolutions   *MetricsResolutions `protobuf:"bytes,1,opt,name=metrics_resolutions,json=metricsResolutions,proto3" json:"metrics_resolutions,omitempty"`
	Telemetry            bool                `protobuf:"varint,2,opt,name=telemetry,proto3" json:"telemetry,omitempty"`
	UpdatesDisabled      bool                `protobuf:"varint,3,opt,name=updates_disabled,json=updatesDisabled,proto3" json:"updates_disabled,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) GetMetricsResolutions 

func (m *Settings) GetMetricsResolutions() *MetricsResolutions

func (*Settings) GetTelemetry 

func (m *Settings) GetTelemetry() 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 status.
	AuthToken            string   `protobuf:"bytes,1,opt,name=auth_token,json=authToken,proto3" json:"auth_token,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) 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) 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, starts from 0.
	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.
	NextLogOffset uint32 `protobuf:"varint,2,opt,name=next_log_offset,json=nextLogOffset,proto3" json:"next_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) GetNextLogOffset 

func (m *UpdateStatusResponse) GetNextLogOffset() 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 VersionRequest 

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

func (*VersionRequest) Descriptor 

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

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 {
	// Currently installed PMM Server version.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// True if there is a PMM Server update available.
	UpdateAvailable bool `protobuf:"varint,2,opt,name=update_available,json=updateAvailable,proto3" json:"update_available,omitempty"`
	// pmm-managed version information for debugging.
	Managed              *VersionResponse_Managed `protobuf:"bytes,3,opt,name=managed,proto3" json:"managed,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*VersionResponse) Descriptor 

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

func (*VersionResponse) GetManaged 

func (m *VersionResponse) GetManaged() *VersionResponse_Managed

func (*VersionResponse) GetUpdateAvailable 

func (m *VersionResponse) GetUpdateAvailable() bool

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

type VersionResponse_Managed 

type VersionResponse_Managed struct {
	// Version.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Commit.
	Commit string `protobuf:"bytes,2,opt,name=commit,proto3" json:"commit,omitempty"`
	// Build timestamp.
	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:"-"`
}

Managed describes pmm-managed build information.

func (*VersionResponse_Managed) Descriptor 

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

func (*VersionResponse_Managed) GetCommit 

func (m *VersionResponse_Managed) GetCommit() string

func (*VersionResponse_Managed) GetTimestamp 

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

func (*VersionResponse_Managed) GetVersion 

func (m *VersionResponse_Managed) GetVersion() string

func (*VersionResponse_Managed) ProtoMessage 

func (*VersionResponse_Managed) ProtoMessage()

func (*VersionResponse_Managed) Reset 

func (m *VersionResponse_Managed) Reset()

func (*VersionResponse_Managed) String 

func (m *VersionResponse_Managed) String() string

func (*VersionResponse_Managed) Validate 

func (this *VersionResponse_Managed) Validate() error

func (*VersionResponse_Managed) XXX_DiscardUnknown 

func (m *VersionResponse_Managed) XXX_DiscardUnknown()

func (*VersionResponse_Managed) XXX_Marshal 

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

func (*VersionResponse_Managed) XXX_Merge 

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

func (*VersionResponse_Managed) XXX_Size 

func (m *VersionResponse_Managed) XXX_Size() int

func (*VersionResponse_Managed) XXX_Unmarshal 

func (m *VersionResponse_Managed) 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.