pod

Documentation

Index

• type Pods
  • func NewPods() *Pods
  • func (p *Pods) Get() []string
  • func (p *Pods) Has(name string) bool
  • func (p *Pods) Set(pods []string)
• type Source
• type Task
• type TaskState
• type TaskType
  • func (t TaskType) String() string

Types

type Pods

type Pods struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewPods

func NewPods() *Pods

func (*Pods) Get

func (p *Pods) Get() []string

func (*Pods) Has

func (p *Pods) Has(name string) bool

func (*Pods) Set

func (p *Pods) Set(pods []string)

type Source

type Source interface {
	Name() string
	URL() string
	Pods() ([]string, error)
	GetTasks(podName string) ([]Task, error)
}

type Task

type Task interface {
	Name() string
	Service() string
	State() TaskState
	HasState() bool
	IsRunning() bool
	IsUpdating() bool
	IsTaskType(taskType TaskType) bool
	GetMongoAddr() (*db.Addr, error)
	GetMongoReplsetName() (string, error)
}

type TaskState

type TaskState interface {
	String() string
}

type TaskType

type TaskType string

var (
	TaskTypeMongod       TaskType = "mongod"
	TaskTypeMongodBackup TaskType = "mongod-backup"
	TaskTypeArbiter      TaskType = "arbiter"
	TaskTypeConfigSvr    TaskType = "configsvr"
	TaskTypeMongos       TaskType = "mongos"
)

func (TaskType) String

func (t TaskType) String() string