stub

Documentation

Index

• Variables
• func GetReplsetAddrs(m *v1alpha1.PerconaServerMongoDB, replset *v1alpha1.ReplsetSpec, ...) ([]string, error)
• func NewHandler(client sdk.Client) opSdk.Handler
• type Handler
  • func (h *Handler) Handle(ctx context.Context, event opSdk.Event) error
• type ServiceAddr
  • func (s ServiceAddr) String() string

Variables

var (
	ErrNoRunningMongodContainers = errors.New("no mongod containers in running state")
	MongoDBTimeout               = 3 * time.Second
)

var ErrExecCommandTimeout = errors.New("timeout executing command")

var ReplsetInitWait = 10 * time.Second

Functions

func GetReplsetAddrs

func GetReplsetAddrs(m *v1alpha1.PerconaServerMongoDB, replset *v1alpha1.ReplsetSpec, pods []corev1.Pod) ([]string, error)

GetReplsetAddrs returns a slice of replset host:port addresses

func NewHandler

func NewHandler(client sdk.Client) opSdk.Handler

NewHandler return new instance of sdk.Handler interface.

Types

type Handler

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

Handler implements sdk.Handler interface.

func (*Handler) Handle

func (h *Handler) Handle(ctx context.Context, event opSdk.Event) error

Handle is the main operator function that is ran for every SDK event

type ServiceAddr

type ServiceAddr struct {
	Host string
	Port int
}

func (ServiceAddr) String

func (s ServiceAddr) String() string