Documentation ¶
Index ¶
- func ClusterService() types.ClusterService
- func EnableHealthCheck()
- func GetGroupIDByName(api *slack.RTM) map[string]string
- func NewAbbRouter() *napnap.Router
- func NewClusterDatabase(db *sqlx.DB) types.ClusterRepository
- func NewClusterManager(repo types.ClusterRepository) types.ClusterService
- func NewClusterMongo() (types.ClusterRepository, error)
- func NewHealthCheckerManager(repo types.HealthCheckerRepository) (types.HealthChecker, error)
- func NewServiceManager(cluster *types.Cluster, repo types.ServiceRepository) (types.ServiceService, error)
- func NewServiceMongo() (types.ServiceRepository, error)
- type ClusterDatabase
- func (c *ClusterDatabase) ClusterByName(ctx context.Context, name string) (*types.Cluster, error)
- func (c *ClusterDatabase) ClusterCreate(ctx context.Context, entity *types.Cluster) error
- func (c *ClusterDatabase) ClusterList(ctx context.Context) ([]*types.Cluster, error)
- func (c *ClusterDatabase) ClusterUpdate(ctx context.Context, entity *types.Cluster) error
- type ClusterManager
- func (manager *ClusterManager) ClusterByName(ctx context.Context, name string) (*types.Cluster, error)
- func (manager *ClusterManager) ClusterCreate(ctx context.Context, target *types.Cluster) error
- func (manager *ClusterManager) ClusterList(ctx context.Context) ([]*types.Cluster, error)
- func (manager *ClusterManager) ClusterUpdate(ctx context.Context, target *types.Cluster) error
- type ClusterMongo
- func (c *ClusterMongo) ClusterByName(ctx context.Context, name string) (*types.Cluster, error)
- func (c *ClusterMongo) ClusterCreate(ctx context.Context, target *types.Cluster) error
- func (c *ClusterMongo) ClusterList(ctx context.Context) ([]*types.Cluster, error)
- func (c *ClusterMongo) ClusterUpdate(ctx context.Context, target *types.Cluster) error
- type ConfigManager
- func (m *ConfigManager) Close(ctx context.Context) error
- func (m *ConfigManager) Create(ctx context.Context, config *types.Config) error
- func (m *ConfigManager) Delete(ctx context.Context, configID string) error
- func (m *ConfigManager) DockerClient() *client.Client
- func (m *ConfigManager) Get(ctx context.Context, configID string) (*types.Config, error)
- func (m *ConfigManager) List(ctx context.Context, opts types.ConfigListOption) ([]*types.Config, error)
- type ErrorHandlingMiddleware
- type HealthCheckDAO
- func (repo *HealthCheckDAO) Delete(ctx context.Context, id string) error
- func (repo *HealthCheckDAO) Find(ctx context.Context, opts types.HealthCheckFilterOptions) ([]*types.HealthCheck, error)
- func (repo *HealthCheckDAO) FindOne(ctx context.Context, opts types.HealthCheckFilterOptions) (*types.HealthCheck, error)
- func (repo *HealthCheckDAO) Insert(ctx context.Context, entity *types.HealthCheck) error
- func (repo *HealthCheckDAO) Update(ctx context.Context, target *types.HealthCheck) error
- type HealthCheckManager
- type ServiceManager
- func (m *ServiceManager) DockerClient() *client.Client
- func (m *ServiceManager) List(ctx context.Context, opts types.ServiceFilterOptions) ([]*types.Service, error)
- func (m *ServiceManager) Redeploy(ctx context.Context, id string) error
- func (m *ServiceManager) ServiceCreate(ctx context.Context, target *types.Service) error
- func (m *ServiceManager) ServiceDelete(ctx context.Context, id string) error
- func (m *ServiceManager) ServiceGetByID(ctx context.Context, id string) (*types.Service, error)
- func (m *ServiceManager) ServiceGetByName(ctx context.Context, name string) (*types.Service, error)
- func (m *ServiceManager) ServiceLogsByID(ctx context.Context, id string) (string, error)
- func (m *ServiceManager) ServiceRawByID(ctx context.Context, id string) (*swarm.Service, error)
- func (m *ServiceManager) ServiceStop(ctx context.Context, id string) error
- func (m *ServiceManager) ServiceTaskListByID(ctx context.Context, id string) ([]swarm.Task, error)
- func (m *ServiceManager) ServiceUpdate(ctx context.Context, target *types.Service) error
- type ServiceMongo
- func (repo *ServiceMongo) Delete(ctx context.Context, id string) error
- func (repo *ServiceMongo) Find(ctx context.Context, opts types.ServiceFilterOptions) ([]*types.Service, error)
- func (repo *ServiceMongo) FindByID(ctx context.Context, id string) (*types.Service, error)
- func (repo *ServiceMongo) FindByName(ctx context.Context, name string) (*types.Service, error)
- func (repo *ServiceMongo) FindOne(ctx context.Context, opts types.ServiceFilterOptions) (*types.Service, error)
- func (repo *ServiceMongo) Insert(ctx context.Context, target *types.Service) error
- func (repo *ServiceMongo) Update(ctx context.Context, target *types.Service) error
- type TaskManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClusterService ¶
func ClusterService() types.ClusterService
func EnableHealthCheck ¶
func EnableHealthCheck()
func NewAbbRouter ¶
func NewClusterDatabase ¶
func NewClusterDatabase(db *sqlx.DB) types.ClusterRepository
func NewClusterManager ¶
func NewClusterManager(repo types.ClusterRepository) types.ClusterService
func NewClusterMongo ¶
func NewClusterMongo() (types.ClusterRepository, error)
func NewHealthCheckerManager ¶
func NewHealthCheckerManager(repo types.HealthCheckerRepository) (types.HealthChecker, error)
func NewServiceManager ¶
func NewServiceManager(cluster *types.Cluster, repo types.ServiceRepository) (types.ServiceService, error)
func NewServiceMongo ¶
func NewServiceMongo() (types.ServiceRepository, error)
Types ¶
type ClusterDatabase ¶
type ClusterDatabase struct {
// contains filtered or unexported fields
}
func (*ClusterDatabase) ClusterByName ¶
func (*ClusterDatabase) ClusterCreate ¶
func (*ClusterDatabase) ClusterList ¶
func (*ClusterDatabase) ClusterUpdate ¶
type ClusterManager ¶
type ClusterManager struct {
// contains filtered or unexported fields
}
func (*ClusterManager) ClusterByName ¶
func (*ClusterManager) ClusterCreate ¶
func (*ClusterManager) ClusterList ¶
func (*ClusterManager) ClusterUpdate ¶
type ClusterMongo ¶
type ClusterMongo struct { }
func (*ClusterMongo) ClusterByName ¶
func (*ClusterMongo) ClusterCreate ¶
func (*ClusterMongo) ClusterList ¶
func (*ClusterMongo) ClusterUpdate ¶
type ConfigManager ¶
type ConfigManager struct {
// contains filtered or unexported fields
}
func (*ConfigManager) Delete ¶
func (m *ConfigManager) Delete(ctx context.Context, configID string) error
func (*ConfigManager) DockerClient ¶
func (m *ConfigManager) DockerClient() *client.Client
func (*ConfigManager) List ¶
func (m *ConfigManager) List(ctx context.Context, opts types.ConfigListOption) ([]*types.Config, error)
type ErrorHandlingMiddleware ¶
type ErrorHandlingMiddleware struct { }
func NewErrorHandlingMiddleware ¶
func NewErrorHandlingMiddleware() *ErrorHandlingMiddleware
func (*ErrorHandlingMiddleware) Invoke ¶
func (m *ErrorHandlingMiddleware) Invoke(c *napnap.Context, next napnap.HandlerFunc)
type HealthCheckDAO ¶
type HealthCheckDAO struct {
// contains filtered or unexported fields
}
func (*HealthCheckDAO) Delete ¶
func (repo *HealthCheckDAO) Delete(ctx context.Context, id string) error
func (*HealthCheckDAO) Find ¶
func (repo *HealthCheckDAO) Find(ctx context.Context, opts types.HealthCheckFilterOptions) ([]*types.HealthCheck, error)
func (*HealthCheckDAO) FindOne ¶
func (repo *HealthCheckDAO) FindOne(ctx context.Context, opts types.HealthCheckFilterOptions) (*types.HealthCheck, error)
func (*HealthCheckDAO) Insert ¶
func (repo *HealthCheckDAO) Insert(ctx context.Context, entity *types.HealthCheck) error
func (*HealthCheckDAO) Update ¶
func (repo *HealthCheckDAO) Update(ctx context.Context, target *types.HealthCheck) error
type HealthCheckManager ¶
type HealthCheckManager struct {
// contains filtered or unexported fields
}
func (*HealthCheckManager) Create ¶
func (m *HealthCheckManager) Create(ctx context.Context, entity *types.HealthCheck) error
func (*HealthCheckManager) List ¶
func (m *HealthCheckManager) List(ctx context.Context, opts types.HealthCheckFilterOptions) ([]*types.HealthCheck, error)
type ServiceManager ¶
type ServiceManager struct {
// contains filtered or unexported fields
}
func (*ServiceManager) DockerClient ¶
func (m *ServiceManager) DockerClient() *client.Client
func (*ServiceManager) List ¶
func (m *ServiceManager) List(ctx context.Context, opts types.ServiceFilterOptions) ([]*types.Service, error)
func (*ServiceManager) Redeploy ¶
func (m *ServiceManager) Redeploy(ctx context.Context, id string) error
func (*ServiceManager) ServiceCreate ¶
func (*ServiceManager) ServiceDelete ¶
func (m *ServiceManager) ServiceDelete(ctx context.Context, id string) error
func (*ServiceManager) ServiceGetByID ¶
func (*ServiceManager) ServiceGetByName ¶
func (*ServiceManager) ServiceLogsByID ¶
func (*ServiceManager) ServiceRawByID ¶
func (*ServiceManager) ServiceStop ¶
func (m *ServiceManager) ServiceStop(ctx context.Context, id string) error
func (*ServiceManager) ServiceTaskListByID ¶
func (*ServiceManager) ServiceUpdate ¶
type ServiceMongo ¶
type ServiceMongo struct { }
func (*ServiceMongo) Delete ¶
func (repo *ServiceMongo) Delete(ctx context.Context, id string) error
func (*ServiceMongo) Find ¶
func (repo *ServiceMongo) Find(ctx context.Context, opts types.ServiceFilterOptions) ([]*types.Service, error)
func (*ServiceMongo) FindByName ¶
func (*ServiceMongo) FindOne ¶
func (repo *ServiceMongo) FindOne(ctx context.Context, opts types.ServiceFilterOptions) (*types.Service, error)
type TaskManager ¶
type TaskManager struct {
// contains filtered or unexported fields
}
func (*TaskManager) DockerClient ¶
func (m *TaskManager) DockerClient() *client.Client
func (*TaskManager) List ¶
func (m *TaskManager) List(ctx context.Context, opts types.TaskListOption) ([]types.Task, error)
Click to show internal directories.
Click to hide internal directories.