subscriber

Documentation

Index

• Constants
• func Start(subscriberPoT *PoT)
• type Channels
• type KeYs
• type KfKParameters
• type PoT
• type Pool
• type Provider
• type RdSParameters

Constants

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

Functions

func Start

func Start(subscriberPoT *PoT)

Types

type Channels

type Channels map[interface{}][]Provider

type KeYs

type KeYs []interface{}

type KfKParameters

type KfKParameters struct {
}

type PoT

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

type Pool

type Pool struct {
	Method string
	Config interface{}
}

type Provider

type Provider interface {
	Provided(channel string, content interface{})
}

type RdSParameters

type RdSParameters struct {
	Info interface{}
}