queues

Documentation

Index

• Constants
• func Start(queuePoT *PoT)
• type Channels
• type Interval
• type KeYs
• type KfKParameters
• type PoT
• type Pool
• type RdSParameters
• type Recipient

Constants

const (
	MethodRdS string = "rds"
	MethodKfK string = "kafka"
)

Functions

func Start

func Start(queuePoT *PoT)

Types

type Channels

type Channels map[interface{}][]Recipient

type Interval

type Interval struct {
	Value time.Duration
	Units time.Duration
}

type KeYs

type KeYs []interface{}

type KfKParameters

type KfKParameters struct {
}

type PoT

type PoT struct {
	KeYs     *KeYs
	Pool     *Pool
	Channels *Channels
	Interval *Interval
}

type Pool

type Pool struct {
	Method string
	Config interface{}
}

type RdSParameters

type RdSParameters struct {
	Info interface{}
}

type Recipient

type Recipient interface {
	Receipted(channel, content interface{})
}