queue

package
v0.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 16, 2021 License: MIT Imports: 8 Imported by: 0

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

View Source
const (
	BindAll int8 = iota
	BindSports
	BindVirtuals
	BindPrematch
	BindLive
)

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

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL