agent

type BuildServer struct {
	apiv1.UnimplementedBuildServiceServer
	Service buildsvc.Service
	Mirror  *MirrorServer
	Logger  logr.Logger

	RequireSandbox bool
	SandboxConfig  string
	SandboxBin     string
	SandboxLogs    bool
}

type Config struct {
	ListenAddr                string
	KubeconfigPath            string
	KubeContext               string
	AuthToken                 string
	HTTPListenAddr            string
	TLSCertFile               string
	TLSKeyFile                string
	TLSClientCAFile           string
	MirrorStore               string
	MirrorMaxSessions         int
	MirrorMaxFramesPerSession uint64
	MirrorMaxBytes            int64
	MirrorPruneInterval       time.Duration
	BuildRequireSandbox       bool
	BuildSandboxConfig        string
	BuildSandboxBin           string
	BuildSandboxLogs          bool
}

type DeployServer struct {
	apiv1.UnimplementedDeployServiceServer
	Logger logr.Logger
	Mirror *MirrorServer
}

type LogServer struct {
	apiv1.UnimplementedLogServiceServer
	Config Config
	Logger logr.Logger
	Mirror *MirrorServer
}

type MirrorServer struct {
	apiv1.UnimplementedMirrorServiceServer
	// contains filtered or unexported fields
}

type MirrorServerOption func(*MirrorServer)

type MirrorSession struct {
	SessionID        string
	CreatedUnixNano  int64
	LastSeenUnixNano int64
	LastSequence     uint64
	Meta             MirrorSessionMeta
	Tags             map[string]string
	Status           MirrorSessionStatus
}

type MirrorSessionMeta struct {
	Command     string
	Args        []string
	Requester   string
	Cluster     string
	KubeContext string
	Namespace   string
	Release     string
	Chart       string
}

type MirrorSessionState int32

type MirrorSessionStatus struct {
	State             MirrorSessionState
	ExitCode          int32
	ErrorMessage      string
	CompletedUnixNano int64
}

type MirrorStore interface {
	Append(frame *apiv1.MirrorFrame) error
	UpsertSessionMeta(ctx context.Context, sessionID string, meta MirrorSessionMeta, tags map[string]string) error
	UpsertSessionStatus(ctx context.Context, sessionID string, st MirrorSessionStatus) error
	DeleteSession(ctx context.Context, sessionID string) (bool, error)
	GetSession(ctx context.Context, sessionID string) (MirrorSession, bool, error)
	ListSessions(ctx context.Context, limit int) ([]MirrorSession, error)
	Replay(ctx context.Context, sessionID string, fromSequence uint64, send func(*apiv1.MirrorFrame) error) (lastSequence uint64, _ error)
	Close() error
}

type MirrorStoreOptions struct {
	MaxSessions         int
	MaxFramesPerSession uint64
	MaxBytes            int64
	PruneInterval       time.Duration
}

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

type StackServer struct {
	apiv1.UnimplementedStackServiceServer
	Mirror *MirrorServer
}