queue

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

• func WithReconnect(ctx context.Context, conn *Connection) func() (<-chan *uof.Message, <-chan error)
• type Connection
  • func Dial(ctx context.Context, env uof.Environment, bookmakerID int, token string, ...) (*Connection, error)
  • func DialCustom(ctx context.Context, server string, bookmakerID int, token string, ...) (*Connection, error)
  • func DialProduction(ctx context.Context, bookmakerID int, token string, nodeID, prefetchCount int, ...) (*Connection, error)
  • func DialProductionGlobal(ctx context.Context, bookmakerID int, token string, nodeID, prefetchCount int, ...) (*Connection, error)
  • func DialReplay(ctx context.Context, bookmakerID int, token string, nodeID, prefetchCount int, ...) (*Connection, error)
  • func DialStaging(ctx context.Context, bookmakerID int, token string, nodeID, prefetchCount int, ...) (*Connection, error)
  • func (c *Connection) Listen() (<-chan *uof.Message, <-chan error)
• type ConnectionInfo

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 int, token string, nodeID, prefetchCount int, isTLS, isThrottled, autoAck bool) (*Connection, error)

Dial connects to the queue chosen by environment

func DialCustom

func DialCustom(ctx context.Context, server string, bookmakerID int, token string, nodeID, prefetchCount int, isTLS, isThrottled, autoAck bool) (*Connection, error)

DialCustom connects to a custom server

func DialProduction

func DialProduction(ctx context.Context, bookmakerID int, token string, nodeID, prefetchCount int, isTLS, isThrottled, autoAck bool) (*Connection, error)

DialProduction connects to the production queue

func DialProductionGlobal

func DialProductionGlobal(ctx context.Context, bookmakerID int, token string, nodeID, prefetchCount int, isTLS, isThrottled, autoAck bool) (*Connection, error)

DialProductionGlobal connects to the production queue

func DialReplay

func DialReplay(ctx context.Context, bookmakerID int, token string, nodeID, prefetchCount int, isTLS, isThrottled, autoAck bool) (*Connection, error)

DialReplay connects to the replay server

func DialStaging

func DialStaging(ctx context.Context, bookmakerID int, token string, nodeID, prefetchCount int, isTLS, isThrottled, autoAck bool) (*Connection, error)

DialStaging connects to the staging queue

func (*Connection) Listen

func (c *Connection) Listen() (<-chan *uof.Message, <-chan error)

type ConnectionInfo

type ConnectionInfo struct {
	// contains filtered or unexported fields
}