receiver

Documentation

Index

• Constants
• Variables
• func Shutdown()
• type Receiver
  • func New() Receiver
• type Report
• type Thrown

Constants

const (
	Name = "wathola-receiver"
)

Variables

var (
	Canceling = make(chan context.CancelFunc, 1)
)

Functions

func Shutdown

func Shutdown()

Types

type Receiver

type Receiver interface {
	Receive()
}

Receiver perform waiting and receiving of events

func New

func New() Receiver

New creates new Receiver

type Report

type Report struct {
	State         string `json:"state"`
	EventsSent    int    `json:"eventsSent"`
	TotalRequests int    `json:"totalRequests"`
	Thrown        Thrown `json:"thrown"`
}

Report represents state as JSON

type Thrown

type Thrown struct {
	Duplicated  []string `json:"duplicated"`
	Missing     []string `json:"missing"`
	Unexpected  []string `json:"unexpected"`
	Unavailable []string `jsong:"unavailable"`
}

Thrown holds different error types.