Documentation ¶
Index ¶
- func InitBus(busType string, config interface{}) error
- func InitConsumer(topic string) chan []byte
- func InitLogger(handle io.Writer, prefix string) *log.Logger
- func InitProducer(topic string) chan []byte
- func TopicExists(topic string) <-chan bool
- func UUID() string
- type App
- type AppInstance
- func (a *AppInstance) ApplicationsGet(ApplicationName string) (*Application, error)
- func (a *AppInstance) ApplicationsList() (*[]Application, error)
- func (a *AppInstance) ApplicationsSubscribe(ApplicationName string, EventSource string) (*Application, error)
- func (a *AppInstance) ApplicationsUnsubscribe(ApplicationName string, EventSource string) (*Application, error)
- func (a *AppInstance) AsteriskGetGlobalVar(Var string) (*Variable, error)
- func (a *AppInstance) AsteriskGetInfo(options ...string) (*AsteriskInfo, error)
- func (a *AppInstance) AsteriskSetGlobalVar(Var string, options ...string) error
- func (a *AppInstance) BridgesAddChannel(BridgeID string, Channel string, options ...string) error
- func (a *AppInstance) BridgesCreate(options ...string) (*Bridge, error)
- func (a *AppInstance) BridgesCreate_Or_Update_With_ID(BridgeID string, options ...string) (*Bridge, error)
- func (a *AppInstance) BridgesDestroy(BridgeID string) error
- func (a *AppInstance) BridgesGet(BridgeID string) (*Bridge, error)
- func (a *AppInstance) BridgesList() (*[]Bridge, error)
- func (a *AppInstance) BridgesPlay(BridgeID string, Media string, options ...string) (*Playback, error)
- func (a *AppInstance) BridgesPlayWithID(BridgeID string, PlaybackID string, Media string, options ...string) (*Playback, error)
- func (a *AppInstance) BridgesRecord(BridgeID string, Name string, Format string, options ...string) (*LiveRecording, error)
- func (a *AppInstance) BridgesRemoveChannel(BridgeID string, Channel string) error
- func (a *AppInstance) BridgesStartMoh(BridgeID string, options ...string) error
- func (a *AppInstance) BridgesStopMoh(BridgeID string) error
- func (a *AppInstance) ChannelsAnswer(ChannelID string) error
- func (a *AppInstance) ChannelsContinueInDialplan(ChannelID string, options ...string) error
- func (a *AppInstance) ChannelsGet(ChannelID string) (*Channel, error)
- func (a *AppInstance) ChannelsGetChannelVar(ChannelID string, Var string) (*Variable, error)
- func (a *AppInstance) ChannelsHangup(ChannelID string, options ...string) error
- func (a *AppInstance) ChannelsHold(ChannelID string) error
- func (a *AppInstance) ChannelsList() (*[]Channel, error)
- func (a *AppInstance) ChannelsMute(ChannelID string, options ...string) error
- func (a *AppInstance) ChannelsOriginate(Endpoint string, options ...string) (*Channel, error)
- func (a *AppInstance) ChannelsOriginateWithID(ChannelID string, Endpoint string, options ...string) (*Channel, error)
- func (a *AppInstance) ChannelsPlay(ChannelID string, Media string, options ...string) (*Playback, error)
- func (a *AppInstance) ChannelsPlayWithID(ChannelID string, PlaybackID string, Media string, options ...string) (*Playback, error)
- func (a *AppInstance) ChannelsRecord(ChannelID string, Name string, Format string, options ...string) (*LiveRecording, error)
- func (a *AppInstance) ChannelsRing(ChannelID string) error
- func (a *AppInstance) ChannelsRingStop(ChannelID string) error
- func (a *AppInstance) ChannelsSendDTMF(ChannelID string, options ...string) error
- func (a *AppInstance) ChannelsSetChannelVar(ChannelID string, Var string, options ...string) error
- func (a *AppInstance) ChannelsSnoopChannel(ChannelID string, App string, options ...string) (*Channel, error)
- func (a *AppInstance) ChannelsSnoopChannelWithID(ChannelID string, SnoopID string, App string, options ...string) (*Channel, error)
- func (a *AppInstance) ChannelsStartMoh(ChannelID string, options ...string) error
- func (a *AppInstance) ChannelsStartSilence(ChannelID string) error
- func (a *AppInstance) ChannelsStopMoh(ChannelID string) error
- func (a *AppInstance) ChannelsStopSilence(ChannelID string) error
- func (a *AppInstance) ChannelsUnhold(ChannelID string) error
- func (a *AppInstance) ChannelsUnmute(ChannelID string, options ...string) error
- func (a *AppInstance) DeviceStatesDelete(DeviceName string) error
- func (a *AppInstance) DeviceStatesGet(DeviceName string) (*DeviceState, error)
- func (a *AppInstance) DeviceStatesList() (*[]DeviceState, error)
- func (a *AppInstance) DeviceStatesUpdate(DeviceName string, DeviceState string) error
- func (a *AppInstance) EndpointsGet(Tech string, Resource string) (*Endpoint, error)
- func (a *AppInstance) EndpointsList() (*[]Endpoint, error)
- func (a *AppInstance) EndpointsListByTech(Tech string) (*[]Endpoint, error)
- func (a *AppInstance) EndpointsSendMessage(To string, From string, options ...string) error
- func (a *AppInstance) EndpointsSendMessageToEndpoint(Tech string, Resource string, From string, options ...string) error
- func (a *AppInstance) EventsEventWebsocket(App string) (*Message, error)
- func (a *AppInstance) EventsUserEvent(EventName string, Application string, options ...string) error
- func (a *AppInstance) InitAppInstance(instanceID string)
- func (a *AppInstance) MailboxesDelete(MailboxName string) error
- func (a *AppInstance) MailboxesGet(MailboxName string) (*Mailbox, error)
- func (a *AppInstance) MailboxesList() (*[]Mailbox, error)
- func (a *AppInstance) MailboxesUpdate(MailboxName string, OldMessages int, NewMessages int) error
- func (a *AppInstance) PlaybacksControl(PlaybackID string, Operation string) error
- func (a *AppInstance) PlaybacksGet(PlaybackID string) (*Playback, error)
- func (a *AppInstance) PlaybacksStop(PlaybackID string) error
- func (a *AppInstance) RecordingsCancel(RecordingName string) error
- func (a *AppInstance) RecordingsCopyStored(RecordingName string, DestinationRecordingName string) (*StoredRecording, error)
- func (a *AppInstance) RecordingsDeleteStored(RecordingName string) error
- func (a *AppInstance) RecordingsGetLive(RecordingName string) (*LiveRecording, error)
- func (a *AppInstance) RecordingsGetStored(RecordingName string) (*StoredRecording, error)
- func (a *AppInstance) RecordingsListStored() (*[]StoredRecording, error)
- func (a *AppInstance) RecordingsMute(RecordingName string) error
- func (a *AppInstance) RecordingsPause(RecordingName string) error
- func (a *AppInstance) RecordingsStop(RecordingName string) error
- func (a *AppInstance) RecordingsUnmute(RecordingName string) error
- func (a *AppInstance) RecordingsUnpause(RecordingName string) error
- func (a *AppInstance) SoundsGet(SoundID string) (*Sound, error)
- func (a *AppInstance) SoundsList(options ...string) (*[]Sound, error)
- type AppInstanceHandler
- type AppStart
- type Application
- type ApplicationReplaced
- type AsteriskInfo
- type Bridge
- type BridgeAttendedTransfer
- type BridgeBlindTransfer
- type BridgeCreated
- type BridgeDestroyed
- type BridgeMerged
- type BuildInfo
- type CallerID
- type Channel
- type ChannelCallerId
- type ChannelCreated
- type ChannelDestroyed
- type ChannelDialplan
- type ChannelDtmfReceived
- type ChannelEnteredBridge
- type ChannelHangupRequest
- type ChannelLeftBridge
- type ChannelStateChange
- type ChannelTalkingFinished
- type ChannelTalkingStarted
- type ChannelUserevent
- type ChannelVarset
- type Command
- type CommandResponse
- type ConfigInfo
- type DeviceState
- type DeviceStateChanged
- type Dial
- type Dialed
- type DialplanCEP
- type Endpoint
- type EndpointStateChange
- type Event
- type FormatLangPair
- type LiveRecording
- type Mailbox
- type Message
- type MessageBus
- type MissingParams
- type NATS
- type Playback
- type PlaybackFinished
- type PlaybackStarted
- type RabbitMQ
- type RecordingFailed
- type RecordingFinished
- type RecordingStarted
- type SetId
- type Sound
- type StasisEnd
- type StasisStart
- type StatusInfo
- type StoredRecording
- type SystemInfo
- type TextMessage
- type TextMessageReceived
- type TextMessageVariable
- type Variable
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitBus ¶
InitBus will initialize a new message bus. Abstracts the message bus initialization based on the configuration in order to allow the creation of a proxy or client using message bus agnostic methods.
func InitConsumer ¶
InitConsumer initializes a new message bus consumer.
func InitLogger ¶
InitLogger is a wrapper function to provide a sane interface to logging messages.
func InitProducer ¶
InitProducer initializes a new message bus producer.
func TopicExists ¶
TopicExists abstracts the basic function provided by the MessageBus interface. Spawns a goroutine which loops through and waits for a topic to actually exist. Returns a channel immediately which is read by the user of this function to determine topic existence or timeout by way of the normal time.After pattern in a select{}.
Types ¶
type App ¶
App struct contains information about an ARI application. The top level that signals the application instance creation.
func (*App) Init ¶
func (a *App) Init(app string, handler AppInstanceHandler)
Init spawns the goroutine that listens for messages on the signalling channel. Creates a new application instance for the client to utilize. Passes the AppInstance to the AppInstanceHandler function.
type AppInstance ¶
type AppInstance struct { Events chan *Event // contains filtered or unexported fields }
AppInstance struct contains the channels necessary for communication to/from the various message bus topics and the event channel.
func NewAppInstance ¶
func NewAppInstance() *AppInstance
NewAppInstance function is a constructor to allocate the memory of AppInstance.
func (*AppInstance) ApplicationsGet ¶
func (a *AppInstance) ApplicationsGet(ApplicationName string) (*Application, error)
func (*AppInstance) ApplicationsList ¶
func (a *AppInstance) ApplicationsList() (*[]Application, error)
func (*AppInstance) ApplicationsSubscribe ¶
func (a *AppInstance) ApplicationsSubscribe(ApplicationName string, EventSource string) (*Application, error)
func (*AppInstance) ApplicationsUnsubscribe ¶
func (a *AppInstance) ApplicationsUnsubscribe(ApplicationName string, EventSource string) (*Application, error)
func (*AppInstance) AsteriskGetGlobalVar ¶
func (a *AppInstance) AsteriskGetGlobalVar(Var string) (*Variable, error)
func (*AppInstance) AsteriskGetInfo ¶
func (a *AppInstance) AsteriskGetInfo(options ...string) (*AsteriskInfo, error)
func (*AppInstance) AsteriskSetGlobalVar ¶
func (a *AppInstance) AsteriskSetGlobalVar(Var string, options ...string) error
func (*AppInstance) BridgesAddChannel ¶
func (a *AppInstance) BridgesAddChannel(BridgeID string, Channel string, options ...string) error
func (*AppInstance) BridgesCreate ¶
func (a *AppInstance) BridgesCreate(options ...string) (*Bridge, error)
func (*AppInstance) BridgesCreate_Or_Update_With_ID ¶
func (a *AppInstance) BridgesCreate_Or_Update_With_ID(BridgeID string, options ...string) (*Bridge, error)
func (*AppInstance) BridgesDestroy ¶
func (a *AppInstance) BridgesDestroy(BridgeID string) error
func (*AppInstance) BridgesGet ¶
func (a *AppInstance) BridgesGet(BridgeID string) (*Bridge, error)
func (*AppInstance) BridgesList ¶
func (a *AppInstance) BridgesList() (*[]Bridge, error)
func (*AppInstance) BridgesPlay ¶
func (*AppInstance) BridgesPlayWithID ¶
func (*AppInstance) BridgesRecord ¶
func (a *AppInstance) BridgesRecord(BridgeID string, Name string, Format string, options ...string) (*LiveRecording, error)
func (*AppInstance) BridgesRemoveChannel ¶
func (a *AppInstance) BridgesRemoveChannel(BridgeID string, Channel string) error
func (*AppInstance) BridgesStartMoh ¶
func (a *AppInstance) BridgesStartMoh(BridgeID string, options ...string) error
func (*AppInstance) BridgesStopMoh ¶
func (a *AppInstance) BridgesStopMoh(BridgeID string) error
func (*AppInstance) ChannelsAnswer ¶
func (a *AppInstance) ChannelsAnswer(ChannelID string) error
func (*AppInstance) ChannelsContinueInDialplan ¶
func (a *AppInstance) ChannelsContinueInDialplan(ChannelID string, options ...string) error
func (*AppInstance) ChannelsGet ¶
func (a *AppInstance) ChannelsGet(ChannelID string) (*Channel, error)
func (*AppInstance) ChannelsGetChannelVar ¶
func (a *AppInstance) ChannelsGetChannelVar(ChannelID string, Var string) (*Variable, error)
func (*AppInstance) ChannelsHangup ¶
func (a *AppInstance) ChannelsHangup(ChannelID string, options ...string) error
func (*AppInstance) ChannelsHold ¶
func (a *AppInstance) ChannelsHold(ChannelID string) error
func (*AppInstance) ChannelsList ¶
func (a *AppInstance) ChannelsList() (*[]Channel, error)
func (*AppInstance) ChannelsMute ¶
func (a *AppInstance) ChannelsMute(ChannelID string, options ...string) error
func (*AppInstance) ChannelsOriginate ¶
func (a *AppInstance) ChannelsOriginate(Endpoint string, options ...string) (*Channel, error)
func (*AppInstance) ChannelsOriginateWithID ¶
func (*AppInstance) ChannelsPlay ¶
func (*AppInstance) ChannelsPlayWithID ¶
func (*AppInstance) ChannelsRecord ¶
func (a *AppInstance) ChannelsRecord(ChannelID string, Name string, Format string, options ...string) (*LiveRecording, error)
func (*AppInstance) ChannelsRing ¶
func (a *AppInstance) ChannelsRing(ChannelID string) error
func (*AppInstance) ChannelsRingStop ¶
func (a *AppInstance) ChannelsRingStop(ChannelID string) error
func (*AppInstance) ChannelsSendDTMF ¶
func (a *AppInstance) ChannelsSendDTMF(ChannelID string, options ...string) error
func (*AppInstance) ChannelsSetChannelVar ¶
func (a *AppInstance) ChannelsSetChannelVar(ChannelID string, Var string, options ...string) error
func (*AppInstance) ChannelsSnoopChannel ¶
func (*AppInstance) ChannelsSnoopChannelWithID ¶
func (*AppInstance) ChannelsStartMoh ¶
func (a *AppInstance) ChannelsStartMoh(ChannelID string, options ...string) error
func (*AppInstance) ChannelsStartSilence ¶
func (a *AppInstance) ChannelsStartSilence(ChannelID string) error
func (*AppInstance) ChannelsStopMoh ¶
func (a *AppInstance) ChannelsStopMoh(ChannelID string) error
func (*AppInstance) ChannelsStopSilence ¶
func (a *AppInstance) ChannelsStopSilence(ChannelID string) error
func (*AppInstance) ChannelsUnhold ¶
func (a *AppInstance) ChannelsUnhold(ChannelID string) error
func (*AppInstance) ChannelsUnmute ¶
func (a *AppInstance) ChannelsUnmute(ChannelID string, options ...string) error
func (*AppInstance) DeviceStatesDelete ¶
func (a *AppInstance) DeviceStatesDelete(DeviceName string) error
func (*AppInstance) DeviceStatesGet ¶
func (a *AppInstance) DeviceStatesGet(DeviceName string) (*DeviceState, error)
func (*AppInstance) DeviceStatesList ¶
func (a *AppInstance) DeviceStatesList() (*[]DeviceState, error)
func (*AppInstance) DeviceStatesUpdate ¶
func (a *AppInstance) DeviceStatesUpdate(DeviceName string, DeviceState string) error
func (*AppInstance) EndpointsGet ¶
func (a *AppInstance) EndpointsGet(Tech string, Resource string) (*Endpoint, error)
func (*AppInstance) EndpointsList ¶
func (a *AppInstance) EndpointsList() (*[]Endpoint, error)
func (*AppInstance) EndpointsListByTech ¶
func (a *AppInstance) EndpointsListByTech(Tech string) (*[]Endpoint, error)
func (*AppInstance) EndpointsSendMessage ¶
func (a *AppInstance) EndpointsSendMessage(To string, From string, options ...string) error
func (*AppInstance) EndpointsSendMessageToEndpoint ¶
func (*AppInstance) EventsEventWebsocket ¶
func (a *AppInstance) EventsEventWebsocket(App string) (*Message, error)
func (*AppInstance) EventsUserEvent ¶
func (a *AppInstance) EventsUserEvent(EventName string, Application string, options ...string) error
func (*AppInstance) InitAppInstance ¶
func (a *AppInstance) InitAppInstance(instanceID string)
InitAppInstance initializes the set of resources necessary for a new application instance.
func (*AppInstance) MailboxesDelete ¶
func (a *AppInstance) MailboxesDelete(MailboxName string) error
func (*AppInstance) MailboxesGet ¶
func (a *AppInstance) MailboxesGet(MailboxName string) (*Mailbox, error)
func (*AppInstance) MailboxesList ¶
func (a *AppInstance) MailboxesList() (*[]Mailbox, error)
func (*AppInstance) MailboxesUpdate ¶
func (a *AppInstance) MailboxesUpdate(MailboxName string, OldMessages int, NewMessages int) error
func (*AppInstance) PlaybacksControl ¶
func (a *AppInstance) PlaybacksControl(PlaybackID string, Operation string) error
func (*AppInstance) PlaybacksGet ¶
func (a *AppInstance) PlaybacksGet(PlaybackID string) (*Playback, error)
func (*AppInstance) PlaybacksStop ¶
func (a *AppInstance) PlaybacksStop(PlaybackID string) error
func (*AppInstance) RecordingsCancel ¶
func (a *AppInstance) RecordingsCancel(RecordingName string) error
func (*AppInstance) RecordingsCopyStored ¶
func (a *AppInstance) RecordingsCopyStored(RecordingName string, DestinationRecordingName string) (*StoredRecording, error)
func (*AppInstance) RecordingsDeleteStored ¶
func (a *AppInstance) RecordingsDeleteStored(RecordingName string) error
func (*AppInstance) RecordingsGetLive ¶
func (a *AppInstance) RecordingsGetLive(RecordingName string) (*LiveRecording, error)
func (*AppInstance) RecordingsGetStored ¶
func (a *AppInstance) RecordingsGetStored(RecordingName string) (*StoredRecording, error)
func (*AppInstance) RecordingsListStored ¶
func (a *AppInstance) RecordingsListStored() (*[]StoredRecording, error)
func (*AppInstance) RecordingsMute ¶
func (a *AppInstance) RecordingsMute(RecordingName string) error
func (*AppInstance) RecordingsPause ¶
func (a *AppInstance) RecordingsPause(RecordingName string) error
func (*AppInstance) RecordingsStop ¶
func (a *AppInstance) RecordingsStop(RecordingName string) error
func (*AppInstance) RecordingsUnmute ¶
func (a *AppInstance) RecordingsUnmute(RecordingName string) error
func (*AppInstance) RecordingsUnpause ¶
func (a *AppInstance) RecordingsUnpause(RecordingName string) error
func (*AppInstance) SoundsList ¶
func (a *AppInstance) SoundsList(options ...string) (*[]Sound, error)
type AppInstanceHandler ¶
type AppInstanceHandler func(*AppInstance)
AppInstanceHandler when you start a new App, you pass in a function of type AppInstanceHandler. The entry point of the execution of an application instance.
type AppStart ¶
type AppStart struct { Application string `json:"application"` DialogID string `json:"dialog_id"` ServerID string `json:"server_id"` }
AppStart struct contains the initial information for the start of a new application instance.
type Application ¶
type ApplicationReplaced ¶
type AsteriskInfo ¶
type AsteriskInfo struct { Build BuildInfo `json:"build"` System SystemInfo `json:"system"` Config ConfigInfo `json:"config"` Status StatusInfo `json:"status"` }
type BridgeAttendedTransfer ¶
type BridgeAttendedTransfer struct { Result string `json:"result"` Transferer_First_Leg Channel `json:"transferer_first_leg"` Transferer_Second_Leg Channel `json:"transferer_second_leg"` Replace_Channel Channel `json:"replace_channel"` Is_External bool `json:"is_external"` Transferer_First_Leg_Bridge Bridge `json:"transferer_first_leg_bridge"` Transferer_Second_Leg_Bridge Bridge `json:"transferer_second_leg_bridge"` Destination_Bridge string `json:"destination_bridge"` Destination_Link_Second_Leg Channel `json:"destination_link_second_leg"` Destination_Threeway_Channel Channel `json:"destination_threeway_channel"` Destination_Threeway_Bridge Bridge `json:"destination_threeway_bridge"` Transferee Channel `json:"transferee"` Transfer_Target Channel `json:"transfer_target"` Destination_Type string `json:"destination_type"` Destination_Application string `json:"destination_application"` Destination_Link_First_Leg Channel `json:"destination_link_first_leg"` Application string `json:"application"` Timestamp string `json:"timestamp"` Type string `json:"type"` }
type BridgeBlindTransfer ¶
type BridgeBlindTransfer struct { Channel Channel `json:"channel"` Replace_Channel Channel `json:"replace_channel"` Transferee Channel `json:"transferee"` Exten string `json:"exten"` Context string `json:"context"` Result string `json:"result"` Is_External bool `json:"is_external"` Bridge Bridge `json:"bridge"` Application string `json:"application"` Timestamp string `json:"timestamp"` Type string `json:"type"` }
type BridgeCreated ¶
type BridgeDestroyed ¶
type BridgeMerged ¶
type ChannelCallerId ¶
type ChannelCreated ¶
type ChannelDestroyed ¶
type ChannelDialplan ¶
type ChannelDtmfReceived ¶
type ChannelEnteredBridge ¶
type ChannelHangupRequest ¶
type ChannelLeftBridge ¶
type ChannelStateChange ¶
type ChannelTalkingFinished ¶
type ChannelTalkingStarted ¶
type ChannelUserevent ¶
type ChannelUserevent struct { Eventname string `json:"eventname"` Channel Channel `json:"channel"` Bridge Bridge `json:"bridge"` Endpoint Endpoint `json:"endpoint"` Userevent string `json:"userevent"` Application string `json:"application"` Timestamp string `json:"timestamp"` Type string `json:"type"` }
type ChannelVarset ¶
type Command ¶
type Command struct { UniqueID string `json:"unique_id"` URL string `json:"url"` Method string `json:"method"` Body string `json:"body"` }
Command struct contains the command we're passing back to ARI.
type CommandResponse ¶
type CommandResponse struct { UniqueID string `json:"unique_id"` StatusCode int `json:"status_code"` ResponseBody string `json:"response_body"` }
CommandResponse struct contains the response to a Command
type ConfigInfo ¶
type DeviceState ¶
type DeviceStateChanged ¶
type DeviceStateChanged struct { Device_State DeviceState `json:"device_state"` Application string `json:"application"` Timestamp string `json:"timestamp"` Type string `json:"type"` }
type Dial ¶
type Dial struct { Caller Channel `json:"caller"` Peer Channel `json:"peer"` Forward string `json:"forward"` Forwarded Channel `json:"forwarded"` Dialstring string `json:"dialstring"` Dialstatus string `json:"dialstatus"` Application string `json:"application"` Timestamp string `json:"timestamp"` Type string `json:"type"` }
type DialplanCEP ¶
type EndpointStateChange ¶
type Event ¶
type Event struct { ServerID string `json:"server_id"` Timestamp time.Time `json:"timestamp"` Type string `json:"type"` ARI_Body string `json:"ari_body"` }
Event struct contains the events we pull off the websocket connection.
type FormatLangPair ¶
type LiveRecording ¶
type LiveRecording struct { Name string `json:"name"` Format string `json:"format"` Target_Uri string `json:"target_uri"` State string `json:"state"` Duration int `json:"duration"` Talking_Duration int `json:"talking_duration"` Silence_Duration int `json:"silence_duration"` Cause string `json:"cause"` }
type MessageBus ¶
type MessageBus interface { InitBus(config interface{}) error StartProducer(topic string) (chan []byte, error) StartConsumer(topic string) (chan []byte, error) TopicExists(topic string) bool }
MessageBus interface contains methods for interacting with the abstracted message bus.
type MissingParams ¶
type NATS ¶
type NATS struct {
// contains filtered or unexported fields
}
func (*NATS) TopicExists ¶
type PlaybackFinished ¶
type PlaybackStarted ¶
type RabbitMQ ¶
type RabbitMQ struct {
// contains filtered or unexported fields
}
func (*RabbitMQ) StartConsumer ¶
func (*RabbitMQ) StartProducer ¶
func (*RabbitMQ) TopicExists ¶
type RecordingFailed ¶
type RecordingFailed struct { Recording LiveRecording `json:"recording"` Application string `json:"application"` Timestamp string `json:"timestamp"` Type string `json:"type"` }
type RecordingFinished ¶
type RecordingFinished struct { Recording LiveRecording `json:"recording"` Application string `json:"application"` Timestamp string `json:"timestamp"` Type string `json:"type"` }
type RecordingStarted ¶
type RecordingStarted struct { Recording LiveRecording `json:"recording"` Application string `json:"application"` Timestamp string `json:"timestamp"` Type string `json:"type"` }
type Sound ¶
type Sound struct { Id string `json:"id"` Text string `json:"text"` Formats []FormatLangPair `json:"formats"` }
type StasisStart ¶
type StatusInfo ¶
type StoredRecording ¶
type SystemInfo ¶
type TextMessage ¶
type TextMessage struct { From string `json:"from"` To string `json:"to"` Body string `json:"body"` Variables []TextMessageVariable `json:"variables"` }
type TextMessageReceived ¶
type TextMessageReceived struct { Message TextMessage `json:"message"` Endpoint Endpoint `json:"endpoint"` Application string `json:"application"` Timestamp string `json:"timestamp"` Type string `json:"type"` }