abb

package
v0.0.0-...-748440e Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 28, 2018 License: MIT Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ClusterService 

func ClusterService() types.ClusterService

func EnableHealthCheck 

func EnableHealthCheck()

func GetGroupIDByName 

func GetGroupIDByName(api *slack.RTM) map[string]string

func NewAbbRouter 

func NewAbbRouter() *napnap.Router

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 (c *ClusterDatabase) ClusterByName(ctx context.Context, name string) (*types.Cluster, error)

func (*ClusterDatabase) ClusterCreate 

func (c *ClusterDatabase) ClusterCreate(ctx context.Context, entity *types.Cluster) error

func (*ClusterDatabase) ClusterList 

func (c *ClusterDatabase) ClusterList(ctx context.Context) ([]*types.Cluster, error)

func (*ClusterDatabase) ClusterUpdate 

func (c *ClusterDatabase) ClusterUpdate(ctx context.Context, entity *types.Cluster) error

type ClusterManager 

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

func (*ClusterManager) ClusterByName 

func (manager *ClusterManager) ClusterByName(ctx context.Context, name string) (*types.Cluster, error)

func (*ClusterManager) ClusterCreate 

func (manager *ClusterManager) ClusterCreate(ctx context.Context, target *types.Cluster) error

func (*ClusterManager) ClusterList 

func (manager *ClusterManager) ClusterList(ctx context.Context) ([]*types.Cluster, error)

func (*ClusterManager) ClusterUpdate 

func (manager *ClusterManager) ClusterUpdate(ctx context.Context, target *types.Cluster) error

type ClusterMongo 

type ClusterMongo struct {
}

func (*ClusterMongo) ClusterByName 

func (c *ClusterMongo) ClusterByName(ctx context.Context, name string) (*types.Cluster, error)

func (*ClusterMongo) ClusterCreate 

func (c *ClusterMongo) ClusterCreate(ctx context.Context, target *types.Cluster) error

func (*ClusterMongo) ClusterList 

func (c *ClusterMongo) ClusterList(ctx context.Context) ([]*types.Cluster, error)

func (*ClusterMongo) ClusterUpdate 

func (c *ClusterMongo) ClusterUpdate(ctx context.Context, target *types.Cluster) error

type ConfigManager 

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

func (*ConfigManager) Close 

func (m *ConfigManager) Close(ctx context.Context) error

func (*ConfigManager) Create 

func (m *ConfigManager) Create(ctx context.Context, config *types.Config) error

func (*ConfigManager) Delete 

func (m *ConfigManager) Delete(ctx context.Context, configID string) error

func (*ConfigManager) DockerClient 

func (m *ConfigManager) DockerClient() *client.Client

func (*ConfigManager) Get 

func (m *ConfigManager) Get(ctx context.Context, configID string) (*types.Config, error)

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 (m *ServiceManager) ServiceCreate(ctx context.Context, target *types.Service) error

func (*ServiceManager) ServiceDelete 

func (m *ServiceManager) ServiceDelete(ctx context.Context, id string) error

func (*ServiceManager) ServiceGetByID 

func (m *ServiceManager) ServiceGetByID(ctx context.Context, id string) (*types.Service, error)

func (*ServiceManager) ServiceGetByName 

func (m *ServiceManager) ServiceGetByName(ctx context.Context, name string) (*types.Service, error)

func (*ServiceManager) ServiceLogsByID 

func (m *ServiceManager) ServiceLogsByID(ctx context.Context, id string) (string, error)

func (*ServiceManager) ServiceRawByID 

func (m *ServiceManager) ServiceRawByID(ctx context.Context, id string) (*swarm.Service, error)

func (*ServiceManager) ServiceStop 

func (m *ServiceManager) ServiceStop(ctx context.Context, id string) error

func (*ServiceManager) ServiceTaskListByID 

func (m *ServiceManager) ServiceTaskListByID(ctx context.Context, id string) ([]swarm.Task, error)

func (*ServiceManager) ServiceUpdate 

func (m *ServiceManager) ServiceUpdate(ctx context.Context, target *types.Service) error

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) FindByID 

func (repo *ServiceMongo) FindByID(ctx context.Context, id string) (*types.Service, error)

func (*ServiceMongo) FindByName 

func (repo *ServiceMongo) FindByName(ctx context.Context, name string) (*types.Service, error)

func (*ServiceMongo) FindOne 

func (repo *ServiceMongo) FindOne(ctx context.Context, opts types.ServiceFilterOptions) (*types.Service, error)

func (*ServiceMongo) Insert 

func (repo *ServiceMongo) Insert(ctx context.Context, target *types.Service) error

func (*ServiceMongo) Update 

func (repo *ServiceMongo) Update(ctx context.Context, target *types.Service) error

type TaskManager 

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

func (*TaskManager) Close 

func (m *TaskManager) Close(ctx context.Context) error

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.