gatewayinfo

Documentation

Index

• Variables
• type Public
  • func NewPublic(accountServer string) *Public
  • func (p *Public) HandleConnect(ctx middleware.Context, msg *types.ConnectMessage) error
  • func (p *Public) HandleDisconnect(ctx middleware.Context, msg *types.DisconnectMessage) error
  • func (p *Public) HandleStatus(ctx middleware.Context, msg *types.StatusMessage) error
  • func (p *Public) WithExpire(duration time.Duration) *Public
  • func (p *Public) WithRedis(client *redis.Client, prefix string) (*Public, error)

Variables

var RequestBurst = 50

RequestBurst sets the burst of requests to the account server

var RequestInterval = 50 * time.Millisecond

RequestInterval sets how often the account server may be queried

Types

type Public

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

Public gateway information will be injected

func NewPublic

func NewPublic(accountServer string) *Public

NewPublic returns a middleware that injects public gateway information

func (*Public) HandleConnect

func (p *Public) HandleConnect(ctx middleware.Context, msg *types.ConnectMessage) error

HandleConnect fetches public gateway information in the background when a ConnectMessage is received

func (*Public) HandleDisconnect

func (p *Public) HandleDisconnect(ctx middleware.Context, msg *types.DisconnectMessage) error

HandleDisconnect cleans up

func (*Public) HandleStatus

func (p *Public) HandleStatus(ctx middleware.Context, msg *types.StatusMessage) error

HandleStatus inserts metadata if set in info, but not present in message

func (*Public) WithExpire

func (p *Public) WithExpire(duration time.Duration) *Public

WithExpire adds an expiration to gateway information. Information is re-fetched if expired

func (*Public) WithRedis

func (p *Public) WithRedis(client *redis.Client, prefix string) (*Public, error)

WithRedis initializes the Redis store for persistence between restarts