messages

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

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"
)

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