reminders

Documentation

Index

• type ReminderCallback
• type ReminderConfig
  • func (r *ReminderConfig) ReminderStore() (storage.ReminderStore, error)
• type ReminderRegistry
  • func NewReminderRegistry(ctx context.Context, config ReminderConfig) (*ReminderRegistry, error)
  • func (r *ReminderRegistry) Register(name string, grainType string, grainId string, payload []byte, ...) error
  • func (r *ReminderRegistry) StartReminderProcess()
  • func (r *ReminderRegistry) Tick() error

Types

type ReminderCallback

type ReminderCallback func(*grains.Invocation) (*grains.GrainExecution, error)

type ReminderConfig

type ReminderConfig struct {
	ReminderStoreDSN string
	TickInterval     time.Duration
	SiloClient       pb.SiloServiceClient
	MetricsRegistry  *metrics.MetricsRegistry
	RedisHostPort    string
	SiloHostPort     string
}

func (*ReminderConfig) ReminderStore

func (r *ReminderConfig) ReminderStore() (storage.ReminderStore, error)

type ReminderRegistry

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

func NewReminderRegistry

func NewReminderRegistry(ctx context.Context, config ReminderConfig) (*ReminderRegistry, error)

func (*ReminderRegistry) Register

func (r *ReminderRegistry) Register(name string, grainType string, grainId string, payload []byte, dueTime time.Time, period time.Duration) error

func (*ReminderRegistry) StartReminderProcess

func (r *ReminderRegistry) StartReminderProcess()

func (*ReminderRegistry) Tick

func (r *ReminderRegistry) Tick() error