tiflowapi

Documentation

Index

• Constants
• func GetTLSConfig(cli client.Client, namespace, secretName string) (*tls.Config, error)
• func LoadTlsConfigFromSecret(secret *corev1.Secret) (*tls.Config, error)
• func MasterClientURL(namespace, clusterName, podName, scheme string) string
• type Executor
• type ExecutorsInfo
• type LeaderInfo
• type Master
• type MasterClient
  • func GetMasterClient(cli client.Client, namespace, tcName, podName string, tlsEnabled bool) MasterClient
  • func NewMasterClient(url string, timeout time.Duration, tlsConfig *tls.Config) MasterClient
• type MastersInfo

Constants

const (
	DefaultTimeout = 5 * time.Second
)

Functions

func GetTLSConfig

func GetTLSConfig(cli client.Client, namespace, secretName string) (*tls.Config, error)

GetTLSConfig returns *tls.Config for given TiDB cluster.

func LoadTlsConfigFromSecret

func LoadTlsConfigFromSecret(secret *corev1.Secret) (*tls.Config, error)

func MasterClientURL

func MasterClientURL(namespace, clusterName, podName, scheme string) string

MasterClientURL builds the url of master client

Types

type Executor

type Executor struct {
	ID         string `json:"id,omitempty"`
	Name       string `json:"name,omitempty"`
	Address    string `json:"address,omitempty"`
	Capability string `json:"capability,omitempty"`
}

type ExecutorsInfo

type ExecutorsInfo struct {
	Executors []*Executor `json:"executors,omitempty"`
}

type LeaderInfo

type LeaderInfo struct {
	AdvertiseAddr string `json:"advertise_addr,omitempty"`
}

type Master

type Master struct {
	ID       string `json:"id,omitempty"`
	Name     string `json:"name,omitempty"`
	Address  string `json:"address,omitempty"`
	IsLeader bool   `json:"is_leader,omitempty"`
}

type MasterClient

type MasterClient interface {
	// GetMasters returns all master members from cluster
	GetMasters() (MastersInfo, error)
	GetExecutors() (ExecutorsInfo, error)
	GetLeader() (LeaderInfo, error)
	GetURL() string
	EvictLeader() error
	DeleteMaster(name string) error
	DeleteExecutor(name string) error
}

MasterClient provides master server's api

func GetMasterClient

func GetMasterClient(cli client.Client, namespace, tcName, podName string, tlsEnabled bool) MasterClient

GetMasterClient provides a MasterClient of real tiflow-master cluster podName == "": get load balancer service of tiflow-master cluster podNAme != "": get exact pod's service of tiflow-master client

func NewMasterClient

func NewMasterClient(url string, timeout time.Duration, tlsConfig *tls.Config) MasterClient

NewMasterClient returns a new MasterClient

type MastersInfo

type MastersInfo struct {
	Masters []*Master `json:"masters,omitempty"`
}