util

package

v2.1.1+incompatible Latest Latest Go to latest Published: May 21, 2019 License: Apache-2.0 Imports: 31 Imported by: 16

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var (
	ErrInvalidCredentials = errors.New("invalid credentials")
)

func BindParams(params map[string]string, object interface{}) error

bind params uses json serializing and reflect package that is underneath to avoid direct access to map for getting appropriate field values.

func BootstrapKeys(config *steps.Config) error

Create bootstrap key pair and save to config ssh section

func CreateLBName(clusterID string, isExternal bool) string

func FillCloudAccountCredentials(cloudAccount *model.CloudAccount, config *steps.Config) error

TODO(stgleb): move getting cloud account outside of this function Gets cloud account from storage and fills config object with those credentials

func GetLogger(w io.Writer) (log *logrus.Logger)

func GetRandomNode(nodeMap map[string]*model.Machine) *model.Machine

func GetWriter(name string) (io.WriteCloser, error)

func LoadCloudSpecificDataFromKube(k *model.Kube, config *steps.Config) error

func MakeFileName(taskID string) string

func MakeKeyName(name string, isUser bool) string

func MakeNodeName(clusterName string, nodeId string, isMaster bool) string

func MakeRole(isMaster bool) string

func RandomString(n int) string

RandomString generates random string with reservoir sampling algorithm https://en.wikipedia.org/wiki/Reservoir_sampling

func UpdateKubeWithCloudSpecificData(k *model.Kube, config *steps.Config)

type CloudAccountValidator interface {
	ValidateCredentials(cloudAccount *model.CloudAccount) error
}

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

func NewCloudAccountValidator() *CloudAccountValidatorImpl

func (v *CloudAccountValidatorImpl) ValidateCredentials(cloudAccount *model.CloudAccount) error

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

func NewCountdownLatch(ctx context.Context, count int) *CountdownLatch

func (c *CountdownLatch) CountDown()

CountDown decrements the counter

func (c *CountdownLatch) Wait()

Wait until count down to zero or if context is done

Path	Synopsis
strset