subscribing

Documentation

Index

• type Status
  • func (status Status) String() string
• type Subscriber
  • func (subscriber *Subscriber) Initialise()
  • func (subscriber *Subscriber) ReceiveHttp(response http.ResponseWriter, request *http.Request)
  • func (subscriber *Subscriber) Shutdown()
  • func (subscriber *Subscriber) Start()

Types

type Status

type Status int

const (
	Failed Status = iota
	Received
)

func (Status) String

func (status Status) String() string

type Subscriber

type Subscriber struct {
	ReceivedCount      int
	ReceiveFailedCount int
	Url                string
	// contains filtered or unexported fields
}

func (*Subscriber) Initialise

func (subscriber *Subscriber) Initialise()

func (*Subscriber) ReceiveHttp

func (subscriber *Subscriber) ReceiveHttp(response http.ResponseWriter, request *http.Request)

func (*Subscriber) Shutdown

func (subscriber *Subscriber) Shutdown()

func (*Subscriber) Start

func (subscriber *Subscriber) Start()