ha

Documentation

Overview

Package ha provides high-availability (HA) execution patterns.

It supports cache-based HA executors that can register and execute operations with periodic callbacks for health checking and recovery.

Index

• type Executor
  • func New[T any](ctxt context.Context, props *Properties) (Executor[T], *national.Message)
• type Kind
• type Properties
• type Type

Types

type Executor

type Executor[T any] interface {
	Register(ctxt context.Context, kind Kind, interval time.Duration, cb func(v ...T) *national.Message) (*time.Ticker,
		*national.Message)
	Exec(ctxt context.Context, kind Kind, va ...T) *national.Message
}

func New

func New[T any](ctxt context.Context, props *Properties) (Executor[T], *national.Message)

type Kind

type Kind string

type Properties

type Properties struct {
	Type  Type             `yaml:"type" default:"redis"`
	Cache cache.Properties `yaml:"cache"`
}

type Type

type Type string

const (
	Cache Type = "cache"
)