Documentation
¶
Index ¶
- type AbstractService
- func (t *AbstractService) Close()
- func (t *AbstractService) ConfigureRouter(r *gin.RouterGroup)
- func (t *AbstractService) GetLogger() *logrus.Entry
- func (t *AbstractService) GetMode() string
- func (t *AbstractService) GetName() string
- func (t *AbstractService) GetService(name string) Service
- func (t *AbstractService) IsDisabled() bool
- func (t *AbstractService) SetDisabled(value bool)
- func (t *AbstractService) SetMode(value string)
- type ClientFactory
- type DockerClientFactory
- type DockerEventListener
- type DockerTemplate
- type Service
- type SingleContainerService
- func (t *SingleContainerService) Exec1(command []string) (string, error)
- func (t *SingleContainerService) ExecInteractive(command []string) (string, io.Reader, io.Writer, error)
- func (t *SingleContainerService) FollowLogs(since string, tail string) (<-chan string, func(), error)
- func (t *SingleContainerService) FollowLogs2() (<-chan string, func(), error)
- func (t *SingleContainerService) GetContainer() (*types.ContainerJSON, error)
- func (t *SingleContainerService) GetContainerId() string
- func (t *SingleContainerService) GetContainerStatus() (string, error)
- func (t *SingleContainerService) GetLogs(since string, tail string) ([]string, error)
- func (t *SingleContainerService) GetStatus(ctx context.Context) string
- func (t *SingleContainerService) Getenv(key string) (string, error)
- func (t *SingleContainerService) OnEvent(kind string)
- func (t *SingleContainerService) WaitContainer() *types.ContainerJSON
- func (t *SingleContainerService) WaitContainerRunning() *types.ContainerJSON
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AbstractService ¶
type AbstractService struct {
// contains filtered or unexported fields
}
func NewAbstractService ¶
func NewAbstractService(name string, services map[string]Service) *AbstractService
func (*AbstractService) Close ¶
func (t *AbstractService) Close()
func (*AbstractService) ConfigureRouter ¶
func (t *AbstractService) ConfigureRouter(r *gin.RouterGroup)
func (*AbstractService) GetLogger ¶
func (t *AbstractService) GetLogger() *logrus.Entry
func (*AbstractService) GetMode ¶
func (t *AbstractService) GetMode() string
func (*AbstractService) GetName ¶
func (t *AbstractService) GetName() string
func (*AbstractService) GetService ¶
func (t *AbstractService) GetService(name string) Service
func (*AbstractService) IsDisabled ¶
func (t *AbstractService) IsDisabled() bool
func (*AbstractService) SetDisabled ¶
func (t *AbstractService) SetDisabled(value bool)
func (*AbstractService) SetMode ¶
func (t *AbstractService) SetMode(value string)
type ClientFactory ¶
type ClientFactory struct {
// contains filtered or unexported fields
}
func NewClientFactory ¶
func NewClientFactory() (*ClientFactory, error)
func (*ClientFactory) GetSharedInstance ¶
func (t *ClientFactory) GetSharedInstance() *docker.Client
func (*ClientFactory) NewInstance ¶
func (t *ClientFactory) NewInstance() (*docker.Client, error)
type DockerClientFactory ¶
type DockerEventListener ¶
type DockerEventListener interface {
OnEvent(type_ string)
}
type DockerTemplate ¶
type DockerTemplate struct {
// contains filtered or unexported fields
}
type Service ¶
type Service interface {
io.Closer
DockerEventListener
ConfigureRouter(r *gin.RouterGroup)
GetName() string
GetStatus(ctx context.Context) string
GetContainerId() string
IsDisabled() bool
SetDisabled(value bool)
GetMode() string
SetMode(value string)
GetLogs(since string, tail string) ([]string, error)
FollowLogs(since string, tail string) (<-chan string, func(), error)
}
type SingleContainerService ¶
type SingleContainerService struct {
*AbstractService
// contains filtered or unexported fields
}
func (*SingleContainerService) Exec1 ¶
func (t *SingleContainerService) Exec1(command []string) (string, error)
func (*SingleContainerService) ExecInteractive ¶
func (t *SingleContainerService) ExecInteractive(command []string) (string, io.Reader, io.Writer, error)
Exec1 is a shortcut function
func (*SingleContainerService) FollowLogs ¶
func (t *SingleContainerService) FollowLogs(since string, tail string) (<-chan string, func(), error)
func (*SingleContainerService) FollowLogs2 ¶
func (t *SingleContainerService) FollowLogs2() (<-chan string, func(), error)
func (*SingleContainerService) GetContainer ¶
func (t *SingleContainerService) GetContainer() (*types.ContainerJSON, error)
func (*SingleContainerService) GetContainerId ¶
func (t *SingleContainerService) GetContainerId() string
func (*SingleContainerService) GetContainerStatus ¶
func (t *SingleContainerService) GetContainerStatus() (string, error)
func (*SingleContainerService) GetLogs ¶
func (t *SingleContainerService) GetLogs(since string, tail string) ([]string, error)
func (*SingleContainerService) GetStatus ¶
func (t *SingleContainerService) GetStatus(ctx context.Context) string
GetStatus implements Service interface
func (*SingleContainerService) Getenv ¶
func (t *SingleContainerService) Getenv(key string) (string, error)
func (*SingleContainerService) OnEvent ¶
func (t *SingleContainerService) OnEvent(kind string)
func (*SingleContainerService) WaitContainer ¶
func (t *SingleContainerService) WaitContainer() *types.ContainerJSON
func (*SingleContainerService) WaitContainerRunning ¶
func (t *SingleContainerService) WaitContainerRunning() *types.ContainerJSON
Source Files
Click to show internal directories.
Click to hide internal directories.