channel

package
v1.2.3 Latest Latest
Warning

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

Go to latest
Published: Aug 25, 2022 License: Apache-2.0 Imports: 1 Imported by: 0

Documentation

Index

Constants

View Source
const SharedChannelKey = "shared-channel.json"

Variables

This section is empty.

Functions

This section is empty.

Types

type ChannelStatus

type ChannelStatus string
const (
	ChannelBlocked ChannelStatus = "blocked"
	ChannelOpen    ChannelStatus = ""
)

type Node

type Node struct {
	Pod    string `json:"pod,omitempty"`
	Host   string `json:"host,omitempty"`
	Domain string `json:"domain,omitempty"`
	Port   int    `json:"port,omitempty"`
	// Node name in k8s.
	HostName string `json:"node_name,omitempty"`
	// Pod role.
	Role string `json:"role,omitempty"`
}

type SharedChannel

type SharedChannel struct {
	Generation            int64         `json:"generation,omitempty"`
	Nodes                 []Node        `json:"nodes,omitempty"`
	Status                ChannelStatus `json:"status,omitempty"`
	LastBackupBinlogIndex *int64        `json:"last_backup_log_index,omitempty"`
}

func (*SharedChannel) IsBlocked

func (sc *SharedChannel) IsBlocked() bool

func (*SharedChannel) Load

func (sc *SharedChannel) Load(s string) error

func (*SharedChannel) String

func (sc *SharedChannel) String() string

func (*SharedChannel) Unblock

func (sc *SharedChannel) Unblock()

Jump to

Keyboard shortcuts

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