utils

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

type Constrained interface {
	Constraints() map[string][]Constraint
	Attribute(name string) string
}

type Constraint interface {
	Matches(value string, values []string) bool
}

type Constraints map[string][]Constraint

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

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

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

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

type Log interface {
	//Formats a given message according to given params to log with level Trace.
	Trace(message string, params ...interface{})

	//Formats a given message according to given params to log with level Debug.
	Debug(message string, params ...interface{})

	//Formats a given message according to given params to log with level Info.
	Info(message string, params ...interface{})

	//Formats a given message according to given params to log with level Warn.
	Warn(message string, params ...interface{})

	//Formats a given message according to given params to log with level Error.
	Error(message string, params ...interface{})

	//Formats a given message according to given params to log with level Critical.
	Critical(message string, params ...interface{})
}

type LogLevel string

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

type Reconciler struct {
	ReconcileDelay    time.Duration
	ReconcileMaxTries int
	// contains filtered or unexported fields
}

type Storage interface {
	Save([]byte) error
	Load() ([]byte, error)
}

type Task interface {
	Config() TaskConfig
	Data() *TaskData
	Matches(*mesos.Offer) string
	NewTaskInfo(*mesos.Offer) *mesos.TaskInfo
}

type TaskConfig map[string]string

type TaskData struct {
	Type          string
	ID            string
	TaskID        string
	SlaveID       string
	ExecutorID    string
	Attributes    map[string]string
	State         TaskState
	Cpu           float64
	Mem           float64
	ConstraintMap Constraints
}

type TaskState string

type Tasks interface {
	Exists(id string) bool
	Add(task Task)
	Remove(id string)
	Get(id string) Task
	GetAll() []Task
	GetWithFilter(filter func(Task) bool) []Task
	GetStopped() []Task
	IsReconciling() bool
	GetConstrained() []Constrained
}

type Unique struct{}

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

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