executionv1

package
v0.2.31 Latest Latest
Warning

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

Go to latest
Published: Jul 23, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ExecutionExporter_Export_FullMethodName = "/codefly.execution.v1.ExecutionExporter/Export"
)

Variables

View Source
var (
	ExecutionStage_name = map[int32]string{
		0: "EXECUTION_STAGE_UNSPECIFIED",
		1: "EXECUTION_STAGE_ADMITTED",
		2: "EXECUTION_STAGE_STARTED",
		3: "EXECUTION_STAGE_SUCCEEDED",
		4: "EXECUTION_STAGE_FAILED",
		5: "EXECUTION_STAGE_COMPENSATED",
		6: "EXECUTION_STAGE_UNCERTAIN",
	}
	ExecutionStage_value = map[string]int32{
		"EXECUTION_STAGE_UNSPECIFIED": 0,
		"EXECUTION_STAGE_ADMITTED":    1,
		"EXECUTION_STAGE_STARTED":     2,
		"EXECUTION_STAGE_SUCCEEDED":   3,
		"EXECUTION_STAGE_FAILED":      4,
		"EXECUTION_STAGE_COMPENSATED": 5,
		"EXECUTION_STAGE_UNCERTAIN":   6,
	}
)

Enum value maps for ExecutionStage.

View Source
var (
	ExecutionAssurance_name = map[int32]string{
		0: "EXECUTION_ASSURANCE_UNSPECIFIED",
		1: "EXECUTION_ASSURANCE_GATEWAY_EXECUTED",
		2: "EXECUTION_ASSURANCE_PLUGIN_EXECUTED",
		3: "EXECUTION_ASSURANCE_COORDINATOR_PERMITTED",
		4: "EXECUTION_ASSURANCE_OBSERVED_ONLY",
	}
	ExecutionAssurance_value = map[string]int32{
		"EXECUTION_ASSURANCE_UNSPECIFIED":           0,
		"EXECUTION_ASSURANCE_GATEWAY_EXECUTED":      1,
		"EXECUTION_ASSURANCE_PLUGIN_EXECUTED":       2,
		"EXECUTION_ASSURANCE_COORDINATOR_PERMITTED": 3,
		"EXECUTION_ASSURANCE_OBSERVED_ONLY":         4,
	}
)

Enum value maps for ExecutionAssurance.

View Source
var ExecutionExporter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "codefly.execution.v1.ExecutionExporter",
	HandlerType: (*ExecutionExporterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Export",
			Handler:    _ExecutionExporter_Export_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "codefly/execution/v1/execution.proto",
}

ExecutionExporter_ServiceDesc is the grpc.ServiceDesc for ExecutionExporter service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_codefly_execution_v1_execution_proto protoreflect.FileDescriptor

Functions

func RegisterExecutionExporterServer

func RegisterExecutionExporterServer(s grpc.ServiceRegistrar, srv ExecutionExporterServer)

Types

type ExecutionAssurance

type ExecutionAssurance int32

ExecutionAssurance states which boundary directly observed the effect.

const (
	// EXECUTION_ASSURANCE_UNSPECIFIED is invalid for a persisted receipt.
	ExecutionAssurance_EXECUTION_ASSURANCE_UNSPECIFIED ExecutionAssurance = 0
	// EXECUTION_ASSURANCE_GATEWAY_EXECUTED means the Codefly Gateway performed the effect.
	ExecutionAssurance_EXECUTION_ASSURANCE_GATEWAY_EXECUTED ExecutionAssurance = 1
	// EXECUTION_ASSURANCE_PLUGIN_EXECUTED means a Codefly plugin returned the typed effect result.
	ExecutionAssurance_EXECUTION_ASSURANCE_PLUGIN_EXECUTED ExecutionAssurance = 2
	// EXECUTION_ASSURANCE_COORDINATOR_PERMITTED proves admission, not execution by itself.
	ExecutionAssurance_EXECUTION_ASSURANCE_COORDINATOR_PERMITTED ExecutionAssurance = 3
	// EXECUTION_ASSURANCE_OBSERVED_ONLY is observation without executor proof.
	ExecutionAssurance_EXECUTION_ASSURANCE_OBSERVED_ONLY ExecutionAssurance = 4
)

func (ExecutionAssurance) Descriptor

func (ExecutionAssurance) Enum

func (ExecutionAssurance) EnumDescriptor deprecated

func (ExecutionAssurance) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecutionAssurance.Descriptor instead.

func (ExecutionAssurance) Number

func (ExecutionAssurance) String

func (x ExecutionAssurance) String() string

func (ExecutionAssurance) Type

type ExecutionAttestationV1

type ExecutionAttestationV1 struct {

	// receipt is the immutable signed payload.
	Receipt *ExecutionReceiptV1 `protobuf:"bytes,1,opt,name=receipt,proto3" json:"receipt,omitempty"`
	// signer_id identifies one registered Codefly Gateway installation.
	SignerId string `protobuf:"bytes,2,opt,name=signer_id,json=signerId,proto3" json:"signer_id,omitempty"`
	// key_id selects a registered Gateway verification key during rotation.
	KeyId string `protobuf:"bytes,3,opt,name=key_id,json=keyId,proto3" json:"key_id,omitempty"`
	// algorithm is fixed to "Ed25519".
	Algorithm string `protobuf:"bytes,4,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	// signature is exactly one Ed25519 signature over the receipt.
	Signature []byte `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

ExecutionAttestationV1 is a Gateway-signed receipt. The signature covers the deterministic protobuf encoding of receipt after payload_sha256 is populated.

func (*ExecutionAttestationV1) Descriptor deprecated

func (*ExecutionAttestationV1) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionAttestationV1.ProtoReflect.Descriptor instead.

func (*ExecutionAttestationV1) GetAlgorithm

func (x *ExecutionAttestationV1) GetAlgorithm() string

func (*ExecutionAttestationV1) GetKeyId

func (x *ExecutionAttestationV1) GetKeyId() string

func (*ExecutionAttestationV1) GetReceipt

func (x *ExecutionAttestationV1) GetReceipt() *ExecutionReceiptV1

func (*ExecutionAttestationV1) GetSignature

func (x *ExecutionAttestationV1) GetSignature() []byte

func (*ExecutionAttestationV1) GetSignerId

func (x *ExecutionAttestationV1) GetSignerId() string

func (*ExecutionAttestationV1) ProtoMessage

func (*ExecutionAttestationV1) ProtoMessage()

func (*ExecutionAttestationV1) ProtoReflect

func (x *ExecutionAttestationV1) ProtoReflect() protoreflect.Message

func (*ExecutionAttestationV1) Reset

func (x *ExecutionAttestationV1) Reset()

func (*ExecutionAttestationV1) String

func (x *ExecutionAttestationV1) String() string

type ExecutionExporterClient

type ExecutionExporterClient interface {
	// Export durably accepts one idempotent signed receipt.
	Export(ctx context.Context, in *ExportExecutionRequest, opts ...grpc.CallOption) (*ExportExecutionResponse, error)
}

ExecutionExporterClient is the client API for ExecutionExporter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

ExecutionExporter is the product-neutral Codefly plugin API. Installing or removing an exporter changes only receipt delivery, never execution behavior.

type ExecutionExporterServer

type ExecutionExporterServer interface {
	// Export durably accepts one idempotent signed receipt.
	Export(context.Context, *ExportExecutionRequest) (*ExportExecutionResponse, error)
	// contains filtered or unexported methods
}

ExecutionExporterServer is the server API for ExecutionExporter service. All implementations must embed UnimplementedExecutionExporterServer for forward compatibility.

ExecutionExporter is the product-neutral Codefly plugin API. Installing or removing an exporter changes only receipt delivery, never execution behavior.

type ExecutionProducerV1

type ExecutionProducerV1 struct {

	// id is a stable namespaced producer ID such as "codefly.execution".
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// component identifies the actual Gateway or plugin component.
	Component string `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	// release is the immutable component release.
	Release string `protobuf:"bytes,3,opt,name=release,proto3" json:"release,omitempty"`
	// contains filtered or unexported fields
}

ExecutionProducerV1 identifies the neutral producer and its release.

func (*ExecutionProducerV1) Descriptor deprecated

func (*ExecutionProducerV1) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionProducerV1.ProtoReflect.Descriptor instead.

func (*ExecutionProducerV1) GetComponent

func (x *ExecutionProducerV1) GetComponent() string

func (*ExecutionProducerV1) GetId

func (x *ExecutionProducerV1) GetId() string

func (*ExecutionProducerV1) GetRelease

func (x *ExecutionProducerV1) GetRelease() string

func (*ExecutionProducerV1) ProtoMessage

func (*ExecutionProducerV1) ProtoMessage()

func (*ExecutionProducerV1) ProtoReflect

func (x *ExecutionProducerV1) ProtoReflect() protoreflect.Message

func (*ExecutionProducerV1) Reset

func (x *ExecutionProducerV1) Reset()

func (*ExecutionProducerV1) String

func (x *ExecutionProducerV1) String() string

type ExecutionReceiptV1

type ExecutionReceiptV1 struct {

	// schema is fixed to "codefly.execution-receipt/v1".
	Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// receipt_id uniquely identifies this immutable stage receipt.
	ReceiptId string `protobuf:"bytes,2,opt,name=receipt_id,json=receiptId,proto3" json:"receipt_id,omitempty"`
	// operation_id is stable across transport retries of one logical operation.
	OperationId string `protobuf:"bytes,3,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// attempt_id changes only when the effect is intentionally re-executed.
	AttemptId string `protobuf:"bytes,4,opt,name=attempt_id,json=attemptId,proto3" json:"attempt_id,omitempty"`
	// stage is one admitted/started/terminal lifecycle fact.
	Stage ExecutionStage `protobuf:"varint,5,opt,name=stage,proto3,enum=codefly.execution.v1.ExecutionStage" json:"stage,omitempty"`
	// operation_kind is an extensible namespaced kind such as "code.apply-edit".
	OperationKind string `protobuf:"bytes,6,opt,name=operation_kind,json=operationKind,proto3" json:"operation_kind,omitempty"`
	// producer identifies the generic component and immutable release.
	Producer *ExecutionProducerV1 `protobuf:"bytes,7,opt,name=producer,proto3" json:"producer,omitempty"`
	// assurance states which boundary directly observed the effect.
	Assurance ExecutionAssurance `protobuf:"varint,8,opt,name=assurance,proto3,enum=codefly.execution.v1.ExecutionAssurance" json:"assurance,omitempty"`
	// work_context is a verified claims snapshot, not the signed bearer token.
	WorkContext *v0.WorkContextV1 `protobuf:"bytes,9,opt,name=work_context,json=workContext,proto3" json:"work_context,omitempty"`
	// work_context_sha256 binds the snapshot to the admitted signed token.
	WorkContextSha256 string `protobuf:"bytes,10,opt,name=work_context_sha256,json=workContextSha256,proto3" json:"work_context_sha256,omitempty"`
	// target identifies the Codefly workspace/service boundary.
	Target *ExecutionTargetV1 `protobuf:"bytes,11,opt,name=target,proto3" json:"target,omitempty"`
	// started_at is shared by every receipt for the same attempt.
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// completed_at is set only on terminal receipts.
	CompletedAt *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=completed_at,json=completedAt,proto3,oneof" json:"completed_at,omitempty"`
	// resources are bounded safe references and digests affected by the operation.
	Resources []*ExecutionResourceV1 `protobuf:"bytes,14,rep,name=resources,proto3" json:"resources,omitempty"`
	// result contains bounded generic status and numeric result facts.
	Result *ExecutionResultV1 `protobuf:"bytes,15,opt,name=result,proto3" json:"result,omitempty"`
	// extension_schema identifies optional plugin-owned canonical extension JSON.
	ExtensionSchema *string `protobuf:"bytes,16,opt,name=extension_schema,json=extensionSchema,proto3,oneof" json:"extension_schema,omitempty"`
	// extension_json is canonical JSON validated by extension_schema and capped at 16 KiB.
	ExtensionJson []byte `protobuf:"bytes,17,opt,name=extension_json,json=extensionJson,proto3,oneof" json:"extension_json,omitempty"`
	// payload_sha256 is the digest of deterministic receipt bytes with this field empty.
	PayloadSha256 string `protobuf:"bytes,18,opt,name=payload_sha256,json=payloadSha256,proto3" json:"payload_sha256,omitempty"`
	// contains filtered or unexported fields
}

ExecutionReceiptV1 is the product-neutral immutable execution fact exported by Codefly. It contains bounded metadata, never source bytes, patches, unbounded process output, bearer tokens, or a product-specific evidence envelope.

func (*ExecutionReceiptV1) Descriptor deprecated

func (*ExecutionReceiptV1) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionReceiptV1.ProtoReflect.Descriptor instead.

func (*ExecutionReceiptV1) GetAssurance

func (x *ExecutionReceiptV1) GetAssurance() ExecutionAssurance

func (*ExecutionReceiptV1) GetAttemptId

func (x *ExecutionReceiptV1) GetAttemptId() string

func (*ExecutionReceiptV1) GetCompletedAt

func (x *ExecutionReceiptV1) GetCompletedAt() *timestamppb.Timestamp

func (*ExecutionReceiptV1) GetExtensionJson

func (x *ExecutionReceiptV1) GetExtensionJson() []byte

func (*ExecutionReceiptV1) GetExtensionSchema

func (x *ExecutionReceiptV1) GetExtensionSchema() string

func (*ExecutionReceiptV1) GetOperationId

func (x *ExecutionReceiptV1) GetOperationId() string

func (*ExecutionReceiptV1) GetOperationKind

func (x *ExecutionReceiptV1) GetOperationKind() string

func (*ExecutionReceiptV1) GetPayloadSha256

func (x *ExecutionReceiptV1) GetPayloadSha256() string

func (*ExecutionReceiptV1) GetProducer

func (x *ExecutionReceiptV1) GetProducer() *ExecutionProducerV1

func (*ExecutionReceiptV1) GetReceiptId

func (x *ExecutionReceiptV1) GetReceiptId() string

func (*ExecutionReceiptV1) GetResources

func (x *ExecutionReceiptV1) GetResources() []*ExecutionResourceV1

func (*ExecutionReceiptV1) GetResult

func (x *ExecutionReceiptV1) GetResult() *ExecutionResultV1

func (*ExecutionReceiptV1) GetSchema

func (x *ExecutionReceiptV1) GetSchema() string

func (*ExecutionReceiptV1) GetStage

func (x *ExecutionReceiptV1) GetStage() ExecutionStage

func (*ExecutionReceiptV1) GetStartedAt

func (x *ExecutionReceiptV1) GetStartedAt() *timestamppb.Timestamp

func (*ExecutionReceiptV1) GetTarget

func (x *ExecutionReceiptV1) GetTarget() *ExecutionTargetV1

func (*ExecutionReceiptV1) GetWorkContext

func (x *ExecutionReceiptV1) GetWorkContext() *v0.WorkContextV1

func (*ExecutionReceiptV1) GetWorkContextSha256

func (x *ExecutionReceiptV1) GetWorkContextSha256() string

func (*ExecutionReceiptV1) ProtoMessage

func (*ExecutionReceiptV1) ProtoMessage()

func (*ExecutionReceiptV1) ProtoReflect

func (x *ExecutionReceiptV1) ProtoReflect() protoreflect.Message

func (*ExecutionReceiptV1) Reset

func (x *ExecutionReceiptV1) Reset()

func (*ExecutionReceiptV1) String

func (x *ExecutionReceiptV1) String() string

type ExecutionResourceV1

type ExecutionResourceV1 struct {

	// kind is a namespaced resource kind such as "workspace.path".
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// reference is a bounded canonical reference; policy may choose a digest instead of a path.
	Reference string `protobuf:"bytes,2,opt,name=reference,proto3" json:"reference,omitempty"`
	// previous_reference is used by moves/renames.
	PreviousReference *string `protobuf:"bytes,3,opt,name=previous_reference,json=previousReference,proto3,oneof" json:"previous_reference,omitempty"`
	// before_sha256 is the previous content digest when known.
	BeforeSha256 *string `protobuf:"bytes,4,opt,name=before_sha256,json=beforeSha256,proto3,oneof" json:"before_sha256,omitempty"`
	// after_sha256 is the resulting content digest when known.
	AfterSha256 *string `protobuf:"bytes,5,opt,name=after_sha256,json=afterSha256,proto3,oneof" json:"after_sha256,omitempty"`
	// changed says whether the operation changed this resource.
	Changed bool `protobuf:"varint,6,opt,name=changed,proto3" json:"changed,omitempty"`
	// contains filtered or unexported fields
}

ExecutionResourceV1 is a safe resource reference and immutable digest set.

func (*ExecutionResourceV1) Descriptor deprecated

func (*ExecutionResourceV1) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionResourceV1.ProtoReflect.Descriptor instead.

func (*ExecutionResourceV1) GetAfterSha256

func (x *ExecutionResourceV1) GetAfterSha256() string

func (*ExecutionResourceV1) GetBeforeSha256

func (x *ExecutionResourceV1) GetBeforeSha256() string

func (*ExecutionResourceV1) GetChanged

func (x *ExecutionResourceV1) GetChanged() bool

func (*ExecutionResourceV1) GetKind

func (x *ExecutionResourceV1) GetKind() string

func (*ExecutionResourceV1) GetPreviousReference

func (x *ExecutionResourceV1) GetPreviousReference() string

func (*ExecutionResourceV1) GetReference

func (x *ExecutionResourceV1) GetReference() string

func (*ExecutionResourceV1) ProtoMessage

func (*ExecutionResourceV1) ProtoMessage()

func (*ExecutionResourceV1) ProtoReflect

func (x *ExecutionResourceV1) ProtoReflect() protoreflect.Message

func (*ExecutionResourceV1) Reset

func (x *ExecutionResourceV1) Reset()

func (*ExecutionResourceV1) String

func (x *ExecutionResourceV1) String() string

type ExecutionResultV1

type ExecutionResultV1 struct {

	// status is a bounded machine status owned by the operation producer.
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// error_code is a bounded stable error class and never an unbounded message.
	ErrorCode *string `protobuf:"bytes,2,opt,name=error_code,json=errorCode,proto3,oneof" json:"error_code,omitempty"`
	// exit_code is present for command-like operations.
	ExitCode *int32 `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3,oneof" json:"exit_code,omitempty"`
	// duration_ms is the measured operation latency.
	DurationMs uint64 `protobuf:"varint,4,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	// passed_count is a bounded successful-item/test count.
	PassedCount uint64 `protobuf:"varint,5,opt,name=passed_count,json=passedCount,proto3" json:"passed_count,omitempty"`
	// failed_count is a bounded failed-item/test count.
	FailedCount uint64 `protobuf:"varint,6,opt,name=failed_count,json=failedCount,proto3" json:"failed_count,omitempty"`
	// skipped_count is a bounded skipped-item/test count.
	SkippedCount uint64 `protobuf:"varint,7,opt,name=skipped_count,json=skippedCount,proto3" json:"skipped_count,omitempty"`
	// contains filtered or unexported fields
}

ExecutionResultV1 contains bounded generic outcome facts. Rich operation-specific metadata belongs in a versioned extension schema.

func (*ExecutionResultV1) Descriptor deprecated

func (*ExecutionResultV1) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionResultV1.ProtoReflect.Descriptor instead.

func (*ExecutionResultV1) GetDurationMs

func (x *ExecutionResultV1) GetDurationMs() uint64

func (*ExecutionResultV1) GetErrorCode

func (x *ExecutionResultV1) GetErrorCode() string

func (*ExecutionResultV1) GetExitCode

func (x *ExecutionResultV1) GetExitCode() int32

func (*ExecutionResultV1) GetFailedCount

func (x *ExecutionResultV1) GetFailedCount() uint64

func (*ExecutionResultV1) GetPassedCount

func (x *ExecutionResultV1) GetPassedCount() uint64

func (*ExecutionResultV1) GetSkippedCount

func (x *ExecutionResultV1) GetSkippedCount() uint64

func (*ExecutionResultV1) GetStatus

func (x *ExecutionResultV1) GetStatus() string

func (*ExecutionResultV1) ProtoMessage

func (*ExecutionResultV1) ProtoMessage()

func (*ExecutionResultV1) ProtoReflect

func (x *ExecutionResultV1) ProtoReflect() protoreflect.Message

func (*ExecutionResultV1) Reset

func (x *ExecutionResultV1) Reset()

func (*ExecutionResultV1) String

func (x *ExecutionResultV1) String() string

type ExecutionStage

type ExecutionStage int32

ExecutionStage is one causally ordered fact in an execution attempt.

const (
	// EXECUTION_STAGE_UNSPECIFIED is invalid for a persisted receipt.
	ExecutionStage_EXECUTION_STAGE_UNSPECIFIED ExecutionStage = 0
	// EXECUTION_STAGE_ADMITTED records successful policy admission.
	ExecutionStage_EXECUTION_STAGE_ADMITTED ExecutionStage = 1
	// EXECUTION_STAGE_STARTED is durably recorded before the effect begins.
	ExecutionStage_EXECUTION_STAGE_STARTED ExecutionStage = 2
	// EXECUTION_STAGE_SUCCEEDED records a completed successful effect.
	ExecutionStage_EXECUTION_STAGE_SUCCEEDED ExecutionStage = 3
	// EXECUTION_STAGE_FAILED records a completed failed effect.
	ExecutionStage_EXECUTION_STAGE_FAILED ExecutionStage = 4
	// EXECUTION_STAGE_COMPENSATED records a completed compensating effect.
	ExecutionStage_EXECUTION_STAGE_COMPENSATED ExecutionStage = 5
	// EXECUTION_STAGE_UNCERTAIN records an attempt whose terminal state cannot be proven.
	ExecutionStage_EXECUTION_STAGE_UNCERTAIN ExecutionStage = 6
)

func (ExecutionStage) Descriptor

func (ExecutionStage) Enum

func (x ExecutionStage) Enum() *ExecutionStage

func (ExecutionStage) EnumDescriptor deprecated

func (ExecutionStage) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecutionStage.Descriptor instead.

func (ExecutionStage) Number

func (ExecutionStage) String

func (x ExecutionStage) String() string

func (ExecutionStage) Type

type ExecutionTargetV1

type ExecutionTargetV1 struct {

	// workspace_id is the Codefly workspace identity.
	WorkspaceId string `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	// service is the Codefly service identity.
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// project_id optionally identifies the product/repository project.
	ProjectId *string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3,oneof" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

ExecutionTargetV1 identifies where Codefly admitted the execution.

func (*ExecutionTargetV1) Descriptor deprecated

func (*ExecutionTargetV1) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionTargetV1.ProtoReflect.Descriptor instead.

func (*ExecutionTargetV1) GetProjectId

func (x *ExecutionTargetV1) GetProjectId() string

func (*ExecutionTargetV1) GetService

func (x *ExecutionTargetV1) GetService() string

func (*ExecutionTargetV1) GetWorkspaceId

func (x *ExecutionTargetV1) GetWorkspaceId() string

func (*ExecutionTargetV1) ProtoMessage

func (*ExecutionTargetV1) ProtoMessage()

func (*ExecutionTargetV1) ProtoReflect

func (x *ExecutionTargetV1) ProtoReflect() protoreflect.Message

func (*ExecutionTargetV1) Reset

func (x *ExecutionTargetV1) Reset()

func (*ExecutionTargetV1) String

func (x *ExecutionTargetV1) String() string

type ExportExecutionRequest

type ExportExecutionRequest struct {

	// attestation is the Gateway-signed execution receipt.
	Attestation *ExecutionAttestationV1 `protobuf:"bytes,1,opt,name=attestation,proto3" json:"attestation,omitempty"`
	// contains filtered or unexported fields
}

ExportExecutionRequest delivers one durable attestation to an exporter plugin.

func (*ExportExecutionRequest) Descriptor deprecated

func (*ExportExecutionRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExportExecutionRequest.ProtoReflect.Descriptor instead.

func (*ExportExecutionRequest) GetAttestation

func (x *ExportExecutionRequest) GetAttestation() *ExecutionAttestationV1

func (*ExportExecutionRequest) ProtoMessage

func (*ExportExecutionRequest) ProtoMessage()

func (*ExportExecutionRequest) ProtoReflect

func (x *ExportExecutionRequest) ProtoReflect() protoreflect.Message

func (*ExportExecutionRequest) Reset

func (x *ExportExecutionRequest) Reset()

func (*ExportExecutionRequest) String

func (x *ExportExecutionRequest) String() string

type ExportExecutionResponse

type ExportExecutionResponse struct {

	// receipt_id repeats the accepted receipt identity.
	ReceiptId string `protobuf:"bytes,1,opt,name=receipt_id,json=receiptId,proto3" json:"receipt_id,omitempty"`
	// duplicate is true when the exporter had already accepted identical bytes.
	Duplicate bool `protobuf:"varint,2,opt,name=duplicate,proto3" json:"duplicate,omitempty"`
	// contains filtered or unexported fields
}

ExportExecutionResponse acknowledges durable exporter acceptance.

func (*ExportExecutionResponse) Descriptor deprecated

func (*ExportExecutionResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExportExecutionResponse.ProtoReflect.Descriptor instead.

func (*ExportExecutionResponse) GetDuplicate

func (x *ExportExecutionResponse) GetDuplicate() bool

func (*ExportExecutionResponse) GetReceiptId

func (x *ExportExecutionResponse) GetReceiptId() string

func (*ExportExecutionResponse) ProtoMessage

func (*ExportExecutionResponse) ProtoMessage()

func (*ExportExecutionResponse) ProtoReflect

func (x *ExportExecutionResponse) ProtoReflect() protoreflect.Message

func (*ExportExecutionResponse) Reset

func (x *ExportExecutionResponse) Reset()

func (*ExportExecutionResponse) String

func (x *ExportExecutionResponse) String() string

type UnimplementedExecutionExporterServer

type UnimplementedExecutionExporterServer struct{}

UnimplementedExecutionExporterServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedExecutionExporterServer) Export

type UnsafeExecutionExporterServer

type UnsafeExecutionExporterServer interface {
	// contains filtered or unexported methods
}

UnsafeExecutionExporterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecutionExporterServer will result in compilation errors.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL