nodes

Documentation

Overview

Package nodes provides changesets for managing Job Distributor nodes.

Usage

import "github.com/smartcontractkit/cld-changesets/jd/changesets/nodes"

// Register nodes (idempotent — already-registered nodes are skipped):
_, err := runtime.ExecChangeset(rt, nodes.RegisterNodesChangeset{}, nodes.RegisterNodesInput{
	Domain: "keystone",
	Nodes: []nodes.NodeToRegister{{
		Name:   "oracle-1",
		CSAKey: "csa-key-1",
	}},
})

// Update node name and/or labels:
_, err = runtime.ExecChangeset(rt, nodes.UpdateNodesChangeset{}, nodes.UpdateNodesInput{
	Nodes: []nodes.NodeToUpdate{{
		ID:     "node-id-1",
		CSAKey: "csa-key-1",
		Name:   "oracle-1-updated",
	}},
})

// Disable nodes by CSA key (idempotent — not-found and already-disabled are skipped):
_, err = runtime.ExecChangeset(rt, nodes.DisableNodesChangeset{}, nodes.DisableNodesInput{
	CSAKeys: []string{"csa-key-1"},
})

Index

• type DisableNodesChangeset
  • func (DisableNodesChangeset) Apply(e cldf.Environment, input DisableNodesInput) (cldf.ChangesetOutput, error)
  • func (DisableNodesChangeset) VerifyPreconditions(_ cldf.Environment, cfg DisableNodesInput) error
• type DisableNodesInput
• type NodeToRegister
• type NodeToUpdate
• type RegisterNodesChangeset
  • func (RegisterNodesChangeset) Apply(e cldf.Environment, input RegisterNodesInput) (cldf.ChangesetOutput, error)
  • func (RegisterNodesChangeset) VerifyPreconditions(_ cldf.Environment, cfg RegisterNodesInput) error
• type RegisterNodesInput
• type UpdateNodesChangeset
  • func (UpdateNodesChangeset) Apply(e cldf.Environment, input UpdateNodesInput) (cldf.ChangesetOutput, error)
  • func (UpdateNodesChangeset) VerifyPreconditions(_ cldf.Environment, cfg UpdateNodesInput) error
• type UpdateNodesInput

Types

type DisableNodesChangeset

type DisableNodesChangeset struct{}

DisableNodesChangeset disables nodes by CSA key.

func (DisableNodesChangeset) Apply

func (DisableNodesChangeset) Apply(e cldf.Environment, input DisableNodesInput) (cldf.ChangesetOutput, error)

func (DisableNodesChangeset) VerifyPreconditions

func (DisableNodesChangeset) VerifyPreconditions(_ cldf.Environment, cfg DisableNodesInput) error

type DisableNodesInput

type DisableNodesInput = jdops.DisableNodesInput

DisableNodesInput is the serializable input of DisableNodesChangeset.

type NodeToRegister

type NodeToRegister = jdops.NodeToRegister

NodeToRegister is the per-node input for RegisterNodesInput.

type NodeToUpdate

type NodeToUpdate = jdops.NodeToUpdate

NodeToUpdate is the per-node input for UpdateNodesInput.

type RegisterNodesChangeset

type RegisterNodesChangeset struct{}

RegisterNodesChangeset upserts nodes (already-registered nodes are skipped).

func (RegisterNodesChangeset) Apply

func (RegisterNodesChangeset) Apply(e cldf.Environment, input RegisterNodesInput) (cldf.ChangesetOutput, error)

func (RegisterNodesChangeset) VerifyPreconditions

func (RegisterNodesChangeset) VerifyPreconditions(_ cldf.Environment, cfg RegisterNodesInput) error

type RegisterNodesInput

type RegisterNodesInput = jdops.RegisterNodesInput

RegisterNodesInput is the serializable input of RegisterNodesChangeset.

type UpdateNodesChangeset

type UpdateNodesChangeset struct{}

UpdateNodesChangeset updates node name and/or labels.

func (UpdateNodesChangeset) Apply

func (UpdateNodesChangeset) Apply(e cldf.Environment, input UpdateNodesInput) (cldf.ChangesetOutput, error)

func (UpdateNodesChangeset) VerifyPreconditions

func (UpdateNodesChangeset) VerifyPreconditions(_ cldf.Environment, cfg UpdateNodesInput) error

type UpdateNodesInput

type UpdateNodesInput = jdops.UpdateNodesInput

UpdateNodesInput is the serializable input of UpdateNodesChangeset.