anware

Documentation

Index

• func RegisterModule(desc ModuleDescriptor)
• type AnModule
• type AnWare
  • func NewAnWare(context context.Context, cancel context.CancelFunc, ...) *AnWare
  • func (m *AnWare) AutoLoadModules(staticData aninterface.StaticData, appConfig any, logger aninterface.AnLogger)
  • func (m *AnWare) Broadcast(msg AnWareEvent)
  • func (m *AnWare) LoopOfAnWare(msg AnWareEvent)
  • func (m *AnWare) Run()
  • func (m *AnWare) Send(msg AnWareEvent)
  • func (m *AnWare) SendSync(source string, target string, msgType string, data any) (any, error)
  • func (m *AnWare) Shutdown()
• type AnWareEvent
• type AnWareReply
• type BaseModule
  • func (b *BaseModule) Ctx() context.Context
  • func (b *BaseModule) In() <-chan AnWareEvent
  • func (b *BaseModule) MW() *AnWare
  • func (b *BaseModule) Name() string
  • func (b *BaseModule) SetRuntime(name string, ctx context.Context, in <-chan AnWareEvent, mw *AnWare)
• type ConfigValidator
• type GenericModuleConstructor
  • func (g GenericModuleConstructor[F, C]) Build(local aninterface.StaticData, config any, flags any, ...) AnModule
• type ModuleDescriptor
• type ModuleFactory

Functions

func RegisterModule

func RegisterModule(desc ModuleDescriptor)

Types

type AnModule

type AnModule interface {
	Name() string

	SetRuntime(
		name string,
		ctx context.Context,
		in <-chan AnWareEvent,
		mw *AnWare,
	)

	Start()
	Stop() error
}

type AnWare

type AnWare struct {
	Logger aninterface.AnLogger
	// contains filtered or unexported fields
}

func NewAnWare

func NewAnWare(context context.Context, cancel context.CancelFunc, logger aninterface.AnLogger) *AnWare

func (*AnWare) AutoLoadModules

func (m *AnWare) AutoLoadModules(
	staticData aninterface.StaticData,
	appConfig any,
	logger aninterface.AnLogger,
)

func (*AnWare) Broadcast

func (m *AnWare) Broadcast(msg AnWareEvent)

func (*AnWare) LoopOfAnWare

func (m *AnWare) LoopOfAnWare(msg AnWareEvent)

func (*AnWare) Run

func (m *AnWare) Run()

func (*AnWare) Send

func (m *AnWare) Send(msg AnWareEvent)

func (*AnWare) SendSync

func (m *AnWare) SendSync(
	source string,
	target string,
	msgType string,
	data any,
) (any, error)

func (*AnWare) Shutdown

func (m *AnWare) Shutdown()

type AnWareEvent

type AnWareEvent struct {
	Source string
	Target string
	Type   string
	Data   any

	ReplyTo chan AnWareReply
}

type AnWareReply

type AnWareReply struct {
	Data any
	Err  error
}

type BaseModule

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

func (*BaseModule) Ctx

func (b *BaseModule) Ctx() context.Context

func (*BaseModule) In

func (b *BaseModule) In() <-chan AnWareEvent

func (*BaseModule) MW

func (b *BaseModule) MW() *AnWare

func (*BaseModule) Name

func (b *BaseModule) Name() string

func (*BaseModule) SetRuntime

func (b *BaseModule) SetRuntime(
	name string,
	ctx context.Context,
	in <-chan AnWareEvent,
	mw *AnWare,
)

type ConfigValidator

type ConfigValidator interface {
	Validate() error
}

type GenericModuleConstructor

type GenericModuleConstructor[F any, C any] struct {
	// contains filtered or unexported fields
}

func (GenericModuleConstructor[F, C]) Build

func (g GenericModuleConstructor[F, C]) Build(local aninterface.StaticData, config any, flags any, logger aninterface.AnLogger) AnModule

type ModuleDescriptor

type ModuleDescriptor struct {
	Name string

	New func(
		local aninterface.StaticData,
		cfg any,
		logger aninterface.AnLogger,
	) AnModule

	ConfigType any
}

type ModuleFactory

type ModuleFactory interface {
	Build(local aninterface.StaticData, config any, flags any, logger aninterface.AnLogger) AnModule
}