sessinvalidator

Documentation

Index

• Constants
• func BroadcastSessionExpiry(sessId string)
• func Run()
• type Processor
  • func (p *Processor) HandleMessage(msg *nsqlib.Message) error

Constants

const (
	TopicName   = "login.sessionexpire"
	ChannelName = "expire"
)

Functions

func BroadcastSessionExpiry

func BroadcastSessionExpiry(sessId string)

BroadcastSessionExpiry sends a message to NSQ saying that a session is now invalid

func Run

func Run()

Run will connect to NSQ, consume and process session expiry requests We can trigger after initialisation via `server.RegisterPostConnectHandler(sessinvalidator.Run)`

Types

type Processor

type Processor struct{}

Processor exists to strap a HandleMessage to in order to satisfy http://godoc.org/github.com/bitly/go-nsq#Handler

func (*Processor) HandleMessage

func (p *Processor) HandleMessage(msg *nsqlib.Message) error

HandleMessage implements http://godoc.org/github.com/bitly/go-nsq#Handler for processing our jobs