component

Documentation

Index

• Constants
• Variables
• func GetUidGid(username string) (uid, gid int)
• type BackoffNode
• type ClusterComponent
• type ClusterComponentData
• type ClusterConfig
• type Etcd
  • func (e Etcd) Backup() error
  • func (e Etcd) Configure(overwrite bool) error
  • func (e Etcd) Init(dir string) error
  • func (e Etcd) Restore() error
• type EtcdConfig
• type HTTPAdapterSet
• type ListOutput
• type Master
  • func (m Master) Backup() error
  • func (m Master) Configure(overwrite bool) error
  • func (m Master) Init(dir string) error
  • func (m Master) Restore() error
• type MasterConfig
• type Node
  • func (n Node) Backup() error
  • func (n Node) Configure(overwrite bool) error
  • func (n Node) Init(s string) error
  • func (n Node) Restore() error
• type NodeConfig
• type OpenVPN
  • func (o OpenVPN) Backup() error
  • func (o OpenVPN) Configure(overwrite bool) error
  • func (o OpenVPN) Init(dir string) error
  • func (o OpenVPN) Restore() error
• type OpenVPNClient
  • func (o OpenVPNClient) CreateUser(clientName string) error
  • func (o OpenVPNClient) ListUserCertificates(output string) error
  • func (o OpenVPNClient) RevokeUser(clientName string) error
• type OpenVPNConfig
• type RevocationResponse
• type SSHComponent
  • func (o SSHComponent) Backup() error
  • func (o SSHComponent) Configure(overwrite bool) error
  • func (o SSHComponent) Init(dir string) error
  • func (o SSHComponent) Restore() error
• type SSHConfig
• type SSHUsersFile
• type SystemUser
• type UserSpec

Constants

const (
	EtcdCaCrt              = "ca.crt"
	EtcdCaKey              = "ca.key"
	SnapshotFilenameBucket = "snapshot.db"
)

const (
	MasterSaKey     = "sa.key"
	MasterSaPub     = "sa.pub"
	MasterFProxyCrt = "front-proxy-ca.crt"
	MasterFProxyKey = "front-proxy-ca.key"
	MasterCaKey     = "ca.key"
	MasterCaCrt     = "ca.crt"
)

const (
	JoinFile                 string        = "join.sh"
	BucketPath               string        = "join"
	LocalJoinFilePath        string        = "."
	DefaultJointTimeoutValue time.Duration = 30
)

const (
	OpenVPNServerCert = "server.crt"
	OpenVPNServerKey  = "server.key"
	OpenVPNCaCert     = "ca.crt"
	OpenVPNCaKey      = "ca.key"
	OpenVPNCRL        = "ca.crl"
	OpenVPNTaKey      = "ta.key"
	OpenVPNPath       = "pki/vpn"
)

const (
	OpenVPNClientCert        = "client.crt"
	OpenVPNClientKey         = "client.key"
	OpenVPNClientCaCert      = "ca.crt"
	OpenVPNClientCaKey       = "ca.key"
	OpenVPNClientTaKey       = "ta.key"
	OpenVPNClientPath        = "pki/vpn-client"
	OpenVPNClientRevokedPath = "pki/vpn-client/revoked"
)

const (
	SSHUserSpecs                  = "ssh-users.yml"
	SSHBucketDir                  = "ssh"
	SSHAuthorizedKeysFileName     = "authorized_keys"
	SSHAuthorizedKeysTempFileName = "authorized_keys_tmp"
	SSHSudoerDir                  = "/etc/sudoers.d"
)

Variables

var (
	CertConfig = certutil.Config{
		CommonName:   "SIGHUP s.r.l. Server",
		Organization: []string{"SIGHUP s.r.l."},
		AltNames:     certutil.AltNames{DNSNames: []string{}, IPs: []net.IP{}},
		Usages:       []x509.ExtKeyUsage{x509.ExtKeyUsageServerAuth},
	}
)

Functions

func GetUidGid

func GetUidGid(username string) (uid, gid int)

Types

type BackoffNode

type BackoffNode struct {
	Node
	OverWrite bool
}

type ClusterComponent

type ClusterComponent interface {
	Backup() error
	Restore() error
	Configure(bool) error
	Init(string) error
}

ClusterComponent interface represent the basic concept of the component: etcd, master, node

type ClusterComponentData

type ClusterComponentData struct {
	*ClusterConfig
	*storage.Data
}

type ClusterConfig

type ClusterConfig struct {
	NodeName string        `mapstructure:"nodeName"`
	Etcd     EtcdConfig    `mapstructure:"etcd"`
	Master   MasterConfig  `mapstructure:"master"`
	Node     NodeConfig    `mapstructure:"node"`
	OpenVPN  OpenVPNConfig `mapstructure:"openvpn"`
	SSH      SSHConfig     `mapstructure:"sshkeys"`
}

ClusterConfig represents the configuration for the whole cluster

type Etcd

type Etcd struct {
	ClusterComponentData
}

Etcd implements the ClusterComponent Interface

func (Etcd) Backup

func (e Etcd) Backup() error

Backup implements

func (Etcd) Configure

func (e Etcd) Configure(overwrite bool) error

func (Etcd) Init

func (e Etcd) Init(dir string) error

func (Etcd) Restore

func (e Etcd) Restore() error

Restore implements

type EtcdConfig

type EtcdConfig struct {
	DataDir             string `mapstructure:"dataDir"`
	CertDir             string `mapstructure:"certDir"`
	CaCertFilename      string `mapstructure:"caCertFilename"`
	CaKeyFilename       string `mapstructure:"caKeyFilename"`
	ClientCertFilename  string `mapstructure:"clientCertFilename"`
	InitialClusterToken string `mapstructure:"initialClusterToken"`
	SnapshotFile        string `mapstructure:"snapshotFile"`
	ClientKeyFilename   string `mapstructure:"clientKeyFilename"`
	Endpoint            string `mapstructure:"endpoint"`
}

EtcdConfig is used to backup/restore/configure etcd nodes

type HTTPAdapterSet

type HTTPAdapterSet struct {
	Name string
	Uri  string
}

type ListOutput

type ListOutput struct {
	User      string             `json:"user"`
	ValidFrom string             `json:"valid_from"`
	ValidTo   string             `json:"valid_to"`
	Expired   bool               `json:"expired"`
	Revoked   RevocationResponse `json:"revoke_info"`
}

type Master

type Master struct {
	ClusterComponentData
}

Master implements the ClusterComponent interface

func (Master) Backup

func (m Master) Backup() error

Backup implements

func (Master) Configure

func (m Master) Configure(overwrite bool) error

Configure implements

func (Master) Init

func (m Master) Init(dir string) error

func (Master) Restore

func (m Master) Restore() error

Restore implements

type MasterConfig

type MasterConfig struct {
	CertDir          string `mapstructure:"certDir"`
	CaCertFile       string `mapstructure:"caCertFilename"`
	CaKeyFile        string `mapstructure:"caKeyFilename"`
	SaPubFile        string `mapstructure:"saPubFilename"`
	SaKeyFile        string `mapstructure:"saKeyFilename"`
	ProxyCaCertFile  string `mapstructure:"proxyCaCertFilename"`
	ProxyKeyCertFile string `mapstructure:"proxyKeyCertFilename"`
}

MasterConfig is used to backup/restore/configure master nodes

type Node

type Node struct {
	ClusterComponentData
}

Node represent the object that reflects what nodes need (implements ClusterComponent)

func (Node) Backup

func (n Node) Backup() error

Backup of a node is Empty

func (Node) Configure

func (n Node) Configure(overwrite bool) error

Configure basically joins the nodes to the cluster

func (Node) Init

func (n Node) Init(s string) error

Init is for interface compliance, now is empty

func (Node) Restore

func (n Node) Restore() error

Restore of a node is Empty

type NodeConfig

type NodeConfig struct {
	CloudProvider string `mapstructure:"caKeyFilename"`
	// contains filtered or unexported fields
}

NodeConfig is used to backup/restore/configure worker nodes (backup and restore have an empty implementation right now)

type OpenVPN

type OpenVPN struct {
	ClusterComponentData
}

func (OpenVPN) Backup

func (o OpenVPN) Backup() error

func (OpenVPN) Configure

func (o OpenVPN) Configure(overwrite bool) error

func (OpenVPN) Init

func (o OpenVPN) Init(dir string) error

func (OpenVPN) Restore

func (o OpenVPN) Restore() error

type OpenVPNClient

type OpenVPNClient struct {
	ClusterComponentData
}

func (OpenVPNClient) CreateUser

func (o OpenVPNClient) CreateUser(clientName string) error

func (OpenVPNClient) ListUserCertificates

func (o OpenVPNClient) ListUserCertificates(output string) error

func (OpenVPNClient) RevokeUser

func (o OpenVPNClient) RevokeUser(clientName string) error

type OpenVPNConfig

type OpenVPNConfig struct {
	CertDir string   `mapstructure:"certDir"`
	Servers []string `mapstructure:"servers"`
}

type RevocationResponse

type RevocationResponse struct {
	Revoked    bool      `json:"revoked"`
	RevokeTime time.Time `json:"revoked_time"`
}

type SSHComponent

type SSHComponent struct {
	ClusterComponentData
}

func (SSHComponent) Backup

func (o SSHComponent) Backup() error

Backup is a nil function to match the interface

func (SSHComponent) Configure

func (o SSHComponent) Configure(overwrite bool) error

Configure setup for each file entry the github configured ssh keys in the authorized_keys file

func (SSHComponent) Init

func (o SSHComponent) Init(dir string) error

func (SSHComponent) Restore

func (o SSHComponent) Restore() error

Restore is a nil function to match the interface

type SSHConfig

type SSHConfig struct {
	User            string         `mapstructure:"user"`
	TempDir         string         `mapstructure:"tempDir"`
	LocalDirConfigs string         `mapstructure:"localDirConfigs"`
	Adapter         HTTPAdapterSet `mapstructure:"adapter"`
}

type SSHUsersFile

type SSHUsersFile struct {
	Users []UserSpec `yaml:"users"`
}

type SystemUser

type SystemUser struct {
	Name string
	Home string
	Gid  int
	Uid  int
}

type UserSpec

type UserSpec struct {
	Name   string `yaml:"name"`
	UserID string `yaml:"user_id"`
}