util

Documentation

Index

• Variables
• func GenerateLockfile(service string) error
• func LockfileBackoff(lockfilePath string) error
• func RemoveLockfile(service string) error
• func UpdateCPULoad()

Variables

var BackoffSchedule = []time.Duration{
	1 * time.Second,
	2 * time.Second,
	4 * time.Second,
	8 * time.Second,
	16 * time.Second,
}

var (
	CPU_HIGH = false
)

var ProcessBackoff = func() error {
	timeout := time.NewTimer(_backoff_timeout)
	defer timeout.Stop()

	select {
	case <-time.After(_backoff_duration):
		logger.DefaultLogger.Warn("cpu load high")
		return nil
	case <-timeout.C:
		return logger.RpcError(status.Error(codes.Internal, "queue processinging signing requests at capacity"), nil)
	}
}

Backoff Authentication middleware/authentication.go

Functions

func GenerateLockfile

func GenerateLockfile(service string) error

func LockfileBackoff

func LockfileBackoff(lockfilePath string) error

func RemoveLockfile

func RemoveLockfile(service string) error

func UpdateCPULoad

func UpdateCPULoad()