common

type Daemon ¶

type Daemon interface {
	Start(ctx context.Context) error
	Stop(wait bool) error
}

type Debuggable ¶

type Debuggable interface {
	Info(w io.Writer, debug bool)
}

type Initializable ¶

type Initializable interface {
	Init(ctx context.Context) error
}

Initializable is implemented by services that require initialization. Init is called on first startup and on every restart, making it the appropriate place to load dynamic configuration that may change between runs.

type Liveness ¶ added in v0.3.0

type Liveness interface {
	Alive(ctx context.Context) error
}

Liveness and Readiness probes take the caller's context: probes may do I/O (a database ping), and the caller owns the deadline budget and the shutdown signal. Implementations may layer their own tighter timeout on top, never a looser one.

type Message ¶ added in v0.2.16

type Message interface {
	Kind() string
}

type MessageHandler ¶ added in v0.2.16

type MessageHandler interface {
	Service
	HandleMessage(ctx context.Context, msg Message) error
}

type MessageSender ¶ added in v0.2.16

type MessageSender interface {
	Service
	SendMessage(ctx context.Context, from Named, msg Message)
}

type Named ¶

type Named interface {
	Name() string
}

type Pair ¶

type Pair[K comparable, V any] interface {
	SetKey(key K)
	SetValue(value V)
	GetKey() K
	GetValue() V
	String() string
}

func NewPair[K comparable, V any](key K, value V) Pair[K, V]

func ParsePair(s string) (Pair[string, string], bool)

type Pairs ¶

type Pairs []Pair[string, string]

func NewPairs[T Pair[string, string]](src []T) Pairs

func ParsePairs(s string) (Pairs, bool)

func ParsePairsMap(m map[string]string) Pairs

func (p Pairs) Map() map[string]string

func (p Pairs) String() string

type RawMessageHandler ¶ added in v0.2.16

type RawMessageHandler interface {
	Service
	HandleRawMessage(ctx context.Context, kind string, payload any) error
}

type RawMessageSender ¶ added in v0.2.16

type RawMessageSender interface {
	Service
	SendRawMessage(ctx context.Context, from Named, kind string, payload any)
}

type Readiness ¶ added in v0.3.0

type Readiness interface {
	Ready(ctx context.Context) error
}

type Service ¶

type Service interface {
	Named
	Dependencies() []Service
}

type Unique ¶

type Unique interface {
	Key() string
}

type Weighted ¶

type Weighted interface {
	GetPriority() int
	SetPriority(priority int)
}