node_controller

Apr 28, 2026

Changes in this version

+ const ConfigID

+ const ControllerID

+ var Version = semver.MustParse("0.0.1")

+ func BuildConcurrentLookupConfig(notFoundBehavior lookup_concurrent.NotFoundBehavior) lookup.Config

+ func BuildDefaultLookupConfig() lookup.Config

+ type Config struct

+ DefaultLookup *proto.ControllerConfig

+ DisableDefaultLookup bool

+ DisableLookup bool

+ func (*Config) ProtoMessage()

+ func (c *Config) EqualsConfig(other config.Config) bool

+ func (c *Config) GetConfigID() string

+ func (c *Config) Validate() error

+ func (m *Config) CloneMessageVT() protobuf_go_lite.CloneMessage

+ func (m *Config) CloneVT() *Config

+ func (m *Config) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Config) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Config) MarshalVT() (dAtA []byte, err error)

+ func (m *Config) SizeVT() (n int)

+ func (m *Config) UnmarshalVT(dAtA []byte) error

+ func (this *Config) EqualMessageVT(thatMsg any) bool

+ func (this *Config) EqualVT(that *Config) bool

+ func (x *Config) GetDefaultLookup() *proto.ControllerConfig

+ func (x *Config) GetDisableDefaultLookup() bool

+ func (x *Config) GetDisableLookup() bool

+ func (x *Config) MarshalJSON() ([]byte, error)

+ func (x *Config) MarshalProtoJSON(s *json.MarshalState)

+ func (x *Config) MarshalProtoText() string

+ func (x *Config) Reset()

+ func (x *Config) String() string

+ func (x *Config) UnmarshalJSON(b []byte) error

+ func (x *Config) UnmarshalProtoJSON(s *json.UnmarshalState)

+ type Controller struct

+ func NewController(cc *Config, le *logrus.Entry, b bus.Bus) *Controller

+ func (c *Controller) Close() error

+ func (c *Controller) Execute(ctx context.Context) error

+ func (c *Controller) GetControllerInfo() *controller.Info

+ func (c *Controller) HandleDirective(ctx context.Context, di directive.Instance) ([]directive.Resolver, error)

+ type Factory struct

+ func NewFactory(bus bus.Bus) *Factory

+ func (t *Factory) Construct(ctx context.Context, conf config.Config, opts controller.ConstructOpts) (controller.Controller, error)

+ func (t *Factory) ConstructConfig() config.Config

+ func (t *Factory) GetConfigID() string

+ func (t *Factory) GetControllerID() string

+ func (t *Factory) GetVersion() semver.Version