manager

Documentation

Index

• func Execute()
• func StartWorkerService(data *ServiceData) error
• type FakeMessageSender
  • func NewFakeMessageSender() *FakeMessageSender
  • func (fms *FakeMessageSender) Send(message messages.Message, queue string, replyQueue string) error
• type ResultSaver
• type ServiceData
• type SpeechIndicator

Functions

func Execute

func Execute()

Execute starts the server

func StartWorkerService

func StartWorkerService(data *ServiceData) error

StartWorkerService starts the event queue listener service to listen for events

Types

type FakeMessageSender

type FakeMessageSender struct {
}

FakeMessageSender is mail sender doing nothing

func NewFakeMessageSender

func NewFakeMessageSender() *FakeMessageSender

NewFakeMessageSender inits new instance

func (*FakeMessageSender) Send

func (fms *FakeMessageSender) Send(message messages.Message, queue string, replyQueue string) error

Send does nothing

type ResultSaver

type ResultSaver interface {
	Save(ID string, result string) error
}

ResultSaver saves the transcription result into db

type ServiceData

type ServiceData struct {
	MessageSender       messages.Sender
	InformMessageSender messages.Sender
	Publisher           messages.Publisher
	StatusSaver         status.Saver
	ResultSaver         ResultSaver
	DecodeCh            <-chan amqp.Delivery
	SplitChannelsCh     <-chan amqp.Delivery
	AudioConvertCh      <-chan amqp.Delivery
	DiarizationCh       <-chan amqp.Delivery
	TranscriptionCh     <-chan amqp.Delivery
	RescoreCh           <-chan amqp.Delivery
	ResultMakeCh        <-chan amqp.Delivery
	// contains filtered or unexported fields
}

ServiceData keeps data required for service work

type SpeechIndicator

type SpeechIndicator interface {
	Test(string) (bool, error)
}

SpeechIndicator looks if request audio has speech