registration

Documentation

Index

• type FileContent
  • func NewFileContent(c *config.Config, _ ServerInfoSource, logger *logrus.Entry) (*FileContent, error)
  • func (fc *FileContent) Init(c *config.Config, logger *logrus.Entry)
  • func (fc *FileContent) StartRegistration(ctx context.Context, wg *sync.WaitGroup, interval int, ...)
• type FileContentMessage
• type InventoryBuildInfo
• type InventoryContent
  • func NewInventoryContent(c *config.Config, si ServerInfoSource, logger *logrus.Entry) (*InventoryContent, error)
  • func (ic *InventoryContent) Init(c *config.Config, logger *logrus.Entry)
  • func (ic *InventoryContent) StartRegistration(ctx context.Context, wg *sync.WaitGroup, interval int, ...)
• type InventoryContentMessage
• type InventoryData
• type InventoryMachineState
• type ServerInfoSource

Types

type FileContent

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

FileContent is a fully managed registration plugin for the choria server instance it reads a file and publishing it to the collective regularly

func NewFileContent

func NewFileContent(c *config.Config, _ ServerInfoSource, logger *logrus.Entry) (*FileContent, error)

NewFileContent creates a new fully managed registration plugin instance

func (*FileContent) Init

func (fc *FileContent) Init(c *config.Config, logger *logrus.Entry)

Init sets up the plugin

func (*FileContent) StartRegistration

func (fc *FileContent) StartRegistration(ctx context.Context, wg *sync.WaitGroup, interval int, output chan *data.RegistrationItem)

StartRegistration starts stats a publishing loop

type FileContentMessage

type FileContentMessage struct {
	Mtime    int64  `json:"mtime"`
	File     string `json:"file"`
	Updated  bool   `json:"updated"`
	Protocol string `json:"protocol"`
	Content  []byte `json:"content,omitempty"`
	ZContent []byte `json:"zcontent,omitempty"`
}

FileContentMessage contains message being published

type InventoryBuildInfo

type InventoryBuildInfo struct {
	Version string `json:"version"`
	SHA     string `json:"sha"`
}

type InventoryContent

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

InventoryContent is a fully managed registration plugin for the choria server instance it reads the server inventory and publishing it to the collective regularly

func NewInventoryContent

func NewInventoryContent(c *config.Config, si ServerInfoSource, logger *logrus.Entry) (*InventoryContent, error)

NewInventoryContent creates a new fully managed registration plugin instance

func (*InventoryContent) Init

func (ic *InventoryContent) Init(c *config.Config, logger *logrus.Entry)

Init sets up the plugin

func (*InventoryContent) StartRegistration

func (ic *InventoryContent) StartRegistration(ctx context.Context, wg *sync.WaitGroup, interval int, output chan *data.RegistrationItem)

StartRegistration starts stats a publishing loop

type InventoryContentMessage

type InventoryContentMessage struct {
	Protocol string          `json:"protocol"`
	Content  json.RawMessage `json:"content,omitempty"`
	ZContent []byte          `json:"zcontent,omitempty"`
}

type InventoryData

type InventoryData struct {
	Agents      []agents.Metadata          `json:"agents"`
	Classes     []string                   `json:"classes"`
	Facts       json.RawMessage            `json:"facts"`
	Status      *statistics.InstanceStatus `json:"status"`
	Collectives []string                   `json:"collectives"`
	BuildInfo   *InventoryBuildInfo        `json:"build_info"`
	AutoAgents  []*InventoryMachineState   `json:"machines"`
}

type InventoryMachineState

type InventoryMachineState struct {
	Name    string `json:"name"`
	Version string `json:"version"`
	State   string `json:"state"`
}

type ServerInfoSource

type ServerInfoSource interface {
	Classes() []string
	Facts() json.RawMessage
	Identity() string
	KnownAgents() []string
	DataFuncMap() (ddl.FuncMap, error)
	Status() *statistics.InstanceStatus
	AgentMetadata(agent string) (agents.Metadata, bool)
	BuildInfo() *build.Info
	MachinesStatus() ([]aagent.MachineState, error)
}