messages

package
v0.5.3 Latest Latest
Warning

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

Go to latest
Published: Nov 24, 2023 License: GPL-3.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

View Source
const (

	// Upload queue name
	Upload = st + "Work:wrk-upload"
	// Work queue name
	Work = st + "Work"
	// Inform  queue name
	Inform = st + "Inform"
	// StatusChange queue name
	StatusChange = st + "StatusChange"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ASRMessage

type ASRMessage struct {
	amessages.QueueMessage
	RequestID string `json:"requestID,omitempty"`
}

ASRMessage main message passing through in roxy asr system

func NewMessageFrom

func NewMessageFrom(m *ASRMessage) *ASRMessage

NewMessageFrom creates a copy of a message

type CleanMessage

type CleanMessage struct {
	amessages.QueueMessage
	ExternalID  string `json:"extID,omitempty"`
	Transcriber string `json:"transcriber,omitempty"`
}

CleanMessage message to clean external data

type Options

type Options struct {
	Queue string
	After time.Duration
}

ASRMessage main message passing through in roxy asr system

func DefaultOpts

func DefaultOpts(queue string) *Options

func (*Options) Delay

func (opt *Options) Delay(after time.Duration) *Options

type StatusMessage

type StatusMessage struct {
	amessages.QueueMessage
	Status           string   `json:"status,omitempty"`
	Error            string   `json:"error,omitempty"`
	Progress         int      `json:"progress,omitempty"`
	ErrorCode        string   `json:"errorCode,omitempty"`
	AudioReady       bool     `json:"audioReady,omitempty"`
	AvailableResults []string `json:"avResults,omitempty"`
	ExternalID       string   `json:"extID,omitempty"`
	RecognizedText   string   `json:"recognizedText,omitempty"`

	Transcriber string `json:"transcriber,omitempty"`
}

StatusMessage main message passing through in roxy asr system

Jump to

Keyboard shortcuts

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