entitygraph_controller

Documentation

Index

• Constants
• Variables
• type CollectEntityGraphDirective
  • func NewCollectEntityGraphDirective() *CollectEntityGraphDirective
  • func (d *CollectEntityGraphDirective) CollectEntityGraphDirective()
  • func (d *CollectEntityGraphDirective) GetDebugVals() directive.DebugValues
  • func (d *CollectEntityGraphDirective) GetName() string
  • func (d *CollectEntityGraphDirective) GetValueOptions() directive.ValueOptions
  • func (d *CollectEntityGraphDirective) IsEquivalent(other directive.Directive) bool
  • func (d *CollectEntityGraphDirective) Superceeds(other directive.Directive) bool
  • func (d *CollectEntityGraphDirective) Validate() error
• type Config
  • func (m *Config) CloneMessageVT() proto.Message
  • func (m *Config) CloneVT() *Config
  • func (*Config) Descriptor() ([]byte, []int)
  • func (this *Config) EqualMessageVT(thatMsg proto.Message) bool
  • func (this *Config) EqualVT(that *Config) bool
  • func (c *Config) EqualsConfig(other config.Config) bool
  • func (c *Config) GetConfigID() string
  • 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 (*Config) ProtoMessage()
  • func (x *Config) ProtoReflect() protoreflect.Message
  • func (x *Config) Reset()
  • func (m *Config) SizeVT() (n int)
  • func (x *Config) String() string
  • func (m *Config) UnmarshalVT(dAtA []byte) error
  • func (c *Config) Validate() error
• type Controller
  • func NewController(le *logrus.Entry, bus bus.Bus, conf *Config) *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, inst directive.Instance) ([]directive.Resolver, error)
• type Factory
  • func NewFactory(bus bus.Bus) *Factory
  • func (t *Factory) Construct(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

Constants

const ConfigID = ControllerID

ConfigID is the string used to identify this config object.

const ControllerID = "entitygraph/collector/1"

ControllerID is the ID of the controller.

Variables

var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)

var File_github_com_aperturerobotics_entitygraph_controller_config_proto protoreflect.FileDescriptor

var Version = semver.MustParse("0.0.1")

Version is the version of the controller implementation.

Types

type CollectEntityGraphDirective

type CollectEntityGraphDirective struct {
}

CollectEntityGraphDirective implements CollectEntityGraph.

func NewCollectEntityGraphDirective

func NewCollectEntityGraphDirective() *CollectEntityGraphDirective

NewCollectEntityGraphDirective constructs a new CollectEntityGraph directive.

func (*CollectEntityGraphDirective) CollectEntityGraphDirective

func (d *CollectEntityGraphDirective) CollectEntityGraphDirective()

CollectEntityGraphDirective is a marker function.

func (*CollectEntityGraphDirective) GetDebugVals

func (d *CollectEntityGraphDirective) GetDebugVals() directive.DebugValues

GetDebugVals returns the directive arguments as k/v pairs. This is not necessarily unique, and is primarily intended for display.

func (*CollectEntityGraphDirective) GetName

func (d *CollectEntityGraphDirective) GetName() string

GetName returns the directive's type name. This is not necessarily unique, and is primarily intended for display.

func (*CollectEntityGraphDirective) GetValueOptions

func (d *CollectEntityGraphDirective) GetValueOptions() directive.ValueOptions

GetValueOptions returns options relating to value handling.

func (*CollectEntityGraphDirective) IsEquivalent

func (d *CollectEntityGraphDirective) IsEquivalent(other directive.Directive) bool

IsEquivalent checks if the other directive is equivalent. If two directives are equivalent, and the new directive does not superceed the old, then the new directive will be merged (de-duplicated) into the old.

func (*CollectEntityGraphDirective) Superceeds

func (d *CollectEntityGraphDirective) Superceeds(other directive.Directive) bool

Superceeds checks if the directive overrides another. The other directive will be canceled if superceded.

func (*CollectEntityGraphDirective) Validate

func (d *CollectEntityGraphDirective) Validate() error

Validate validates the directive. This is a cursory validation to see if the values "look correct."

type Config

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

Config is the entity graph aggregation controller config.

func (*Config) CloneMessageVT

func (m *Config) CloneMessageVT() proto.Message

func (*Config) CloneVT

func (m *Config) CloneVT() *Config

func (*Config) Descriptor

func (*Config) Descriptor() ([]byte, []int)

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) EqualMessageVT

func (this *Config) EqualMessageVT(thatMsg proto.Message) bool

func (*Config) EqualVT

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

func (*Config) EqualsConfig

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

EqualsConfig checks if the other config is equal.

func (*Config) GetConfigID

func (c *Config) GetConfigID() string

GetConfigID returns the unique string for this configuration type. This string is stored with the encoded config.

func (*Config) MarshalToSizedBufferVT

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

func (*Config) MarshalToVT

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

func (*Config) MarshalVT

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

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) ProtoReflect

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset

func (x *Config) Reset()

func (*Config) SizeVT

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

func (*Config) String

func (x *Config) String() string

func (*Config) UnmarshalVT

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

func (*Config) Validate

func (c *Config) Validate() error

Validate validates the configuration. This is a cursory validation to see if the values "look correct."

type Controller

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

Controller implements the entity graph aggregation controller. The controller issues a CollectEntityGraph directive, aggregates entities, and fulfills ObserveEntityGraph directives.

func NewController

func NewController(
	le *logrus.Entry,
	bus bus.Bus,
	conf *Config,
) *Controller

NewController constructs a new entity graph controller.

func (*Controller) Close

func (c *Controller) Close() error

Close releases any resources used by the controller. Error indicates any issue encountered releasing.

func (*Controller) Execute

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

Execute executes the given controller. Returning nil ends execution. Returning an error triggers a retry with backoff.

func (*Controller) GetControllerInfo

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

GetControllerInfo returns information about the controller.

func (*Controller) HandleDirective

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

HandleDirective asks if the handler can resolve the directive.

type Factory

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

Factory constructs a entity graph controller.

func NewFactory

func NewFactory(bus bus.Bus) *Factory

NewFactory builds a entity graph controller factory.

func (*Factory) Construct

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

Construct constructs the associated controller given configuration. The transport's identity (private key) comes from a GetNode lookup.

func (*Factory) ConstructConfig

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

ConstructConfig constructs an instance of the controller configuration.

func (*Factory) GetConfigID

func (t *Factory) GetConfigID() string

GetConfigID returns the configuration ID for the controller.

func (*Factory) GetControllerID

func (t *Factory) GetControllerID() string

GetControllerID returns the unique ID for the controller.

func (*Factory) GetVersion

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

GetVersion returns the version of this controller.