sync

Documentation

Index

• func Start(ctx context.Context, triggerFunc TriggerFunc, syncFunc func())
• type TriggerFunc
  • func AmqpTrigger(amqpURL, queueName string) (TriggerFunc, error)
  • func PeriodicTrigger(duration time.Duration) TriggerFunc

Functions

func Start

func Start(ctx context.Context, triggerFunc TriggerFunc, syncFunc func())

Types

type TriggerFunc

type TriggerFunc func(context.Context, chan<- struct{}) error

func AmqpTrigger

func AmqpTrigger(amqpURL, queueName string) (TriggerFunc, error)

func PeriodicTrigger

func PeriodicTrigger(duration time.Duration) TriggerFunc