service

Feb 9, 2023

Changes in this version

type Option

+ func WithMinNodes(i int) Option

Feb 9, 2022

Changes in this version

type Client

+ func (c Client) AdvertizingNodes() (active []string, err error)

Jan 12, 2022

Changes in this version

+ type Client struct

+ func NewClient(serviceID string, c *edgeVPNClient.Client) *Client

+ func (c Client) ActiveNodes() (active []string, err error)

+ func (c Client) Advertize(uuid string) error

+ func (c Client) Clean() error

+ func (c Client) Get(args ...string) (string, error)

+ func (c Client) ListItems(serviceID, suffix string) (strs []string, err error)

+ func (c Client) Set(thing, uuid, value string) error

+ type Node struct

+ func NewNode(o ...Option) (*Node, error)

+ func (k *Node) Clean()

+ func (k *Node) Start(ctx context.Context) error

+ func (k *Node) Stop()

+ type Option func(k *Node) error

+ func WithAPIAddress(s string) Option

+ func WithAssets(assets ...string) Option

+ func WithClient(e *Client) Option

+ func WithDefaultRoles(roles string) Option

+ func WithFS(fs embed.FS) Option

+ func WithLogger(l log.StandardLogger) Option

+ func WithNetworkToken(token string) Option

+ func WithPersistentRoles(roles string) Option

+ func WithRoles(k ...RoleKey) Option

+ func WithStateDir(s string) Option

+ func WithStopRoles(roles string) Option

+ func WithTokenfile(s string) Option

+ func WithUUID(s string) Option

+ type ProcessController struct

+ func NewProcessController(statedir string) *ProcessController

+ func (a *ProcessController) BinaryPath(b string) string

+ func (a *ProcessController) Process(state, p string, opts ...process.Option) *process.Process

+ func (a *ProcessController) Run(command string, args ...string) (string, error)

+ type Role string

+ func (rr Role) Apply(opts ...RoleOption)

+ type RoleConfig struct

+ APIAddress string

+ Client *Client

+ Logger log.StandardLogger

+ NetworkToken string

+ ServiceID string

+ StateDir string

+ UUID string

+ type RoleKey struct

+ Role Role

+ RoleHandler func(c *RoleConfig) error

+ type RoleOption func(c *RoleConfig)

+ func WithRole(f map[Role]func(c *RoleConfig) error) RoleOption

+ func WithRoleAPIAddress(s string) RoleOption

+ func WithRoleClient(e *Client) RoleOption

+ func WithRoleLogger(l log.StandardLogger) RoleOption

+ func WithRoleServiceID(s string) RoleOption

+ func WithRoleStateDir(s string) RoleOption

+ func WithRoleToken(s string) RoleOption

+ func WithRoleUUID(u string) RoleOption