internal

Documentation

Index

• func NewCentrifugoHttpClient() *http.Client
• type NotifierApplication
  • func NewApplication() *NotifierApplication
  • func (app *NotifierApplication) Init()
  • func (app *NotifierApplication) Process(o *proto.Order, d amqp.Delivery) error
  • func (app *NotifierApplication) Run()
  • func (app *NotifierApplication) Stop()

Functions

func NewCentrifugoHttpClient

func NewCentrifugoHttpClient() *http.Client

Types

type NotifierApplication

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

func NewApplication

func NewApplication() *NotifierApplication

func (*NotifierApplication) Init

func (app *NotifierApplication) Init()

func (*NotifierApplication) Process

func (app *NotifierApplication) Process(o *proto.Order, d amqp.Delivery) error

func (*NotifierApplication) Run

func (app *NotifierApplication) Run()

func (*NotifierApplication) Stop

func (app *NotifierApplication) Stop()