Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

agent

package

Go to main page

Versions in this module

v1

v1.0.9

May 24, 2026

v1.0.8

May 11, 2026

v1.0.7

May 11, 2026

Changes in this version

type BuildServer

+ RequireSandbox bool

+ SandboxBin string

+ SandboxConfig string

+ SandboxLogs bool

type Config

+ BuildRequireSandbox bool

+ BuildSandboxBin string

+ BuildSandboxConfig string

+ BuildSandboxLogs bool

+ type StackServer struct

+ Mirror *MirrorServer

+ func (s *StackServer) Apply(req *apiv1.StackRunRequest, stream apiv1.StackService_ApplyServer) error

+ func (s *StackServer) Delete(req *apiv1.StackRunRequest, stream apiv1.StackService_DeleteServer) error

+ func (s *StackServer) Plan(ctx context.Context, req *apiv1.StackPlanRequest) (*apiv1.StackPlanResult, error)

+ func (s *StackServer) Status(ctx context.Context, req *apiv1.StackStatusRequest) (*apiv1.StackStatusResult, error)

v1.0.6

May 6, 2026

Changes in this version

+ type BuildServer struct

+ Logger logr.Logger

+ Mirror *MirrorServer

+ Service buildsvc.Service

+ func (s *BuildServer) RunBuild(req *apiv1.RunBuildRequest, stream apiv1.BuildService_RunBuildServer) error

+ type Config struct

+ AuthToken string

+ HTTPListenAddr string

+ KubeContext string

+ KubeconfigPath string

+ ListenAddr string

+ MirrorMaxBytes int64

+ MirrorMaxFramesPerSession uint64

+ MirrorMaxSessions int

+ MirrorPruneInterval time.Duration

+ MirrorStore string

+ TLSCertFile string

+ TLSClientCAFile string

+ TLSKeyFile string

+ type DeployServer struct

+ Logger logr.Logger

+ Mirror *MirrorServer

+ func (s *DeployServer) Apply(req *apiv1.DeployApplyRequest, stream apiv1.DeployService_ApplyServer) (retErr error)

+ func (s *DeployServer) Destroy(req *apiv1.DeployDestroyRequest, stream apiv1.DeployService_DestroyServer) (retErr error)

+ type LogServer struct

+ Config Config

+ Logger logr.Logger

+ Mirror *MirrorServer

+ func (s *LogServer) StreamLogs(req *apiv1.LogRequest, stream apiv1.LogService_StreamLogsServer) (retErr error)

+ type MirrorServer struct

+ func NewMirrorServer(opts ...MirrorServerOption) *MirrorServer

+ func (s *MirrorServer) Close() error

+ func (s *MirrorServer) DeleteSession(ctx context.Context, req *apiv1.MirrorDeleteSessionRequest) (*apiv1.MirrorDeleteSessionResponse, error)

+ func (s *MirrorServer) Export(req *apiv1.MirrorExportRequest, stream apiv1.MirrorService_ExportServer) error

+ func (s *MirrorServer) GetSession(ctx context.Context, req *apiv1.MirrorGetSessionRequest) (*apiv1.MirrorSession, error)

+ func (s *MirrorServer) ListSessions(ctx context.Context, req *apiv1.MirrorListSessionsRequest) (*apiv1.MirrorListSessionsResponse, error)

+ func (s *MirrorServer) Publish(stream apiv1.MirrorService_PublishServer) error

+ func (s *MirrorServer) SetSessionMeta(ctx context.Context, req *apiv1.MirrorSetSessionMetaRequest) (*apiv1.MirrorSession, error)

+ func (s *MirrorServer) SetSessionStatus(ctx context.Context, req *apiv1.MirrorSetSessionStatusRequest) (*apiv1.MirrorSession, error)

+ func (s *MirrorServer) Subscribe(req *apiv1.MirrorSubscribeRequest, stream apiv1.MirrorService_SubscribeServer) error

+ func (s *MirrorServer) UpsertSessionMeta(ctx context.Context, sessionID string, meta MirrorSessionMeta, ...) MirrorSession

+ func (s *MirrorServer) UpsertSessionStatus(ctx context.Context, sessionID string, st MirrorSessionStatus) MirrorSession

+ type MirrorServerOption func(*MirrorServer)

+ func WithMirrorBuffer(n int) MirrorServerOption

+ func WithMirrorStore(store MirrorStore) MirrorServerOption

+ type MirrorSession struct

+ CreatedUnixNano int64

+ LastSeenUnixNano int64

+ LastSequence uint64

+ Meta MirrorSessionMeta

+ SessionID string

+ Status MirrorSessionStatus

+ Tags map[string]string

+ type MirrorSessionMeta struct

+ Args []string

+ Chart string

+ Cluster string

+ Command string

+ KubeContext string

+ Namespace string

+ Release string

+ Requester string

+ type MirrorSessionState int32

+ const MirrorSessionStateDone

+ const MirrorSessionStateError

+ const MirrorSessionStateRunning

+ const MirrorSessionStateUnspecified

+ type MirrorSessionStatus struct

+ CompletedUnixNano int64

+ ErrorMessage string

+ ExitCode int32

+ State MirrorSessionState

+ type MirrorStore interface

+ Append func(frame *apiv1.MirrorFrame) error

+ Close func() error

+ DeleteSession func(ctx context.Context, sessionID string) (bool, error)

+ GetSession func(ctx context.Context, sessionID string) (MirrorSession, bool, error)

+ ListSessions func(ctx context.Context, limit int) ([]MirrorSession, error)

+ Replay func(ctx context.Context, sessionID string, fromSequence uint64, ...) (lastSequence uint64, _ error)

+ UpsertSessionMeta func(ctx context.Context, sessionID string, meta MirrorSessionMeta, ...) error

+ UpsertSessionStatus func(ctx context.Context, sessionID string, st MirrorSessionStatus) error

+ func OpenMirrorStore(path string, opts MirrorStoreOptions) (MirrorStore, error)

+ type MirrorStoreOptions struct

+ MaxBytes int64

+ MaxFramesPerSession uint64

+ MaxSessions int

+ PruneInterval time.Duration

+ type Server struct

+ func New(cfg Config, svc buildsvc.Service) (*Server, error)

+ func (s *Server) Run(ctx context.Context) error

+ func (s *Server) Serve(ctx context.Context, ln net.Listener) error