manager

package
v0.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 9, 2023 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL