controller

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

type Database interface {
	ListInstances(ctx context.Context, limit int64, offset int64, sort string, asc bool, search string, includeGenerated bool, ids []string) (result []model.Instance, err error)
	GetInstance(ctx context.Context, id string) (instance model.Instance, exists bool, err error)
	SetInstance(ctx context.Context, instance model.Instance) error
	GetInstances(ctx context.Context, ids []string) (result []model.Instance, allExist bool, err error)
	RemoveInstances(ctx context.Context, ids []string) error
}

type DeploymentClient interface {
	CreateContainer(name string, image string, userid string, env map[string]string, restart bool) (id string, err error)
	UpdateContainer(id string, name string, image string, userid string, env map[string]string, restart bool) (newId string, err error)
	RemoveContainer(id string) (err error)
	ContainerExists(id string) (exists bool, err error)
}

type Driver interface {
	CreateInstance(instance *model.Instance, env map[string]string) (serviceId string, err error)
	DeleteInstance(id string) (err error)
}

type KafkaAdmin interface {
	CreateTopic(name string) (err error)
	DeleteTopic(name string) (err error)
}