mini

Documentation

Index

• Constants
• func GetSchedule(id int) kafka.Schedule
• type Runner
  • func NewRunner() *Runner
  • func (r Runner) Close() error
  • func (r *Runner) Start() error
• type Sysout
  • func NewHandler(store hmap.Hmap) Sysout
  • func (s Sysout) Handle(event scheduler.Event)

Constants

const (
	ID1 = 1
	ID2 = 2
	ID3 = 3
)

Functions

func GetSchedule

func GetSchedule(id int) kafka.Schedule

Types

type Runner

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

func NewRunner

func NewRunner() *Runner

func (Runner) Close

func (r Runner) Close() error

func (*Runner) Start

func (r *Runner) Start() error

type Sysout

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

func NewHandler

func NewHandler(store hmap.Hmap) Sysout

func (Sysout) Handle

func (s Sysout) Handle(event scheduler.Event)

Print and reschedule all triggered schedules, so there is always 3 schedules planned