handlers

Documentation

Overview

Package handlers implements gRPC API of pmm-managed.

Index

• type BaseServer
  • func (s *BaseServer) Version(context.Context, *api.BaseVersionRequest) (*api.BaseVersionResponse, error)
• type DemoServer
  • func (s *DemoServer) Error(ctx context.Context, req *api.DemoErrorRequest) (*api.DemoErrorResponse, error)
• type RDSServer
  • func (s *RDSServer) Add(ctx context.Context, req *api.RDSAddRequest) (*api.RDSAddResponse, error)
  • func (s *RDSServer) Discover(ctx context.Context, req *api.RDSDiscoverRequest) (*api.RDSDiscoverResponse, error)
  • func (s *RDSServer) List(ctx context.Context, req *api.RDSListRequest) (*api.RDSListResponse, error)
  • func (s *RDSServer) Remove(ctx context.Context, req *api.RDSRemoveRequest) (*api.RDSRemoveResponse, error)
• type ScrapeConfigsServer
  • func (s *ScrapeConfigsServer) AddStaticTargets(ctx context.Context, req *api.ScrapeConfigsAddStaticTargetsRequest) (*api.ScrapeConfigsAddStaticTargetsResponse, error)
  • func (s *ScrapeConfigsServer) Create(ctx context.Context, req *api.ScrapeConfigsCreateRequest) (*api.ScrapeConfigsCreateResponse, error)
  • func (s *ScrapeConfigsServer) Delete(ctx context.Context, req *api.ScrapeConfigsDeleteRequest) (*api.ScrapeConfigsDeleteResponse, error)
  • func (s *ScrapeConfigsServer) Get(ctx context.Context, req *api.ScrapeConfigsGetRequest) (*api.ScrapeConfigsGetResponse, error)
  • func (s *ScrapeConfigsServer) List(ctx context.Context, req *api.ScrapeConfigsListRequest) (*api.ScrapeConfigsListResponse, error)
  • func (s *ScrapeConfigsServer) RemoveStaticTargets(ctx context.Context, req *api.ScrapeConfigsRemoveStaticTargetsRequest) (*api.ScrapeConfigsRemoveStaticTargetsResponse, error)

Types

type BaseServer

type BaseServer struct {
	PMMVersion string
}

func (*BaseServer) Version

func (s *BaseServer) Version(context.Context, *api.BaseVersionRequest) (*api.BaseVersionResponse, error)

type DemoServer

type DemoServer struct{}

func (*DemoServer) Error

func (s *DemoServer) Error(ctx context.Context, req *api.DemoErrorRequest) (*api.DemoErrorResponse, error)

type RDSServer

type RDSServer struct {
	RDS *rds.Service
}

func (*RDSServer) Add

func (s *RDSServer) Add(ctx context.Context, req *api.RDSAddRequest) (*api.RDSAddResponse, error)

func (*RDSServer) Discover

func (s *RDSServer) Discover(ctx context.Context, req *api.RDSDiscoverRequest) (*api.RDSDiscoverResponse, error)

func (*RDSServer) List

func (s *RDSServer) List(ctx context.Context, req *api.RDSListRequest) (*api.RDSListResponse, error)

func (*RDSServer) Remove

func (s *RDSServer) Remove(ctx context.Context, req *api.RDSRemoveRequest) (*api.RDSRemoveResponse, error)

type ScrapeConfigsServer

type ScrapeConfigsServer struct {
	Prometheus *prometheus.Service
}

func (*ScrapeConfigsServer) AddStaticTargets

func (s *ScrapeConfigsServer) AddStaticTargets(ctx context.Context, req *api.ScrapeConfigsAddStaticTargetsRequest) (*api.ScrapeConfigsAddStaticTargetsResponse, error)

func (*ScrapeConfigsServer) Create

func (s *ScrapeConfigsServer) Create(ctx context.Context, req *api.ScrapeConfigsCreateRequest) (*api.ScrapeConfigsCreateResponse, error)

Create creates a new scrape config. Errors: InvalidArgument(3) if some argument is not valid, AlreadyExists(6) if scrape config with that job name is already present.

func (*ScrapeConfigsServer) Delete

func (s *ScrapeConfigsServer) Delete(ctx context.Context, req *api.ScrapeConfigsDeleteRequest) (*api.ScrapeConfigsDeleteResponse, error)

Delete removes existing scrape config by job name. Errors: NotFound(5) if no such scrape config is present.

func (*ScrapeConfigsServer) Get

func (s *ScrapeConfigsServer) Get(ctx context.Context, req *api.ScrapeConfigsGetRequest) (*api.ScrapeConfigsGetResponse, error)

Get returns a scrape config by job name. Errors: NotFound(5) if no such scrape config is present.

func (*ScrapeConfigsServer) List

func (s *ScrapeConfigsServer) List(ctx context.Context, req *api.ScrapeConfigsListRequest) (*api.ScrapeConfigsListResponse, error)

List returns all scrape configs.

func (*ScrapeConfigsServer) RemoveStaticTargets

func (s *ScrapeConfigsServer) RemoveStaticTargets(ctx context.Context, req *api.ScrapeConfigsRemoveStaticTargetsRequest) (*api.ScrapeConfigsRemoveStaticTargetsResponse, error)