store

Documentation

Index

• func GenerateName(txn *Txn) (string, error)
• func IsErrInvalidName(err error) bool
• func ValidateName(s string) (string, error)
• type Node
  • func (n *Node) Copy() *Node
• type NodeGroup
  • func (ng *NodeGroup) Copy() *NodeGroup
  • func (ng *NodeGroup) Leave(name string) error
  • func (ng *NodeGroup) Update(name, endpoint string, platforms []string, endpointsSet bool, ...) error
• type Store
  • func New(cfg *confutil.Config) (*Store, error)
  • func (s *Store) Txn() (*Txn, func(), error)
• type Txn
  • func (t *Txn) Current(key string) (*NodeGroup, error)
  • func (t *Txn) GetLastActivity(ng *NodeGroup) (la time.Time, _ error)
  • func (t *Txn) List() ([]*NodeGroup, error)
  • func (t *Txn) NodeGroupByName(name string) (*NodeGroup, error)
  • func (t *Txn) Remove(name string) error
  • func (t *Txn) RemoveLastActivity(name string) error
  • func (t *Txn) Save(ng *NodeGroup) error
  • func (t *Txn) SetCurrent(key, name string, global, def bool) error
  • func (t *Txn) UpdateLastActivity(ng *NodeGroup) error

Functions

func GenerateName

func GenerateName(txn *Txn) (string, error)

func IsErrInvalidName

func IsErrInvalidName(err error) bool

func ValidateName

func ValidateName(s string) (string, error)

Types

type Node

type Node struct {
	Name           string
	Endpoint       string
	Platforms      []specs.Platform
	DriverOpts     map[string]string
	BuildkitdFlags []string `json:"Flags"` // keep the field name for backward compatibility

	Files map[string][]byte
}

func (*Node) Copy

func (n *Node) Copy() *Node

type NodeGroup

type NodeGroup struct {
	Name    string
	Driver  string
	Nodes   []Node
	Dynamic bool

	// skip the following fields from being saved in the store
	DockerContext bool      `json:"-"`
	LastActivity  time.Time `json:"-"`
}

func (*NodeGroup) Copy

func (ng *NodeGroup) Copy() *NodeGroup

func (*NodeGroup) Leave

func (ng *NodeGroup) Leave(name string) error

func (*NodeGroup) Update

func (ng *NodeGroup) Update(name, endpoint string, platforms []string, endpointsSet bool, actionAppend bool, buildkitdFlags []string, buildkitdConfigFile string, do map[string]string) error

type Store

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

func New

func New(cfg *confutil.Config) (*Store, error)

func (*Store) Txn

func (s *Store) Txn() (*Txn, func(), error)

type Txn

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

func (*Txn) Current

func (t *Txn) Current(key string) (*NodeGroup, error)

func (*Txn) GetLastActivity

func (t *Txn) GetLastActivity(ng *NodeGroup) (la time.Time, _ error)

func (*Txn) List

func (t *Txn) List() ([]*NodeGroup, error)

func (*Txn) NodeGroupByName

func (t *Txn) NodeGroupByName(name string) (*NodeGroup, error)

func (*Txn) Remove

func (t *Txn) Remove(name string) error

func (*Txn) RemoveLastActivity

func (t *Txn) RemoveLastActivity(name string) error

func (*Txn) Save

func (t *Txn) Save(ng *NodeGroup) error

func (*Txn) SetCurrent

func (t *Txn) SetCurrent(key, name string, global, def bool) error

func (*Txn) UpdateLastActivity

func (t *Txn) UpdateLastActivity(ng *NodeGroup) error