service

Documentation

Index

• Constants
• func JobRunnerIsValid(runner string) error
• type APIConfig
  • func (c APIConfig) IsValid() error
• type Client
  • func NewClient(cfg ClientConfig, opts ...ClientOption) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) CreateJob(cfg JobConfig) (Job, error)
  • func (c *Client) GetJob(jobID string) (Job, error)
  • func (c *Client) GetJobLogs(jobID string) ([]byte, error)
  • func (c *Client) Login(clientID string, authKey string) error
  • func (c *Client) Register(clientID string, authKey string) error
  • func (c *Client) StopJob(jobID string) error
  • func (c *Client) Unregister(clientID string) error
  • func (c *Client) UpdateJobRunner(runner string) error
• type ClientConfig
  • func (c *ClientConfig) Parse() error
• type ClientOption
  • func WithDialFunc(dialFn DialContextFn) ClientOption
• type Config
  • func (c Config) IsValid() error
  • func (c *Config) SetDefaults()
• type DialContextFn
• type Job
• type JobAPIType
• type JobConfig
  • func (c JobConfig) IsValid() error
• type JobService
  • func NewJobService(cfg JobsConfig, log *mlog.Logger) (*JobService, error)
  • func (s *JobService) CreateRecordingJobDocker(cfg JobConfig, onStopCb stopCb) (Job, error)
  • func (s *JobService) RecordingJobLogsDocker(jobID string) ([]byte, error)
  • func (s *JobService) RemoveRecordingJobDocker(jobID string) error
  • func (s *JobService) StopRecordingJobDocker(jobID string) error
  • func (s *JobService) UpdateJobRunnerDocker(runner string) error
• type JobType
• type JobsConfig
  • func (c JobsConfig) IsValid() error
• type RecordingJobInputData
  • func (c *RecordingJobInputData) FromMap(m map[string]any) *RecordingJobInputData
  • func (c RecordingJobInputData) IsValid() error
  • func (c *RecordingJobInputData) ToEnv() []string
  • func (c *RecordingJobInputData) ToMap() map[string]any
• type SecurityConfig
  • func (c SecurityConfig) IsValid() error
• type Service
  • func New(cfg Config) (*Service, error)
  • func (s *Service) DeleteJob(jobID string) error
  • func (s *Service) GetJob(jobID string) (Job, error)
  • func (s *Service) SaveJob(job Job) error
  • func (s *Service) Start() error
  • func (s *Service) Stop() error
• type StoreConfig
  • func (c StoreConfig) IsValid() error

Constants

const (
	JobAPITypeDocker     = "docker"
	JobAPITypeKubernetes = "kubernetes"
)

Functions

func JobRunnerIsValid

func JobRunnerIsValid(runner string) error

Types

type APIConfig

type APIConfig struct {
	HTTP     api.Config     `toml:"http"`
	Security SecurityConfig `toml:"security"`
}

func (APIConfig) IsValid

func (c APIConfig) IsValid() error

type Client

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

func NewClient

func NewClient(cfg ClientConfig, opts ...ClientOption) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) CreateJob

func (c *Client) CreateJob(cfg JobConfig) (Job, error)

func (*Client) GetJob

func (c *Client) GetJob(jobID string) (Job, error)

func (*Client) GetJobLogs

func (c *Client) GetJobLogs(jobID string) ([]byte, error)

func (*Client) Login

func (c *Client) Login(clientID string, authKey string) error

func (*Client) Register

func (c *Client) Register(clientID string, authKey string) error

func (*Client) StopJob

func (c *Client) StopJob(jobID string) error

func (*Client) Unregister

func (c *Client) Unregister(clientID string) error

func (*Client) UpdateJobRunner

func (c *Client) UpdateJobRunner(runner string) error

type ClientConfig

type ClientConfig struct {
	ClientID string
	AuthKey  string
	URL      string
	// contains filtered or unexported fields
}

func (*ClientConfig) Parse

func (c *ClientConfig) Parse() error

type ClientOption

type ClientOption func(c *Client) error

func WithDialFunc

func WithDialFunc(dialFn DialContextFn) ClientOption

WithDialFunc lets the caller set an optional dialing function to setup the HTTP/WebSocket connections used by the client.

type Config

type Config struct {
	API    APIConfig
	Store  StoreConfig
	Jobs   JobsConfig
	Logger logger.Config
}

func (Config) IsValid

func (c Config) IsValid() error

func (*Config) SetDefaults

func (c *Config) SetDefaults()

type DialContextFn

type DialContextFn func(ctx context.Context, network, addr string) (net.Conn, error)

type Job

type Job struct {
	JobConfig
	ID         string         `json:"id"`
	StartAt    int64          `json:"start_at"`
	StopAt     int64          `json:"stop_at,omitempty"`
	OutputData map[string]any `json:"output_data,omitempty"`
}

type JobAPIType

type JobAPIType string

type JobConfig

type JobConfig struct {
	Type           JobType        `json:"type"`
	MaxDurationSec int64          `json:"max_duration_sec"`
	Runner         string         `json:"runner"`
	InputData      map[string]any `json:"input_data,omitempty"`
}

func (JobConfig) IsValid

func (c JobConfig) IsValid() error

type JobService

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

func NewJobService

func NewJobService(cfg JobsConfig, log *mlog.Logger) (*JobService, error)

func (*JobService) CreateRecordingJobDocker

func (s *JobService) CreateRecordingJobDocker(cfg JobConfig, onStopCb stopCb) (Job, error)

func (*JobService) RecordingJobLogsDocker

func (s *JobService) RecordingJobLogsDocker(jobID string) ([]byte, error)

func (*JobService) RemoveRecordingJobDocker

func (s *JobService) RemoveRecordingJobDocker(jobID string) error

func (*JobService) StopRecordingJobDocker

func (s *JobService) StopRecordingJobDocker(jobID string) error

func (*JobService) UpdateJobRunnerDocker

func (s *JobService) UpdateJobRunnerDocker(runner string) error

type JobType

type JobType string

const (
	JobTypeRecording JobType = "recording"
)

type JobsConfig

type JobsConfig struct {
	APIType           JobAPIType `toml:"api_type"`
	MaxConcurrentJobs int        `toml:"max_concurrent_jobs"`
}

func (JobsConfig) IsValid

func (c JobsConfig) IsValid() error

type RecordingJobInputData

type RecordingJobInputData struct {
	SiteURL   string `json:"site_url"`
	CallID    string `json:"call_id"`
	ThreadID  string `json:"thread_id"`
	AuthToken string `json:"auth_token"`
}

func (*RecordingJobInputData) FromMap

func (c *RecordingJobInputData) FromMap(m map[string]any) *RecordingJobInputData

func (RecordingJobInputData) IsValid

func (c RecordingJobInputData) IsValid() error

func (*RecordingJobInputData) ToEnv

func (c *RecordingJobInputData) ToEnv() []string

func (*RecordingJobInputData) ToMap

func (c *RecordingJobInputData) ToMap() map[string]any

type SecurityConfig

type SecurityConfig struct {
	// Whether or not to enable admin API access.
	EnableAdmin bool `toml:"enable_admin"`
	// The secret key used to authenticate admin requests.
	AdminSecretKey string `toml:"admin_secret_key"`
	// Whether or not to allow clients to self-register.
	AllowSelfRegistration bool                    `toml:"allow_self_registration"`
	SessionCache          auth.SessionCacheConfig `toml:"session_cache"`
}

func (SecurityConfig) IsValid

func (c SecurityConfig) IsValid() error

type Service

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

func New

func New(cfg Config) (*Service, error)

func (*Service) DeleteJob

func (s *Service) DeleteJob(jobID string) error

func (*Service) GetJob

func (s *Service) GetJob(jobID string) (Job, error)

func (*Service) SaveJob

func (s *Service) SaveJob(job Job) error

func (*Service) Start

func (s *Service) Start() error

func (*Service) Stop

func (s *Service) Stop() error

type StoreConfig

type StoreConfig struct {
	DataSource string `toml:"data_source"`
}

func (StoreConfig) IsValid

func (c StoreConfig) IsValid() error