foundry

package

v1.1.7 Latest Latest Go to latest Published: Apr 16, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

gitlab.com/mergetb/tech/foundry

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func Delete(obj Object) error
func DeleteConfigs(ids []string) error
func DeleteObjects(objs []Object) error
func Error(message string) error
func ErrorE(message string, err error) error
func ErrorEF(message string, err error, fields log.Fields) error
func ErrorF(message string, fields log.Fields) error
func EtcdClient() (*clientv3.Client, error)
func EtcdConnect() (*clientv3.Client, error)
func GRPCServerOptions() []grpc.ServerOption
func GetConfigs(ids []string) ([]*api.MachineConfig, error)
func GetStatuses(ids []string) (map[string]*api.MachineStatus, error)
func InitLogging(logname string)
func IsTxnFailed(err error) bool
func ListConfigs() (map[string]*api.Config, error)
func Prepare(rq *api.ForgeRequest) (*api.MachineConfig, error)
func Read(obj Object) error
func ReadNew(obj Object) error
func ReadObjects(objs []Object) (error, int)
func RunObjectTx(otx ObjectTx) error
func SetConfigs(configs []*api.MachineConfig) error
func SetStatus(id string, status *api.MachineStatus) error
func TxnFailed(message string) error
func Write(obj Object, opts ...etcd.OpOption) error
func WriteObjects(objs []Object, opts ...etcd.OpOption) error
type Config
- func LoadConfig() *Config
- func ServerConfig() *Config
type Object
type ObjectTx
type TlsConfig

Constants ¶

View Source

const (
	TxnFailedPrefix = "txn failed"
)

Variables ¶

View Source

var (
	MaxMessageSize = 4 * 1024 * 1024
)

View Source

var NotFound error = fmt.Errorf("not found")

View Source

var (
	// Version is the package version
	Version = "undefined"
)

Functions ¶

func Delete ¶

func Delete(obj Object) error

func DeleteConfigs ¶

func DeleteConfigs(ids []string) error

DeleteConfigs removes the machine configuration from the datastore

func DeleteObjects ¶

func DeleteObjects(objs []Object) error

func Error ¶

func Error(message string) error

Error creates an error, and logs it righteously

func ErrorE ¶

func ErrorE(message string, err error) error

Encapsulate err in a structured log and return an abstracted high-level error with message as the payload

func ErrorEF ¶

func ErrorEF(message string, err error, fields log.Fields) error

Encapsulate fields and err in a structured log and return an abstracted high-level error with message as the payload

func ErrorF ¶

func ErrorF(message string, fields log.Fields) error

Encapsulate fields in a structured log and return an abstracted high-level error with message as the payload

func EtcdClient ¶

func EtcdClient() (*clientv3.Client, error)

func EtcdConnect ¶

func EtcdConnect() (*clientv3.Client, error)

Try up to 10 times to connect to etcd

func GRPCServerOptions ¶ added in v0.3.2

func GRPCServerOptions() []grpc.ServerOption

func GetConfigs ¶

func GetConfigs(ids []string) ([]*api.MachineConfig, error)

GetConfigs retrieves the configuration from the datastore

func GetStatuses ¶ added in v1.1.7

func GetStatuses(ids []string) (map[string]*api.MachineStatus, error)

GetStatuses retrieves foundry completion statuses for the given IDs. If ids is empty, returns all statuses.

func InitLogging ¶

func InitLogging(logname string)

func IsTxnFailed ¶

func IsTxnFailed(err error) bool

func ListConfigs ¶

func ListConfigs() (map[string]*api.Config, error)

ListConfigs retrieves all machine configurations from the datastore

func Prepare ¶

func Prepare(rq *api.ForgeRequest) (*api.MachineConfig, error)

func Read ¶

func Read(obj Object) error

func ReadNew ¶

func ReadNew(obj Object) error

func ReadObjects ¶

func ReadObjects(objs []Object) (error, int)

func RunObjectTx ¶

func RunObjectTx(otx ObjectTx) error

func SetConfigs ¶

func SetConfigs(configs []*api.MachineConfig) error

SetConfigs configures foundry's datastore with machine configuration

func SetStatus ¶ added in v1.1.7

func SetStatus(id string, status *api.MachineStatus) error

SetStatus stores a machine's foundry completion status in etcd.

func TxnFailed ¶

func TxnFailed(message string) error

func Write ¶

func Write(obj Object, opts ...etcd.OpOption) error

func WriteObjects ¶

func WriteObjects(objs []Object, opts ...etcd.OpOption) error

Types ¶

type Config ¶

type Config struct {
	ManageEndpoint string     `yaml:"manage_endpoint"`
	EtcdEndpoint   string     `yaml:"etcd_endpoint"`
	EtcdTls        *TlsConfig `yaml:"etcd_tls"`
}

func LoadConfig ¶

func LoadConfig() *Config

func ServerConfig ¶

func ServerConfig() *Config

type Object ¶

type Object interface {
	Key() string
	GetVersion() int64
	SetVersion(int64)
	Value() interface{}
}

all obejcts that go to and fro from the database implement this interface

type ObjectTx ¶

type ObjectTx struct {
	Put    []Object
	Delete []Object
}

type TlsConfig ¶

type TlsConfig struct {
	CA   string `key:"ca"`
	Cert string `yaml:"cert"`
	Key  string `yaml:"key"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL