core

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 4, 2026 License: MIT Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DoctorOK    = "ok"
	DoctorWarn  = "warn"
	DoctorError = "error"
)
View Source 
const (
	HostKeyCheckKnownHosts = "known_hosts"
	HostKeyCheckInsecure   = "insecure"

	DefaultConnectTimeout  = "20s"
	DefaultRemoteScriptDir = "/tmp"
	DefaultKnownHostsPath  = "~/.ssh/known_hosts"
)
View Source 
const (
	DefaultSSHPort       = 22
	DefaultGroup         = "default"
	ConfigVersion        = 1
	ConfigEnvKey         = "SSHC_CONFIG"
	ConfigFileName       = "sshc.config.json"
	LegacyConfigFileName = "hosts.json"
)
View Source 
const MaskedSecret = "***"

Variables

This section is empty.

Functions

func AppendRunLog 

func AppendRunLog(host Host, rec RunLogRecord) error

func AuthLabel added in v0.6.0 

func AuthLabel(host Host) string

func BuildRemoteCommand 

func BuildRemoteCommand(command string, env map[string]string) (string, error)

func BuildRemoteCommandWithCWD 

func BuildRemoteCommandWithCWD(command string, env map[string]string, cwd string) (string, error)

func DecryptPassword added in v0.5.0 

func DecryptPassword(value string) (string, error)

func EncryptPassword added in v0.5.0 

func EncryptPassword(password string) (string, error)

func ErrorString 

func ErrorString(err error) string

func ExecuteRemote 

func ExecuteRemote(host Host, command string, opts RunOptions) ([]byte, error)

func HasDoctorErrors added in v0.6.0 

func HasDoctorErrors(issues []DoctorIssue) bool

func HostGroupName 

func HostGroupName(host Host) string

func HostLogName 

func HostLogName(host Host) string

func JoinRemotePath 

func JoinRemotePath(base, elem string) string

func LegacyStorePath added in v0.5.0 

func LegacyStorePath() (string, error)

func LoadRunEnv 

func LoadRunEnv(file string, inline []string) (map[string]string, error)

func LocalDirPath 

func LocalDirPath(remotePath, localPath string) string

func LocalFilePath 

func LocalFilePath(remotePath, localPath string) string

func LoginRemote 

func LoginRemote(host Host) error

func LoginRemoteWithOptions 

func LoginRemoteWithOptions(host Host, opts LoginOptions) error

func NewRemoteScriptPath 

func NewRemoteScriptPath(value time.Time) string

func NewRemoteScriptPathInDir 

func NewRemoteScriptPathInDir(value time.Time, dir string) string

func NewRunTaskID added in v0.6.0 

func NewRunTaskID(startedAt time.Time, host Host, rec RunLogRecord) string

func Now 

func Now() time.Time

func ParseLogLineRange added in v0.6.0 

func ParseLogLineRange(spec string) (start int, end int, ok bool, err error)

func ParseTimeout 

func ParseTimeout(value string) (time.Duration, error)

func PasswordKeyPath added in v0.5.0 

func PasswordKeyPath() (string, error)

func ReadConfigFile added in v0.6.0 

func ReadConfigFile() (string, []byte, error)

func ReadHostsFile added in v0.6.0 

func ReadHostsFile(path string) ([]string, error)

func ReadRunLogOutputByID added in v0.6.0 

func ReadRunLogOutputByID(target, taskID string) ([]byte, error)

func ReadRunLogs 

func ReadRunLogs(target, match string, tail int) ([]string, error)

func ReadRunLogsSelected added in v0.6.0 

func ReadRunLogsSelected(target, match string, tail int, rangeSpec string) ([]string, error)

func RemoteFilePath 

func RemoteFilePath(localPath, remotePath string) string

func RemoteRelPath 

func RemoteRelPath(root, current string) string

func RunOutputPath added in v0.6.0 

func RunOutputPath(taskID string, startedAt time.Time) (string, string, error)

func RunStatus 

func RunStatus(err error) string

func SaveConfig added in v0.6.0 

func SaveConfig(config *Config) error

func SaveStore 

func SaveStore(store *Store) error

func SelectLogLines added in v0.6.0 

func SelectLogLines(lines []string, rangeSpec string, tail int) ([]string, error)

func SetNowForTest 

func SetNowForTest(fn func() time.Time) func()

func SetUserHomeDirForTest 

func SetUserHomeDirForTest(fn func() (string, error)) func()

func SinceMS 

func SinceMS(start time.Time) int64

func StorePath 

func StorePath() (string, error)

func ValidateSudoUser 

func ValidateSudoUser(user string) error

Types

type AuthProfile added in v0.6.0 

type AuthProfile struct {
	Name        string `json:"name"`
	User        string `json:"user,omitempty"`
	Password    string `json:"password,omitempty"`
	PasswordEnc string `json:"password_enc,omitempty"`
	KeyPath     string `json:"key_path,omitempty"`
	Remark      string `json:"remark,omitempty"`
}

func MaskAuthProfile added in v0.6.0 

func MaskAuthProfile(profile AuthProfile) AuthProfile

type BatchHostSource added in v0.6.0 

type BatchHostSource struct {
	Hosts     []string
	HostsFile string
	Group     string
	Overrides HostOverrides
	AuthRef   string
	AllowRaw  bool
}

type Config added in v0.6.0 

type Config struct {
	Version      int           `json:"version"`
	LogsPath     string        `json:"logs_path,omitempty"`
	Defaults     Defaults      `json:"defaults,omitempty"`
	AuthProfiles []AuthProfile `json:"auth_profiles"`
	Hosts        []Host        `json:"hosts"`
}

func LoadConfig added in v0.6.0 

func LoadConfig() (*Config, error)

func LoadConfigWithSSHConfig added in v0.6.0 

func LoadConfigWithSSHConfig() (*Config, error)

func MaskConfig added in v0.6.0 

func MaskConfig(config Config) Config

func (Config) EffectiveHost added in v0.6.0 

func (c Config) EffectiveHost(host Host, overrides HostOverrides) (EffectiveHost, bool, error)

func (Config) FindAuthProfile added in v0.6.0 

func (c Config) FindAuthProfile(name string) (AuthProfile, bool)

func (Config) ResolveConnection added in v0.6.0 

func (c Config) ResolveConnection(host Host) (ResolvedConnection, error)

func (Config) ResolveEffectiveHost added in v0.6.0 

func (c Config) ResolveEffectiveHost(target string, overrides HostOverrides) (EffectiveHost, bool, error)

type Defaults added in v0.6.0 

type Defaults struct {
	User            string `json:"user,omitempty"`
	Port            int    `json:"port,omitempty"`
	ConnectTimeout  string `json:"connect_timeout,omitempty"`
	RunTimeout      string `json:"run_timeout,omitempty"`
	RemoteScriptDir string `json:"remote_script_dir,omitempty"`
	HostKeyCheck    string `json:"host_key_check,omitempty"`
	KnownHostsPath  string `json:"known_hosts_path,omitempty"`
}

type DoctorIssue added in v0.6.0 

type DoctorIssue struct {
	Level   string `json:"level"`
	Item    string `json:"item"`
	Message string `json:"message"`
}

func CheckConfig added in v0.6.0 

func CheckConfig(config Config) []DoctorIssue

type EffectiveHost added in v0.6.0 

type EffectiveHost struct {
	Host
	ConnectTimeout  string
	RunTimeout      string
	RemoteScriptDir string
	HostKeyCheck    string
	KnownHostsPath  string
}

func (EffectiveHost) ToHost added in v0.6.0 

func (h EffectiveHost) ToHost() Host

type Host 

type Host struct {
	Name        string `json:"name"`
	IP          string `json:"ip"`
	AuthRef     string `json:"auth_ref,omitempty"`
	User        string `json:"user"`
	Password    string `json:"password,omitempty"`
	PasswordEnc string `json:"password_enc,omitempty"`
	KeyPath     string `json:"key_path,omitempty"`
	Remark      string `json:"remark,omitempty"`
	Group       string `json:"group,omitempty"`
	Port        int    `json:"port,omitempty"`
	Jump        string `json:"jump,omitempty"`

	ConnectTimeout  string `json:"connect_timeout,omitempty"`
	RunTimeout      string `json:"run_timeout,omitempty"`
	RemoteScriptDir string `json:"remote_script_dir,omitempty"`
	HostKeyCheck    string `json:"host_key_check,omitempty"`
	KnownHostsPath  string `json:"known_hosts_path,omitempty"`
}

func LoadSSHConfigHosts 

func LoadSSHConfigHosts() ([]Host, error)

func MaskHost added in v0.6.0 

func MaskHost(host Host) Host

func ParseSSHConfig 

func ParseSSHConfig(reader io.Reader) ([]Host, error)

func ResolveBatchHosts added in v0.6.0 

func ResolveBatchHosts(source BatchHostSource) ([]Host, error)

func ResolveHostWithSSHConfig added in v0.6.0 

func ResolveHostWithSSHConfig(target string, overrides HostOverrides) (Host, bool, error)

type HostOverrides added in v0.6.0 

type HostOverrides struct {
	User            string
	Password        string
	KeyPath         string
	Port            int
	ConnectTimeout  string
	RunTimeout      string
	RemoteScriptDir string
	HostKeyCheck    string
	KnownHostsPath  string
}

type LoginOptions 

type LoginOptions struct {
	Stdin  *os.File
	Stdout io.Writer
	Stderr io.Writer
	Term   string
}

type RemoteClient added in v0.6.0 

type RemoteClient interface {
	Run(string) ([]byte, error)
	RunContext(context.Context, string) ([]byte, error)
	NewSession() (*ssh.Session, error)
	NewSftp(...sftp.ClientOption) (*sftp.Client, error)
	Close() error
}

type ResolveConnectionOptions added in v0.6.0 

type ResolveConnectionOptions struct {
	Jump string
}

type ResolvedConnection added in v0.6.0 

type ResolvedConnection struct {
	Target Host
	Jump   *Host
}

func ResolveConnectionForHost added in v0.6.0 

func ResolveConnectionForHost(host Host) (ResolvedConnection, error)

func ResolveConnectionWithSSHConfig added in v0.6.0 

func ResolveConnectionWithSSHConfig(target string, opts ResolveConnectionOptions) (ResolvedConnection, bool, error)

type RunLogRecord 

type RunLogRecord struct {
	Target           string
	TaskID           string
	Command          string
	Status           string
	StartedAt        time.Time
	DurationMS       int64
	Output           string
	OutputFile       string
	OutputBytes      int64
	OutputSHA256     string
	OutputInline     bool
	OutputPreview    string
	Error            string
	CWD              string
	Script           string
	RemoteScript     string
	KeepRemoteScript bool
}

type RunOptions 

type RunOptions struct {
	Timeout          time.Duration
	KillAfter        time.Duration
	Env              map[string]string
	CWD              string
	Sudo             bool
	SudoUser         string
	ScriptPath       string
	RemoteScriptDir  string
	RemoteScriptPath string
	KeepRemoteScript bool
}

type Store 

type Store struct {
	LogsPath string `json:"logs_path,omitempty"`
	Hosts    []Host `json:"hosts"`
}

func LoadConfigSettings added in v0.5.0 

func LoadConfigSettings() (Store, error)

func LoadStore 

func LoadStore() (*Store, error)

func LoadStoreWithSSHConfig 

func LoadStoreWithSSHConfig() (*Store, error)

func (Store) Find 

func (s Store) Find(target string) (Host, bool)

func (Store) MatchHosts 

func (s Store) MatchHosts(target string) []Host

func (Store) ResolveHost 

func (s Store) ResolveHost(target string) (Host, bool, error)

func (*Store) Upsert 

func (s *Store) Upsert(host Host) error

type TransferJob 

type TransferJob struct {
	LocalPath  string
	RemotePath string
	RemoteDir  bool
}

type TransferOptions 

type TransferOptions struct {
	SHA256    bool
	RemoveDir bool
}

type TransferResult 

type TransferResult struct {
	Bytes        int64
	Files        int
	Directories  int
	Elapsed      time.Duration
	LocalSHA256  string
	RemoteSHA256 string
	SHA256OK     bool
}

func FetchRemote 

func FetchRemote(host Host, remotePath, localPath string, opts TransferOptions) (result TransferResult, err error)

func UploadRemote 

func UploadRemote(host Host, localPath, remotePath string, opts TransferOptions) (result TransferResult, err error)

func UploadRemoteBatch 

func UploadRemoteBatch(host Host, jobs []TransferJob, opts TransferOptions) (result TransferResult, err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.