service

Documentation

Index

• Constants
• Variables
• func RegisterServciesFromEtcd(reg registry.Registry)
• func RegisterServices()
• type PDService
  • func (s *PDService) ParseEndpointFromArgs(args []string) map[string]pkg.Endpoint
  • func (s *PDService) Status() *ServiceStatus
• type Service
  • func NewPDService() Service
  • func NewTiDBService() Service
  • func NewTiKVService() Service
• type ServiceStatus
• type TiDBPerfMetrics
• type TiDBService
  • func (s *TiDBService) ParseEndpointFromArgs(args []string) map[string]pkg.Endpoint
  • func (s *TiDBService) RetrieveRealPerformance(allProcesses map[string]*proc.ProcessStatus) *TiDBPerfMetrics
  • func (s *TiDBService) Status() *ServiceStatus
• type TiKVService
  • func (s *TiKVService) ParseEndpointFromArgs(args []string) map[string]pkg.Endpoint
  • func (s *TiKVService) Status() *ServiceStatus

Constants

const PD_SERVICE = "PD"

const TiDB_SERVICE = "TiDB"

const TiKV_SERVICE = "TiKV"

Variables

var Registered map[string]Service

Functions

func RegisterServciesFromEtcd

func RegisterServciesFromEtcd(reg registry.Registry)

func RegisterServices

func RegisterServices()

Types

type PDService

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

func (*PDService) ParseEndpointFromArgs

func (s *PDService) ParseEndpointFromArgs(args []string) map[string]pkg.Endpoint

func (*PDService) Status

func (s *PDService) Status() *ServiceStatus

type Service

type Service interface {
	Status() *ServiceStatus
	ParseEndpointFromArgs([]string) map[string]pkg.Endpoint
}

func NewPDService

func NewPDService() Service

func NewTiDBService

func NewTiDBService() Service

func NewTiKVService

func NewTiKVService() Service

type ServiceStatus

type ServiceStatus struct {
	SvcName      string
	Version      string
	Executor     []string
	Command      string
	Args         []string
	Environments map[string]string
	Endpoints    map[string]pkg.Endpoint
}

type TiDBPerfMetrics

type TiDBPerfMetrics struct {
	TPS         int64  `json:"tps"`
	Connections int    `json:"connections"`
	Version     string `json:"version"`
}

type TiDBService

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

func (*TiDBService) ParseEndpointFromArgs

func (s *TiDBService) ParseEndpointFromArgs(args []string) map[string]pkg.Endpoint

func (*TiDBService) RetrieveRealPerformance

func (s *TiDBService) RetrieveRealPerformance(allProcesses map[string]*proc.ProcessStatus) *TiDBPerfMetrics

func (*TiDBService) Status

func (s *TiDBService) Status() *ServiceStatus

type TiKVService

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

func (*TiKVService) ParseEndpointFromArgs

func (s *TiKVService) ParseEndpointFromArgs(args []string) map[string]pkg.Endpoint

func (*TiKVService) Status

func (s *TiKVService) Status() *ServiceStatus