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() error
}

type Message ¶ added in v0.2.16

type Message interface {
	Kind() string
}

type MessageHandler ¶ added in v0.2.16

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

type MessageSender ¶ added in v0.2.16

type MessageSender interface {
	SendMessage(ctx context.Context, from Named, message 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 {
	HandleRawMessage(ctx context.Context, kind string, payload any) error
}

type RawMessageSender ¶ added in v0.2.16

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

type Readiness ¶ added in v0.3.0

type Readiness interface {
	Ready() 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)
}