clientmanager

Documentation

Index

• Constants
• func InitDBClient(initConnectionTimeout time.Duration) *storage.DB
• type ClientManager
  • func NewClientManager() ClientManager
  • func (c *ClientManager) Authenticators() []auth.Authenticator
  • func (c *ClientManager) Close()
  • func (c *ClientManager) DBStatusStore() storage.DBStatusStoreInterface
  • func (c *ClientManager) DefaultExperimentStore() storage.DefaultExperimentStoreInterface
  • func (c *ClientManager) ExecClient() util.ExecutionClient
  • func (c *ClientManager) ExperimentStore() storage.ExperimentStoreInterface
  • func (c *ClientManager) JobStore() storage.JobStoreInterface
  • func (c *ClientManager) KubernetesCoreClient() client.KubernetesCoreInterface
  • func (c *ClientManager) LogArchive() archive.LogArchiveInterface
  • func (c *ClientManager) ObjectStore() storage.ObjectStoreInterface
  • func (c *ClientManager) PipelineStore() storage.PipelineStoreInterface
  • func (c *ClientManager) ResourceReferenceStore() storage.ResourceReferenceStoreInterface
  • func (c *ClientManager) RunStore() storage.RunStoreInterface
  • func (c *ClientManager) SubjectAccessReviewClient() client.SubjectAccessReviewInterface
  • func (c *ClientManager) SwfClient() client.SwfClientInterface
  • func (c *ClientManager) TaskStore() storage.TaskStoreInterface
  • func (c *ClientManager) Time() util.TimeInterface
  • func (c *ClientManager) TokenReviewClient() client.TokenReviewInterface
  • func (c *ClientManager) UUID() util.UUIDGeneratorInterface

Constants

const (
	VisualizationServiceHost = "ML_PIPELINE_VISUALIZATIONSERVER_SERVICE_HOST"
	VisualizationServicePort = "ML_PIPELINE_VISUALIZATIONSERVER_SERVICE_PORT"
)

Functions

func InitDBClient

func InitDBClient(initConnectionTimeout time.Duration) *storage.DB

Types

type ClientManager

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

Container for all service clients.

func NewClientManager

func NewClientManager() ClientManager

NewClientManager creates and Init a new instance of ClientManager.

func (*ClientManager) Authenticators

func (c *ClientManager) Authenticators() []auth.Authenticator

func (*ClientManager) Close

func (c *ClientManager) Close()

func (*ClientManager) DBStatusStore

func (c *ClientManager) DBStatusStore() storage.DBStatusStoreInterface

func (*ClientManager) DefaultExperimentStore

func (c *ClientManager) DefaultExperimentStore() storage.DefaultExperimentStoreInterface

func (*ClientManager) ExecClient

func (c *ClientManager) ExecClient() util.ExecutionClient

func (*ClientManager) ExperimentStore

func (c *ClientManager) ExperimentStore() storage.ExperimentStoreInterface

func (*ClientManager) JobStore

func (c *ClientManager) JobStore() storage.JobStoreInterface

func (*ClientManager) KubernetesCoreClient

func (c *ClientManager) KubernetesCoreClient() client.KubernetesCoreInterface

func (*ClientManager) LogArchive

func (c *ClientManager) LogArchive() archive.LogArchiveInterface

func (*ClientManager) ObjectStore

func (c *ClientManager) ObjectStore() storage.ObjectStoreInterface

func (*ClientManager) PipelineStore

func (c *ClientManager) PipelineStore() storage.PipelineStoreInterface

func (*ClientManager) ResourceReferenceStore

func (c *ClientManager) ResourceReferenceStore() storage.ResourceReferenceStoreInterface

func (*ClientManager) RunStore

func (c *ClientManager) RunStore() storage.RunStoreInterface

func (*ClientManager) SubjectAccessReviewClient

func (c *ClientManager) SubjectAccessReviewClient() client.SubjectAccessReviewInterface

func (*ClientManager) SwfClient

func (c *ClientManager) SwfClient() client.SwfClientInterface

func (*ClientManager) TaskStore

func (c *ClientManager) TaskStore() storage.TaskStoreInterface

func (*ClientManager) Time

func (c *ClientManager) Time() util.TimeInterface

func (*ClientManager) TokenReviewClient

func (c *ClientManager) TokenReviewClient() client.TokenReviewInterface

func (*ClientManager) UUID

func (c *ClientManager) UUID() util.UUIDGeneratorInterface