messages

package

v0.6.1 Latest Latest Go to latest Published: Aug 23, 2024 License: GPL-3.0 Imports: 2 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/airenas/roxy

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type ASRMessage
- func NewMessageFrom(m *ASRMessage) *ASRMessage
type CleanMessage
type Options
- func DefaultOpts(queue string) *Options
- func (opt *Options) Delay(after time.Duration) *Options
type StatusMessage

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

Source Files ¶

View all Source files

messages.go

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