springboot

type AppType string

type AppTypes []AppType

type Artifact struct {
	Group   string `json:"group"`
	Name    string `json:"name"`
	Version string `json:"version"`
}

type AuthType int32

type Combinator[T any] func(a, b T) T

type Comparator[T comparable] func(a, b T) int

type Connect struct {
	Parallel    bool `yaml:"parallel"`
	Parallelism int  `yaml:"parallelism"`
}

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

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

type ConsoleOutput struct {
	Patterns []string `yaml:"patterns"`
	Yamlpath []string `yaml:"yamlpath"`
}

type Credential struct {
	Id             string `json:"Id,omitempty"`
	FriendlyName   string `json:"FriendlyName,omitempty"`
	Username       string `json:"UserName,omitempty"`
	Password       string `json:"Password,omitempty"`
	CredentialType string `json:"CredentialType,omitempty"`
}

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

type CredentialProvider interface {
	GetCredentials() ([]*Credential, error)
}

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

type DiscoveryExecutor interface {
	Discover(ctx context.Context, server ServerConnectionInfo, alternativeConnectionInfos ...ServerConnectionInfo) ([]*SpringBootApp, error)
}

type Env struct {
	Denylist []string `yaml:"denylist"`
}

type JarFile interface {
	GetLocation() string
	GetAppType() AppType
	GetArtifactGroup() (string, error)
	GetArtifactName() (string, error)
	GetArtifactVersion() (string, error)
	GetAppName(process JavaProcess) (string, error)
	GetAppPort(process JavaProcess) (int, error)
	GetChecksum() (string, error)
	GetBuildJdkVersion() (string, error)
	GetSpringBootVersion() (string, error)
	GetDependencies() ([]string, error)
	GetApplicationConfigurations() (map[string]string, error)
	GetLoggingFiles() (map[string]string, error)
	GetCertificates() ([]string, error)
	GetStaticFiles() ([]string, error)
	GetLastModifiedTime() (time.Time, error)
	GetSize() (int64, error)
	GetManifests() map[string]string
	GetMavenProject() *mvnparser.MavenProject
}

type JarFileWalker func(name string, f *zip.File, j *jarFile) error

type JavaProcess interface {
	GetProcessId() int
	GetUid() int
	GetRuntimeJdkVersion() (string, error)
	LocateJarFile() (string, error)
	GetJavaCmd() (string, error)
	GetJvmOptions() ([]string, error)
	GetEnvironments() ([]string, error)
	GetJvmMemory() (int64, error)
	GetPorts() ([]int, error)
	Executor() ServerDiscovery
}

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

type Logging struct {
	ConsoleOutput ConsoleOutput `yaml:"console_output"`
	FilePatterns  []string      `yaml:"file_patterns"`
}

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

type MonadConstraints interface {
	*SpringBootApp | *Runtime | *Artifact
}

type Monadic[T MonadConstraints] struct {
	// contains filtered or unexported fields
}

type Pattern struct {
	Logging Logging  `yaml:"logging"`
	Cert    []string `yaml:"cert"`
	Static  Static   `yaml:"static"`
	App     []string `yaml:"app"`
}

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

type Predicate func(t any) bool

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

type Runtime struct {
	Server            string   `json:"server"`
	Uid               int      `json:"uid"`
	Pid               int      `json:"pid"`
	RuntimeJdkVersion string   `json:"runtimeJdkVersion"`
	AppPort           int      `json:"appPort"`
	JavaCmd           string   `json:"javaCmd"`
	Environments      []string `json:"environments"`
	JvmOptions        []string `json:"jvmOptions"`
	JvmMemory         int64    `json:"jvmMemory"`
	OsName            string   `json:"osName"`
	OsVersion         string   `json:"osVersion"`
	BindingPorts      []int    `json:"bindingPorts"`
}

type Server struct {
	Connect Connect `yaml:"connect"`
}

type ServerConnectionInfo struct {
	Server string
	Port   int
}

type ServerConnector interface {
	FQDN() string
	Connect(username, password string) error
	Close() error
	Read(remoteLocation string) (io.ReaderAt, os.FileInfo, error)
	RunCmd(cmd string) (string, error)
	Username() string
}

type ServerConnectorFactory interface {
	Create(ctx context.Context, host string, port int) ServerConnector
}

type ServerDiscovery interface {
	Prepare() (*Credential, error)
	Server() ServerConnector
	ProcessScan() ([]JavaProcess, error)
	GetTotalMemory() (int64, error)
	GetOsName() (string, error)
	GetOsVersion() (string, error)
	ReadJarFile(location string, walkers ...JarFileWalker) (JarFile, error)
	Finish() error
}

type SpringBootApp struct {
	AppName                   string            `json:"appName"`
	AppType                   AppType           `json:"appType"`
	ApplicationConfigurations map[string]string `json:"applicationConfigurations"`
	Artifact                  *Artifact         `json:"artifact"`
	BuildJdkVersion           string            `json:"buildJdkVersion"`
	Checksum                  string            `json:"checksum"`
	Certificates              []string          `json:"certificates"`
	Dependencies              []string          `json:"dependencies"`
	JarFileLocation           string            `json:"jarFileLocation"`
	JarSize                   int64             `json:"jarSize"`
	LoggingConfigurations     map[string]string `json:"loggingConfigurations"`
	LastModifiedTime          time.Time         `json:"lastModifiedTime"`
	LastUpdatedTime           time.Time         `json:"lastUpdatedTime"`
	Runtime                   *Runtime          `json:"runtime"`
	SpringBootVersion         string            `json:"springBootVersion"`
	StaticContentLocations    []string          `json:"staticContentLocations"`
}

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

type SshOption func(s *linuxServer)

type Static struct {
	Folder    []string `yaml:"folder"`
	Extension []string `yaml:"extension"`
}

type StepFunc func(process JavaProcess, jarFile JarFile) *Monad

type Stream interface {
	ForEach(f interface{}) error
	Peek(f interface{}) Stream
	Map(f interface{}) Stream
	FlatMap(f interface{}) Stream
	Distinct() Stream
	Filter(f Predicate) Stream
	Join(sep string) (string, error)
	Retry(policy RetryPolicy) Stream
	Take(n int) Stream
	First() (any, error)
	Sorted(less interface{}) Stream
	Reduce(seed any, c Combinator[any]) (any, error)
	Parallel(parallelism int) Stream
	GroupBy(keyFunc func(t any) string, combinator Combinator[any]) (map[string]any, error)
	// contains filtered or unexported methods
}

type YamlConfig struct {
	Pattern Pattern `yaml:"pattern"`
	Env     Env     `yaml:"env"`
	Server  Server  `yaml:"server"`
}