stub

package

v0.2.0 Latest Latest Go to latest Published: Jan 28, 2019 License: Apache-2.0 Imports: 39 Imported by: 0

Details

This section is empty.

View Source

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

View Source

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

View Source

var ReplsetInitWait = 10 * time.Second

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

GetReplsetAddrs returns a slice of replset host:port addresses

func NewHandler(client sdk.Client) opSdk.Handler

NewHandler return new instance of sdk.Handler interface.

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

Handler implements sdk.Handler interface.

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 struct {
	Host string
	Port int
}

func (s ServiceAddr) String() string

Path	Synopsis
backup