discovery

package

v0.0.0-...-22a2038 Latest Latest Go to latest Published: Dec 20, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/al-assad/doris-operator

Documentation ¶

Index ¶

func AddBackend(db *sql.DB, beHostPort string) error
func AddBroker(db *sql.DB, brokerName string, brokerHost string) error
func AddFrontend(db *sql.DB, feHostPort string) error
func DropBackend(db *sql.DB, beHostPort string) error
func DropBroker(db *sql.DB, brokerName string) error
func DropFrontend(db *sql.DB, feHostPort string) error
func GetBeExpectedHosts(cr *dapi.DorisCluster) []string
func GetBrokerExpectedHosts(cr *dapi.DorisCluster) []string
func GetBrokerExpectedNames(cr *dapi.DorisCluster) []string
func GetBrokerNameByPodName(bkPodName string) string
func GetBrokerPodNameByName(bkPodName string) string
func GetCnExpectedHosts(cr *dapi.DorisCluster) []string
func GetFeExpectedHosts(cr *dapi.DorisCluster) []string
func ShowBackendHosts(db *sql.DB) ([]string, error)
func ShowBrokerNameHosts(db *sql.DB) (map[string]string, error)
func ShowFrontendHosts(db *sql.DB) ([]string, error)
type DorisDiscovery
- func (r *DorisDiscovery) Reconcile() *RecErr
type DorisSqlConnConf
- func (e *DorisSqlConnConf) Connect() (*sql.DB, error)
- func (e *DorisSqlConnConf) HostPort() string
type RecErr
- func NewRecErr(err error) *RecErr
- func NewRecSqlErr(err error) *RecErr
- func (e *RecErr) Error() string
type RowMap
- func ReadAllRowsAsString(rows *sql.Rows) []RowMap
type SqlAccount

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AddBackend ¶

func AddBackend(db *sql.DB, beHostPort string) error

func AddBroker ¶

func AddBroker(db *sql.DB, brokerName string, brokerHost string) error

func AddFrontend ¶

func AddFrontend(db *sql.DB, feHostPort string) error

func DropBackend ¶

func DropBackend(db *sql.DB, beHostPort string) error

func DropBroker ¶

func DropBroker(db *sql.DB, brokerName string) error

func DropFrontend ¶

func DropFrontend(db *sql.DB, feHostPort string) error

func GetBeExpectedHosts ¶

func GetBeExpectedHosts(cr *dapi.DorisCluster) []string

func GetBrokerExpectedHosts ¶

func GetBrokerExpectedHosts(cr *dapi.DorisCluster) []string

func GetBrokerExpectedNames ¶

func GetBrokerExpectedNames(cr *dapi.DorisCluster) []string

func GetBrokerNameByPodName ¶

func GetBrokerNameByPodName(bkPodName string) string

func GetBrokerPodNameByName ¶

func GetBrokerPodNameByName(bkPodName string) string

func GetCnExpectedHosts ¶

func GetCnExpectedHosts(cr *dapi.DorisCluster) []string

func GetFeExpectedHosts ¶

func GetFeExpectedHosts(cr *dapi.DorisCluster) []string

func ShowBackendHosts ¶

func ShowBackendHosts(db *sql.DB) ([]string, error)

func ShowBrokerNameHosts ¶

func ShowBrokerNameHosts(db *sql.DB) (map[string]string, error)

ShowBrokerNameHosts returns map structure: key is broker name, value is broker host

func ShowFrontendHosts ¶

func ShowFrontendHosts(db *sql.DB) ([]string, error)

Types ¶

type DorisDiscovery ¶

type DorisDiscovery struct {
	rec.ReconcileContext
	CR *dapi.DorisCluster
}

func (*DorisDiscovery) Reconcile ¶

func (r *DorisDiscovery) Reconcile() *RecErr

type DorisSqlConnConf ¶

type DorisSqlConnConf struct {
	Host     string
	Port     int32
	User     string
	Password string
}

DorisSqlConnConf is the Doris SQL connection configuration

func (*DorisSqlConnConf) Connect ¶

func (e *DorisSqlConnConf) Connect() (*sql.DB, error)

func (*DorisSqlConnConf) HostPort ¶

func (e *DorisSqlConnConf) HostPort() string

type RecErr ¶

type RecErr struct {
	Err      error
	IsSqlErr bool
}

func NewRecErr ¶

func NewRecErr(err error) *RecErr

func NewRecSqlErr ¶

func NewRecSqlErr(err error) *RecErr

func (*RecErr) Error ¶

func (e *RecErr) Error() string

type RowMap ¶

type RowMap map[string]string

func ReadAllRowsAsString ¶

func ReadAllRowsAsString(rows *sql.Rows) []RowMap

ReadAllRowsAsString reads all rows from sql.Rows and returns a slice of map[string]string

type SqlAccount ¶

type SqlAccount struct {
	User     string
	Password string
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL