partyline

Documentation

Overview

Package partyline implements Redis-based communication of command-sets for command-set hosts and their clients.

Index

• func Poller(tu TableUpdater)
• type CommandSetRegistration
  • func NewProvider(selfaddr string, sets []ipc.HostCommandSet) (*CommandSetRegistration, error)
  • func (csr *CommandSetRegistration) Close() error
• type CommandSets
  • func (cs *CommandSets) Poll() (mutated bool, err error)
• type TableUpdater

Functions

func Poller

func Poller(tu TableUpdater)

Types

type CommandSetRegistration

type CommandSetRegistration struct {
	Sets []ipc.HostCommandSet
	// contains filtered or unexported fields
}

TODO: cancel + clean unregister TODO: need to be able to detect cset updates

func NewProvider

func NewProvider(selfaddr string, sets []ipc.HostCommandSet) (*CommandSetRegistration, error)

func (*CommandSetRegistration) Close

func (csr *CommandSetRegistration) Close() error

Close unregisters all commandsets.

type CommandSets

type CommandSets struct {
	Sets map[string]*ipc.HostCommandSet
	// contains filtered or unexported fields
}

func (*CommandSets) Poll

func (cs *CommandSets) Poll() (mutated bool, err error)

type TableUpdater

type TableUpdater interface {
	UpdateSets(sets map[string]*ipc.HostCommandSet)
}