domain

Documentation

Index

• func ConvertParamsToProto(submitRequests *v1.SubmitRequestJSONRequestBody) (requests []*generated.Request)
• func ConvertProtoToInputParams(r *generated.Request) (o *v1.SubmitRequestInput)
• func ConvertProtoToOutputParams(r *generated.Request) (o *v1.SubmitRequestInput)
• type Comms
• type Config
• type Converter
• type Processor
• type Storage

Functions

func ConvertParamsToProto

func ConvertParamsToProto(submitRequests *v1.SubmitRequestJSONRequestBody) (requests []*generated.Request)

func ConvertProtoToInputParams

func ConvertProtoToInputParams(r *generated.Request) (o *v1.SubmitRequestInput)

func ConvertProtoToOutputParams

func ConvertProtoToOutputParams(r *generated.Request) (o *v1.SubmitRequestInput)

Types

type Comms

type Comms interface {
	RequestChan() chan pb.Request
	SendRequest(req *pb.Request) error
}

type Config

type Config struct {
	SubmittedWith       string   `env:"SUBMITTED_WITH" envDefault:"api"`
	ApiHttpPort         int      `env:"API_HTTP_PORT" envDefault:"8080"`
	MinTextBlockSize    uint32   `env:"MIN_TEXT_BLOCK_SIZE" envDefault:"100"`
	WordsPerMinute      uint32   `env:"WORDS_PER_MINUTE" envDefault:"350"`
	EspeakVoice         string   `env:"ESPEAK_VOICE" envDefault:"f5"`
	Atempo              string   `env:"ATEMPO" envDefault:"2.0"`
	TitleLengthLimit    uint32   `env:"TITLE_LENGTH_LIMIT" envDefault:"40"`
	ChownTo             int      `env:"CHOWN_TO" envDefault:"1000"`
	LogLevel            string   `env:"LOG_LEVEL" envDefault:"debug"`
	LocalPath           string   `env:"LOCAL_PATH" envDefault:"./.docker/data"`
	TmpPath             string   `env:"TMP_PATH" envDefault:"/tmp"`
	Channels            []string `env:"CHANNELS" envDefault:"content"`
	RequestProcessorUri string   `env:"REQUEST_PROCESSOR_URI" envDefault:"http://localhost:8080/v1"`
	DDAgentHost         string   `env:"DD_AGENT_HOST" envDefault:"localhost"`
	DDAgentPort         int      `env:"DD_AGENT_PORT" envDefault:"8125"`
}

type Converter

type Converter interface {
	Convert(*pb.Request) error
}

type Processor

type Processor interface {
	Process(*pb.Request) error
}

type Storage

type Storage interface {
	Store(*pb.Request) error
	Load(requestHash string) (*pb.Request, error)
	ListAll() []*pb.Request
	Close() error
}