Help us shape the future of Go! Take the 2026 Go Developer Survey

executionclient

package
v0.0.44 Latest Latest
Warning

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

 Go to latest Published: Oct 1, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Overview

Package executionclient implements the private mTLS client and placement adapter for the independently deployed Kubernetes execution provider.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LoadTLSConfig 

func LoadTLSConfig(files TLSFiles) (*tls.Config, error)

LoadTLSConfig loads provider trust and client identity at process startup.

Types

type Client 

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

Client is a bounded client for the private execution-provider gRPC API.

func New 

func New(endpoint string, tlsConfig *tls.Config) (*Client, error)

New constructs a production mTLS execution-provider client. Endpoint is a plain host:port authority; URI schemes and alternate resolvers are rejected.

func (*Client) AbortReference 

func (c *Client) AbortReference(ctx context.Context, req executionenv.ReferenceRequest) error

func (*Client) AcquireRun 

func (c *Client) AcquireRun(ctx context.Context, req executionenv.RunClaimRequest) (executionenv.RunClaim, error)

AcquireRun acquires one environment-wide run claim.

func (*Client) Attach 

func (c *Client) Attach(ctx context.Context, req executionenv.AttachEnvironmentRequest) (executionenv.AttachEnvironmentResponse, error)

Attach obtains a fresh grant for an exact environment reference.

func (*Client) CancelCommand 

func (c *Client) CancelCommand(ctx context.Context, req executionenv.CommandQueryRequest) (executionenv.CommandStatusResponse, error)

CancelCommand cancels a command after the request has been authorized.

func (*Client) CancelReferenceDelete 

func (c *Client) CancelReferenceDelete(ctx context.Context, req executionenv.ReferenceRequest) error

func (*Client) Close 

func (c *Client) Close()

Close releases the provider connection.

func (*Client) CommandStatus 

func (c *Client) CommandStatus(ctx context.Context, req executionenv.CommandQueryRequest) (executionenv.CommandStatusResponse, error)

CommandStatus queries a command after the request has been authorized.

func (*Client) CommitReference 

func (c *Client) CommitReference(ctx context.Context, req executionenv.ReferenceRequest) error

func (*Client) ConfirmReferenceDelete 

func (c *Client) ConfirmReferenceDelete(ctx context.Context, req executionenv.ReferenceRequest) error

func (*Client) DeleteRetiredEnvironment 

func (c *Client) DeleteRetiredEnvironment(ctx context.Context, ref executionenv.EnvironmentRef, owner executionenv.Owner, expectedPVCUID, operationID string) error

DeleteRetiredEnvironment deletes retained storage after retirement proof.

func (*Client) Ensure 

func (c *Client) Ensure(ctx context.Context, binding, profile string, owner executionenv.Owner, operationID string) (executionenv.EnsureEnvironmentResponse, error)

Ensure idempotently allocates or resolves the environment for a binding.

func (*Client) File 

func (c *Client) File(ctx context.Context, req executionenv.FileRequest) (executionenv.FileResponse, error)

File executes one authorized filesystem operation.

func (*Client) FindReferenceIntent 

func (c *Client) FindReferenceIntent(ctx context.Context, owner executionenv.Owner, environment executionenv.EnvironmentRef, binding string) (executionenv.ReferenceIntent, error)

func (*Client) ListAllReferenceIntents 

func (c *Client) ListAllReferenceIntents(ctx context.Context) ([]executionenv.ReferenceIntent, error)

func (*Client) ListReferenceIntents 

func (c *Client) ListReferenceIntents(ctx context.Context, owner executionenv.Owner) ([]executionenv.ReferenceIntent, error)

func (*Client) MigrateEnvironment 

func (c *Client) MigrateEnvironment(ctx context.Context, ref executionenv.EnvironmentRef, owner executionenv.Owner, expectedSchema uint32, podUID, pvcUID, operationID string) error

MigrateEnvironment upgrades one explicitly identified legacy schema.

func (*Client) PrepareReferenceDelete 

func (c *Client) PrepareReferenceDelete(ctx context.Context, req executionenv.ReferenceRequest) error

func (*Client) RecoverEnvironment 

func (c *Client) RecoverEnvironment(ctx context.Context, req executionenv.RetireEnvironmentRequest) error

RecoverEnvironment clears a fence only after the provider verifies exact terminal evidence.

func (*Client) ReleaseReference 

func (c *Client) ReleaseReference(ctx context.Context, req executionenv.ReferenceReleaseRequest) error

ReleaseReference releases one durable binding reference.

func (*Client) ReleaseRun 

func (c *Client) ReleaseRun(ctx context.Context, req executionenv.RunClaimRequest) error

func (*Client) RenewRun 

func (c *Client) RenewRun(ctx context.Context, req executionenv.RunClaimRequest) (executionenv.RunClaim, error)

func (*Client) ReplaceExecutor 

func (c *Client) ReplaceExecutor(ctx context.Context, req executionenv.RetireEnvironmentRequest) error

ReplaceExecutor requests UID-checked administrative executor replacement.

func (*Client) ReserveSuccessor 

func (c *Client) ReserveSuccessor(ctx context.Context, req executionenv.ReferenceRequest) error

func (*Client) RetireEnvironment 

func (c *Client) RetireEnvironment(ctx context.Context, req executionenv.RetireEnvironmentRequest) error

RetireEnvironment requests administrative retirement.

func (*Client) RevokeEnvironment 

func (c *Client) RevokeEnvironment(ctx context.Context, ref executionenv.EnvironmentRef, owner executionenv.Owner, expectedGeneration uint64, operationID string) (uint64, error)

RevokeEnvironment atomically fences grants and replays a matching operation receipt.

func (*Client) StartCommand 

func (c *Client) StartCommand(ctx context.Context, req executionenv.CommandStartRequest) (executionenv.CommandStartResponse, error)

StartCommand executes one foreground command.

func (*Client) ValidateProfile 

func (c *Client) ValidateProfile(ctx context.Context, profile string) (executionenv.ValidateProfileResponse, error)

ValidateProfile validates a provider profile without allocating an environment.

type Provider 

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

Provider adapts the execution service to server placement binding.

func NewProvider 

func NewProvider(client *Client, profile string) (*Provider, error)

NewProvider binds a client to one operator-selected profile.

func (*Provider) AcquireRun 

func (p *Provider) AcquireRun(ctx context.Context, req server.ExecutionRunRequest) (server.ExecutionRunHandle, error)

func (*Provider) Applies 

func (p *Provider) Applies(ref session.EnvironmentRef) bool

func (*Provider) Bind 

func (p *Provider) Bind(ctx context.Context, req server.PlacementBindRequest) (server.PlacementBinding, error)

Bind allocates the environment for the final session binding.

func (*Provider) CancelReferenceIntentDelete 

func (p *Provider) CancelReferenceIntentDelete(ctx context.Context, intent server.ReferenceIntent) error

func (*Provider) CommitReferenceIntent 

func (p *Provider) CommitReferenceIntent(ctx context.Context, intent server.ReferenceIntent) error

func (*Provider) ConfirmReferenceIntentDelete 

func (p *Provider) ConfirmReferenceIntentDelete(ctx context.Context, intent server.ReferenceIntent) error

func (*Provider) ListReferenceIntents 

func (p *Provider) ListReferenceIntents(ctx context.Context, limit int) ([]server.ReferenceIntent, error)

func (*Provider) PrepareReferenceDelete 

func (p *Provider) PrepareReferenceDelete(ctx context.Context, req server.PlacementSuccessorRequest) (server.ReferenceDeleteHandle, error)

func (*Provider) Reattach 

func (p *Provider) Reattach(ctx context.Context, req server.PlacementReattachRequest) (server.PlacementBinding, error)

Reattach exactly resolves a persisted remote environment for its binding.

func (*Provider) ReserveSuccessor 

func (p *Provider) ReserveSuccessor(ctx context.Context, req server.PlacementSuccessorRequest) (server.PlacementBinding, error)

func (*Provider) ValidatePlacement 

func (p *Provider) ValidatePlacement(ctx context.Context) error

ValidatePlacement performs side-effect-free profile preflight.

type TLSFiles 

type TLSFiles struct{ CA, Cert, Key string }

TLSFiles names the runtime-only mTLS material mounted into mecak8s.

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.