echo

Mar 15, 2025

Changes in this version

+ func SetTimeEventID(id string) func(*TimerEvent)

+ func UpdateTimerEvent(id string, channel string, data string, time time.Time) bool

+ type TimerEventConfig func(*TimerEvent)

type TimerEventHeap

+ func (h *TimerEventHeap) UpdateEvent(event TimerEvent) bool

type Value

+ func (v *Value) SetID(id string) *Value

Sep 30, 2022

Changes in this version

+ func LoadTimerEvent() error

+ func SetStorage(s Storage)

+ type Storage interface

+ AppName func() string

+ Find func(key string) ([]string, error)

+ Get func(key string) (string, error)

+ ListAppend func(key string, data string) (err error)

+ ListRem func(key string, data string) (err error)

+ Rem func(key string) error

+ Save func(key string, val string) (err error)

+ UUID func() string

type Value

+ ID string

Aug 2, 2022

Changes in this version

type Value

+ Ts int64

+ func (v *Value) SetTime(ts int64)

Mar 9, 2022

Changes in this version

+ func GetData(ctx SubCtx) (T, error)

type PubSub

+ func (pb *PubSub[T]) Pub(data T) error

+ func (pb *PubSub[T]) Sub(ctx context.Context, group string, buffer int, consumer func(T))

Feb 4, 2022

Changes in this version

+ func NewGChannelData(channel string, data T) GChannelData[T]

+ type GChannelData struct

+ Channel string

+ Value T

Feb 4, 2022

Changes in this version

+ func NewPubSub() *PubSub[T]

+ type PubSub struct

+ Pools map[string]chan T

+ Rmt sync.RWMutex

Jan 25, 2022

Changes in this version

+ func AddJsonDataToTimerEvent(channel string, data interface{}, time time.Time) error

+ func AddLoopTimerEvent(channel string, data string, time time.Time, loop int64)

+ func AddManyTimerEvent(event []TimerEvent)

+ func AddTimerEvent(channel string, data string, time time.Time)

+ func PubEvent(channel string, data string)

+ func PubEventJson(channel string, data interface{}) error

+ func SetEventBuffer(b int)

+ func StartEventListener(ctx context.Context)

+ func StartTimerEventListener(ctx context.Context)

type TimerEvent

+ Loop int64

Jan 16, 2022

Changes in this version

type Value

+ func NewValue() *Value

Jan 7, 2022

Changes in this version

+ func FireTrigger(key string, data string)

+ func SetTrigger(key string, handler JobHandler)

+ func SetTriggerBuffer(buffer int)

+ func TriggerStart(ctx context.Context)

+ type Trigger struct

+ Data chan ChannelData

+ Mtx sync.RWMutex

+ func NewTrigger(buffer int) *Trigger

+ func (trigger *Trigger) Done(key string)

+ func (trigger *Trigger) Fire(data ChannelData)

+ func (trigger *Trigger) Listen(ctx context.Context)

+ func (trigger *Trigger) Register(key string, handler JobHandler)

Jan 6, 2022

Changes in this version

+ func AddJsonDataToEvent(channel string, data interface{}, time time.Time) error

+ func AddManyEvent(event []TimerEvent)

+ func AddToEvent(channel string, data string, time time.Time)

+ func RunEvent(ctx context.Context)

+ func SetEventHandler(channel string, handler JobHandler)

Jan 6, 2022

Changes in this version

+ func PubQueueJson(channel string, data interface{}) error

Jan 6, 2022

Changes in this version

+ func ConsumeQueue(ctx context.Context)

+ func PubJsonQueue(channel string, data interface{}) error

+ func PubQueue(channel string, data string)

+ func SetQueueBuffer(b int)

+ func SetQueueHandler(channel string, handler JobHandler)

+ type ChannelData struct

+ Channel string

+ func GetChannelDataFromJson(j string) (*ChannelData, error)

+ type ChannelQueue struct

+ DataChannel chan ChannelData

+ Mtx sync.RWMutex

+ func NewChannelQueue(buffer int) *ChannelQueue

+ func (queue *ChannelQueue) Consume(ctx context.Context)

+ func (queue *ChannelQueue) Pub(channelData ChannelData)

Jan 4, 2022

Changes in this version

+ func AddJsonDataToTimerHeap(channel string, data interface{}, time time.Time) error

+ func AddManyEventToTimerHeap(event []TimerEvent)

+ func AddToTimerHeap(channel string, data string, time time.Time)

+ func RunTimerHeap()

+ func SetTimerHeapHandler(channel string, handler JobHandler)

+ type JobRouter struct

+ Handlers map[string]JobHandler

+ func (r *JobRouter) Handle(channel string, ctx *SubCtx) error

+ func (r *JobRouter) Set(channel string, handler JobHandler)

+ type Sleeper struct

+ Duration time.Duration

+ Max time.Duration

+ Step time.Duration

+ func NewSleeper(step time.Duration, max time.Duration) *Sleeper

+ func (sleeper *Sleeper) Reset()

+ func (sleeper *Sleeper) Sleep()

+ type TimerEvent struct

+ EventType string

+ Ts int64

+ type TimerEventHandler func(TimerEvent) error

+ type TimerEventHeap struct

+ Event []TimerEvent

+ Recent int64

+ Remain int

+ func NewTimerHeap() *TimerEventHeap

+ func (h *TimerEventHeap) Extract() (TimerEvent, error)

+ func (h *TimerEventHeap) InitEvent(event []TimerEvent)

+ func (h *TimerEventHeap) Insert(event TimerEvent)

+ func (h *TimerEventHeap) LoadMoreEvent(event []TimerEvent)

+ func (h *TimerEventHeap) Pop() interface{}

+ func (h *TimerEventHeap) Push(x interface{})

+ func (h *TimerEventHeap) Update()

+ func (h TimerEventHeap) Len() int

+ func (h TimerEventHeap) Less(i, j int) bool

+ func (h TimerEventHeap) Swap(i, j int)

Dec 18, 2021

Changes in this version

+ const BoolFalse

+ const BoolTrue

+ func GetBoolValue(k string) (bool, error)

+ func GetJsonValue(k string, data interface{}) error

+ func GetValue(k string) (string, error)

+ func PubBool(channel string, val bool) error

+ func PubBoolQ(channel string, data bool)

+ func PubJsonQ(channel string, data interface{}) error

+ func PubQ(channel string, data string)

+ func RemValue(k string)

+ func SetBoolValue(k string, v bool)

+ func SetJsonValue(k string, data interface{})

+ func SetValue(k string, v string)

+ type JobHandler func(*SubCtx)

+ type Queue struct

+ Stream chan string

+ func (q *Queue) Append(data string) error

+ func (q *Queue) AppendBool(data bool) error

+ func (q *Queue) AppendJson(data interface{}) error

+ func (q *Queue) Consume(ctx context.Context, consumer func(*SubCtx))

+ type Streamer struct

+ QueueHandler map[string]func(*SubCtx)

+ func NewStreamer() *Streamer

+ func (s *Streamer) Add(name string, handler JobHandler)

+ func (s *Streamer) Stream(ctx context.Context)

+ type Value struct

+ Data string

+ func (v *Value) GetBool() bool

+ func (v *Value) GetData() string

+ func (v *Value) GetJsonData(data interface{}) error

+ func (v *Value) SetBool(data bool)

+ func (v *Value) SetJson(data interface{}) error

+ func (v *Value) SetValue(data string)

Dec 16, 2021

Changes in this version

+ func SetBuffer(count int)

Nov 13, 2021

Changes in this version

+ type Suber struct

+ SubMap map[string]func(*SubCtx)

+ func NewSuber() *Suber

+ func (s *Suber) Add(channel string, consumer func(*SubCtx))

+ func (s *Suber) Sub(ctx context.Context)

Nov 1, 2021

Changes in this version

+ func Pub(channel string, val string)

+ func PubJson(channel string, val interface{})

+ func Sub(ctx context.Context, channel string, consumer func(SubCtx))

+ type SubCtx struct

+ Data string

+ func (c *SubCtx) Parser(data interface{}) error