Documentation ¶
Index ¶
- func NewMsgBus() *msgbus.MsgClient
- type Build
- func (b *Build) BuildInit()
- func (b *Build) DeleteJob(jobName string) error
- func (b *Build) GetJobStatus(jobName string) int
- func (b *Build) LaunchAndMonitorBuild(jobName string, node internal.Node) error
- func (b *Build) LaunchBuildJob(jobName *string, image *string, cmd []string, nodetype *string, ...) error
- func (b *Build) ListBuildJobs()
- func (b *Build) ListPods()
- func (b *Build) PublishEvent(uuid string, state string) error
- func (b *Build) WatcherForBuildJobs()
- type BuildOps
- type NodeMetaData
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Build ¶
type Build struct {
// contains filtered or unexported fields
}
func (*Build) LaunchAndMonitorBuild ¶
Go routine to start build process
func (*Build) LaunchBuildJob ¶
func (b *Build) LaunchBuildJob(jobName *string, image *string, cmd []string, nodetype *string, jNodeMetaData []byte) error
Launch Build Job in K8 cluster
func (*Build) WatcherForBuildJobs ¶
func (b *Build) WatcherForBuildJobs()
Watching for changes in job status
type BuildOps ¶
type BuildOps interface { BuildInit() GetJobStatus(jobName string) int DeleteJob(jobName string) error ListBuildJobs() ListPods() WatcherForBuildJobs() error LaunchAndMonitorBuild(jobName string, node internal.Node) error LaunchBuildJob(jobName *string, image *string, cmd []string, nodetype *string, jNodeMetaData []byte) error }
Click to show internal directories.
Click to hide internal directories.