helper

Documentation

Index

• Constants
• func CheckLivenessSSH(privateKey, serverAddress string) error
• func Filter[T any](s []T, fn func(T) bool) []T
• func GenerateSSHKeyPair() (string, string, error)
• func Map[T any, U any](s []T, fn func(T) U) []U
• func ResourceName(jobID string) string
• func SetResourceNamePrefix(prefix string) error
• func WaitReachable(ctx context.Context, privateKey, serverAddress string) error
• type SSHClient
  • func NewSSHClient(privateKeyStr, serverIP string, port uint16) (*SSHClient, error)
  • func (c *SSHClient) Close() error
  • func (c *SSHClient) RunCommand(ctx context.Context, command string) error
• type State
  • func ReadStateFromFile(path string) (*State, error)
  • func (s *State) WriteToFile(path string) error

Constants

const CustomSSHPort = 2222

const StatePath = "state.json"

Functions

func CheckLivenessSSH

func CheckLivenessSSH(privateKey, serverAddress string) error

func Filter

func Filter[T any](s []T, fn func(T) bool) []T

func GenerateSSHKeyPair

func GenerateSSHKeyPair() (string, string, error)

func Map

func Map[T any, U any](s []T, fn func(T) U) []U

func ResourceName

func ResourceName(jobID string) string

func SetResourceNamePrefix

func SetResourceNamePrefix(prefix string) error

func WaitReachable

func WaitReachable(ctx context.Context, privateKey, serverAddress string) error

Types

type SSHClient

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

func NewSSHClient

func NewSSHClient(privateKeyStr, serverIP string, port uint16) (*SSHClient, error)

func (*SSHClient) Close

func (c *SSHClient) Close() error

func (*SSHClient) RunCommand

func (c *SSHClient) RunCommand(ctx context.Context, command string) error

type State

type State struct {
	SSHPrivateKey string
	ServerAddress string
}

func ReadStateFromFile

func ReadStateFromFile(path string) (*State, error)

func (*State) WriteToFile

func (s *State) WriteToFile(path string) error