channel

Documentation

Index

• Constants
• type ChannelStatus
• type Node
• type SharedChannel
  • func (sc *SharedChannel) IsBlocked() bool
  • func (sc *SharedChannel) Load(s string) error
  • func (sc *SharedChannel) String() string
  • func (sc *SharedChannel) Unblock()

Constants

const SharedChannelKey = "shared-channel.json"

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()