controller

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

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

type DeploymentClient interface {
	CreateContainer(name string, image string, env map[string]string, restart bool) (id string, err error)
	UpdateContainer(id string, name string, image 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)
}