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

• 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 DialReplay(ctx context.Context, bookmakerID, token string, bind int8) (*Connection, error)
  • func DialStaging(ctx context.Context, bookmakerID, token string, bind int8) (*Connection, error)
  • func (c *Connection) Listen() (<-chan *uof.Message, <-chan error)

Constants

const (
	BindAll int8 = iota
	BindSports
	BindVirtuals
	BindPrematch
	BindLive
)

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

func DialProduction(ctx context.Context, bookmakerID, token string, bind int8) (*Connection, error)

Dial connects to the production queue

func DialReplay

func DialReplay(ctx context.Context, bookmakerID, token string, bind int8) (*Connection, error)

DialReplay connects to the replay server

func DialStaging

func DialStaging(ctx context.Context, bookmakerID, token string, bind int8) (*Connection, error)

DialStaging connects to the staging queue

func (*Connection) Listen

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