client

Documentation

Index

• type Client
  • func NewClient(serverUrl, credentials, namespace string, opts ...Option) (*Client, error)
  • func (c *Client) CancelJob(jobId string) error
  • func (c *Client) Close()
  • func (c *Client) CreateArtifactsStore() error
  • func (c *Client) CreateJobsQueue() error
  • func (c *Client) CreateJobsRepository() error
  • func (c *Client) DeleteArtifactsStore() error
  • func (c *Client) DeleteJobsQueue() error
  • func (c *Client) DeleteJobsRepository() error
  • func (c *Client) DispatchJobs(ctx context.Context, handleJob func(*core.JobRecord, uint64) (bool, error)) error
  • func (c *Client) DownloadLogArtifact(job *core.JobRecord, filePath string) error
  • func (c *Client) DownloadResultsArtifact(job *core.JobRecord, filePath string) error
  • func (c *Client) DownloadScriptArtifact(job *core.JobRecord, filePath string) error
  • func (c *Client) GetQueueStatus() (*core.QueueStatus, error)
  • func (c *Client) LoadJob(jobId string) (*core.JobRecord, uint64, error)
  • func (c *Client) LoadLogArtifact(job *core.JobRecord, writer io.Writer) error
  • func (c *Client) LoadRecentJobs(limit int) ([]*core.JobRecord, error)
  • func (c *Client) LoadResultsArtifact(job *core.JobRecord, writer io.Writer) error
  • func (c *Client) LoadScriptArtifact(job *core.JobRecord, writer io.Writer) error
  • func (c *Client) QueueName() string
  • func (c *Client) SubmitJob(params core.JobParameters) (*core.JobRecord, error)
  • func (c *Client) UpdateJob(job *core.JobRecord, revision uint64) (uint64, error)
  • func (c *Client) UploadLogArtifact(jobId, logFilePath string) (string, error)
  • func (c *Client) UploadResultsArtifact(jobId, resultsFilePath string) (string, error)
  • func (c *Client) UploadScriptArtifact(jobId, scriptFilePath string) (string, error)
• type Option
  • func InitArtifactsStore() Option
  • func InitJobsQueue() Option
  • func InitJobsRepository() Option
  • func Verbose(verbose bool) Option
  • func WithAltQueue(queueName string) Option
  • func WithClientName(clientName string) Option
• type Options

Types

type Client

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

func NewClient

func NewClient(serverUrl, credentials, namespace string, opts ...Option) (*Client, error)

func (*Client) CancelJob

func (c *Client) CancelJob(jobId string) error

func (*Client) Close

func (c *Client) Close()

func (*Client) CreateArtifactsStore

func (c *Client) CreateArtifactsStore() error

func (*Client) CreateJobsQueue

func (c *Client) CreateJobsQueue() error

func (*Client) CreateJobsRepository

func (c *Client) CreateJobsRepository() error

func (*Client) DeleteArtifactsStore

func (c *Client) DeleteArtifactsStore() error

func (*Client) DeleteJobsQueue

func (c *Client) DeleteJobsQueue() error

func (*Client) DeleteJobsRepository

func (c *Client) DeleteJobsRepository() error

func (*Client) DispatchJobs

func (c *Client) DispatchJobs(ctx context.Context, handleJob func(*core.JobRecord, uint64) (bool, error)) error

func (*Client) DownloadLogArtifact

func (c *Client) DownloadLogArtifact(job *core.JobRecord, filePath string) error

func (*Client) DownloadResultsArtifact

func (c *Client) DownloadResultsArtifact(job *core.JobRecord, filePath string) error

func (*Client) DownloadScriptArtifact

func (c *Client) DownloadScriptArtifact(job *core.JobRecord, filePath string) error

func (*Client) GetQueueStatus

func (c *Client) GetQueueStatus() (*core.QueueStatus, error)

func (*Client) LoadJob

func (c *Client) LoadJob(jobId string) (*core.JobRecord, uint64, error)

func (*Client) LoadLogArtifact

func (c *Client) LoadLogArtifact(job *core.JobRecord, writer io.Writer) error

func (*Client) LoadRecentJobs

func (c *Client) LoadRecentJobs(limit int) ([]*core.JobRecord, error)

func (*Client) LoadResultsArtifact

func (c *Client) LoadResultsArtifact(job *core.JobRecord, writer io.Writer) error

func (*Client) LoadScriptArtifact

func (c *Client) LoadScriptArtifact(job *core.JobRecord, writer io.Writer) error

func (*Client) QueueName

func (c *Client) QueueName() string

func (*Client) SubmitJob

func (c *Client) SubmitJob(params core.JobParameters) (*core.JobRecord, error)

func (*Client) UpdateJob

func (c *Client) UpdateJob(job *core.JobRecord, revision uint64) (uint64, error)

func (*Client) UploadLogArtifact

func (c *Client) UploadLogArtifact(jobId, logFilePath string) (string, error)

func (*Client) UploadResultsArtifact

func (c *Client) UploadResultsArtifact(jobId, resultsFilePath string) (string, error)

func (*Client) UploadScriptArtifact

func (c *Client) UploadScriptArtifact(jobId, scriptFilePath string) (string, error)

type Option

type Option func(*Options) error

func InitArtifactsStore

func InitArtifactsStore() Option

func InitJobsQueue

func InitJobsQueue() Option

func InitJobsRepository

func InitJobsRepository() Option

func Verbose

func Verbose(verbose bool) Option

func WithAltQueue

func WithAltQueue(queueName string) Option

func WithClientName

func WithClientName(clientName string) Option

type Options

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