service

Documentation

Index

• Constants
• func NodeServiceSandboxedContainerContract(descriptor core.RuntimeDescriptor) core.RuntimeAdapterContract
• func ServiceSandboxedContainerContract(descriptor core.RuntimeDescriptor) core.RuntimeAdapterContract
• type RuntimeAdapterCatalogDocument
  • func (d RuntimeAdapterCatalogDocument) Validate() error
• type RuntimeAdapterCatalogEntry
  • func (e RuntimeAdapterCatalogEntry) Contract(descriptor core.RuntimeDescriptor) core.RuntimeAdapterContract
  • func (e RuntimeAdapterCatalogEntry) Validate() error
• type SandboxRuntimeServiceAdapter
  • func (a SandboxRuntimeServiceAdapter) RunSandboxedService(ctx context.Context, invocation SandboxedServiceRuntimeInvocation) (ServiceRunResult, error)
• type SandboxedServiceInvocationOptions
• type SandboxedServiceRuntime
• type SandboxedServiceRuntimeInvocation
  • func NewSandboxedServiceInvocation(opts SandboxedServiceInvocationOptions) (SandboxedServiceRuntimeInvocation, error)
• type ServiceRunResult

Constants

const (
	ServiceSandboxedContainerProviderName     = "service-sandboxed-container"
	NodeServiceSandboxedContainerProviderName = "node-service-sandboxed-container"
	SandboxedServiceOperationRun              = "run-sandboxed-service"
)

Functions

func NodeServiceSandboxedContainerContract

func NodeServiceSandboxedContainerContract(descriptor core.RuntimeDescriptor) core.RuntimeAdapterContract

func ServiceSandboxedContainerContract

func ServiceSandboxedContainerContract(descriptor core.RuntimeDescriptor) core.RuntimeAdapterContract

Types

type RuntimeAdapterCatalogDocument

type RuntimeAdapterCatalogDocument struct {
	Version                   string                       `json:"version"`
	ProtocolVersion           string                       `json:"protocol_version"`
	Adapters                  []RuntimeAdapterCatalogEntry `json:"adapters"`
	HostOwnedResponsibilities []string                     `json:"host_owned_responsibilities"`
}

func (RuntimeAdapterCatalogDocument) Validate

func (d RuntimeAdapterCatalogDocument) Validate() error

type RuntimeAdapterCatalogEntry

type RuntimeAdapterCatalogEntry struct {
	AdapterID           string                      `json:"adapter_id"`
	Operation           string                      `json:"operation"`
	Kinds               []core.RuntimeAdapterKind   `json:"kinds"`
	WorkloadKinds       []core.WorkloadKind         `json:"workload_kinds"`
	RuntimeProfiles     []core.RuntimeProfile       `json:"runtime_profiles"`
	WorkspacePolicy     core.RuntimeWorkspacePolicy `json:"workspace_policy"`
	ConformanceProfiles []string                    `json:"conformance_profiles"`
}

func (RuntimeAdapterCatalogEntry) Contract

func (e RuntimeAdapterCatalogEntry) Contract(descriptor core.RuntimeDescriptor) core.RuntimeAdapterContract

func (RuntimeAdapterCatalogEntry) Validate

func (e RuntimeAdapterCatalogEntry) Validate() error

type SandboxRuntimeServiceAdapter

type SandboxRuntimeServiceAdapter struct {
	Runtime computecontainer.SandboxRuntime
}

func (SandboxRuntimeServiceAdapter) RunSandboxedService

func (a SandboxRuntimeServiceAdapter) RunSandboxedService(ctx context.Context, invocation SandboxedServiceRuntimeInvocation) (ServiceRunResult, error)

type SandboxedServiceInvocationOptions

type SandboxedServiceInvocationOptions struct {
	TaskID          string
	LeaseID         string
	Image           string
	Command         []string
	RuntimeScope    computecontainer.ContainerRuntimeScope
	Workspace       string
	Network         string
	DataMounts      []computecontainer.SandboxMount
	Timeout         time.Duration
	TimeoutLimitHit string
	Workload        core.WorkloadSpec
	ResolvedEnv     map[string]string
	Limits          core.ResourceLimits
}

type SandboxedServiceRuntime

type SandboxedServiceRuntime interface {
	RunSandboxedService(context.Context, SandboxedServiceRuntimeInvocation) (ServiceRunResult, error)
}

type SandboxedServiceRuntimeInvocation

type SandboxedServiceRuntimeInvocation struct {
	Request         core.RuntimeExecutionRequest
	Image           string
	Command         []string
	RuntimeScope    computecontainer.ContainerRuntimeScope
	Workspace       string
	Network         string
	DataMounts      []computecontainer.SandboxMount
	Timeout         time.Duration
	TimeoutLimitHit string
}

func NewSandboxedServiceInvocation

func NewSandboxedServiceInvocation(opts SandboxedServiceInvocationOptions) (SandboxedServiceRuntimeInvocation, error)

type ServiceRunResult

type ServiceRunResult = core.RuntimeServiceResult