agent

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

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
}

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
}