Documentation
¶
Overview ¶
You cannot create your own queues. Instead you have to request a server-named queue (empty queue name in the request). Passive, Exclusive, Non-durable. Reference: https://docs.betradar.com/display/BD/UOF+-+Messages
Index ¶
- Constants
- func WithReconnect(ctx context.Context, conn *Connection) func() (<-chan *uof.Message, <-chan error)
- type Connection
- func Dial(ctx context.Context, env uof.Environment, bookmakerID, token string, bind int8) (*Connection, error)
- func DialProduction(ctx context.Context, bookmakerID, token string, bind int8) (*Connection, error)
- func DialProductionGlobal(ctx context.Context, bookmakerID, token string, bind int8) (*Connection, error)
- func DialReplay(ctx context.Context, bookmakerID, token string, bind int8) (*Connection, error)
- func DialStaging(ctx context.Context, bookmakerID, token string, bind int8) (*Connection, error)
Constants ¶
View Source
const ( BindAll int8 = iota BindSports BindVirtuals )
Variables ¶
This section is empty.
Functions ¶
func WithReconnect ¶
func WithReconnect(ctx context.Context, conn *Connection) func() (<-chan *uof.Message, <-chan error)
WithReconnect ensuers reconnects with exponential backoff interval
Types ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func Dial ¶
func Dial(ctx context.Context, env uof.Environment, bookmakerID, token string, bind int8) (*Connection, error)
Dial connects to the queue chosen by environment
func DialProduction ¶
Dial connects to the production queue
func DialProductionGlobal ¶ added in v0.4.5
func DialProductionGlobal(ctx context.Context, bookmakerID, token string, bind int8) (*Connection, error)
DialProductionGlobal connects to the production global queue
func DialReplay ¶
DialReplay connects to the replay server
func DialStaging ¶
DialStaging connects to the staging queue
func (*Connection) Listen ¶
func (c *Connection) Listen() (<-chan *uof.Message, <-chan error)
Source Files
Click to show internal directories.
Click to hide internal directories.