nats

Documentation

Index

• func Close()
• func GetExistingSchedules()
• func GetKeyValue(key string) ([]byte, error)
• func JetstreamConnect(parentContext context.Context, parentLogger *slog.Logger, ...) error
• func KvConnect() error
• func Publish(subject string, message []byte)
• func PublishRequest(subject string, message []byte, timeout time.Duration, retries int)
• func PublishString(subject, message string)
• func ScheduleStoreConnect() error
• func SetKeyValue(key string, value []byte) error
• func SetKeyValueString(key, value string) error
• func StopSchedules()
• type HatsSchedule
  • func GetSchedule(name string) (*HatsSchedule, error)
  • func NewSchedule(name, cron string) *HatsSchedule
  • func (t *HatsSchedule) Activate() error
  • func (t *HatsSchedule) Cancel()
  • func (t *HatsSchedule) GetNext() string
• type HatsTimer
  • func GetTimer(name string) (*HatsTimer, error)
  • func (t *HatsTimer) Activate(durationOverride string)
  • func (t *HatsTimer) ActivateIfNotAlready(durationOverride string)
  • func (t *HatsTimer) Cancel()
  • func (t *HatsTimer) ToString() string

Functions

func Close

func Close()

func GetExistingSchedules

func GetExistingSchedules()

func GetKeyValue

func GetKeyValue(key string) ([]byte, error)

func JetstreamConnect

func JetstreamConnect(parentContext context.Context, parentLogger *slog.Logger, parentConfig *config.HatsConfig) error

func KvConnect

func KvConnect() error

func Publish

func Publish(subject string, message []byte)

func PublishRequest

func PublishRequest(subject string, message []byte, timeout time.Duration, retries int)

func PublishString

func PublishString(subject, message string)

func ScheduleStoreConnect

func ScheduleStoreConnect() error

func SetKeyValue

func SetKeyValue(key string, value []byte) error

func SetKeyValueString

func SetKeyValueString(key, value string) error

func StopSchedules

func StopSchedules()

Types

type HatsSchedule

type HatsSchedule struct {
	Name string
	Cron string
}

func GetSchedule

func GetSchedule(name string) (*HatsSchedule, error)

func NewSchedule

func NewSchedule(name, cron string) *HatsSchedule

func (*HatsSchedule) Activate

func (t *HatsSchedule) Activate() error

func (*HatsSchedule) Cancel

func (t *HatsSchedule) Cancel()

func (*HatsSchedule) GetNext

func (t *HatsSchedule) GetNext() string

type HatsTimer

type HatsTimer struct {
	Name       string
	State      string
	Duration   time.Duration
	FinishTime time.Time
}

func GetTimer

func GetTimer(name string) (*HatsTimer, error)

func (*HatsTimer) Activate

func (t *HatsTimer) Activate(durationOverride string)

func (*HatsTimer) ActivateIfNotAlready

func (t *HatsTimer) ActivateIfNotAlready(durationOverride string)

func (*HatsTimer) Cancel

func (t *HatsTimer) Cancel()

func (*HatsTimer) ToString

func (t *HatsTimer) ToString() string