job

Documentation

Index

• Constants
• func RunnerIsValid(runner, registry string) error
• type Config
  • func (c Config) IsValid(registry string) error
• type InputData
  • func (d InputData) GetSiteURL() string
  • func (d InputData) SetSiteURL(siteURL string)
  • func (d InputData) ToEnv() []string
• type Job
• type ServiceConfig
  • func (c ServiceConfig) IsValid(registry string) error
• type StopCb
• type Type

Constants

const (
	MinSupportedRecorderVersion    = "0.6.0"
	MinSupportedTranscriberVersion = "0.1.0"
	RecordingJobPrefix             = "calls-recorder"
	TranscribingJobPrefix          = "calls-transcriber"
	ImageRegistryDefault           = "mattermost"

	InputDataSiteURLKey = "site_url"
)

Functions

func RunnerIsValid

func RunnerIsValid(runner, registry string) error

Types

type Config

type Config struct {
	Type           Type      `json:"type"`
	MaxDurationSec int64     `json:"max_duration_sec"`
	Runner         string    `json:"runner"`
	InputData      InputData `json:"input_data,omitempty"`
}

func (Config) IsValid

func (c Config) IsValid(registry string) error

type InputData

type InputData map[string]any

func (InputData) GetSiteURL

func (d InputData) GetSiteURL() string

func (InputData) SetSiteURL

func (d InputData) SetSiteURL(siteURL string)

func (InputData) ToEnv

func (d InputData) ToEnv() []string

type Job

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

type ServiceConfig

type ServiceConfig struct {
	Runners []string
}

func (ServiceConfig) IsValid

func (c ServiceConfig) IsValid(registry string) error

type StopCb

type StopCb func(job Job, success bool) error

type Type

type Type string

const (
	TypeRecording    Type = "recording"
	TypeTranscribing Type = "transcribing"
)