provisioner

package
v0.372.3 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ProvisionResponse_ProvisionResponseStatus_name = map[int32]string{
		0: "UNKNOWN",
		1: "SUBMITTED",
		2: "NO_CHANGES",
	}
	ProvisionResponse_ProvisionResponseStatus_value = map[string]int32{
		"UNKNOWN":    0,
		"SUBMITTED":  1,
		"NO_CHANGES": 2,
	}
)

Enum value maps for ProvisionResponse_ProvisionResponseStatus.

View Source 
var File_xyz_block_ftl_v1beta1_provisioner_plugin_proto protoreflect.FileDescriptor
View Source 
var File_xyz_block_ftl_v1beta1_provisioner_resource_proto protoreflect.FileDescriptor
View Source 
var File_xyz_block_ftl_v1beta1_provisioner_service_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type MysqlResource 

type MysqlResource struct {
	Output *MysqlResource_MysqlResourceOutput `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

func (*MysqlResource) Descriptor deprecated 

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

Deprecated: Use MysqlResource.ProtoReflect.Descriptor instead.

func (*MysqlResource) GetOutput added in v0.368.0 

func (x *MysqlResource) GetOutput() *MysqlResource_MysqlResourceOutput

func (*MysqlResource) ProtoMessage 

func (*MysqlResource) ProtoMessage()

func (*MysqlResource) ProtoReflect 

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

func (*MysqlResource) Reset 

func (x *MysqlResource) Reset()

func (*MysqlResource) String 

func (x *MysqlResource) String() string

type MysqlResource_MysqlResourceOutput added in v0.368.0 

type MysqlResource_MysqlResourceOutput struct {
	ReadEndpoint  string `protobuf:"bytes,1,opt,name=read_endpoint,json=readEndpoint,proto3" json:"read_endpoint,omitempty"`
	WriteEndpoint string `protobuf:"bytes,2,opt,name=write_endpoint,json=writeEndpoint,proto3" json:"write_endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*MysqlResource_MysqlResourceOutput) Descriptor deprecated added in v0.368.0 

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

Deprecated: Use MysqlResource_MysqlResourceOutput.ProtoReflect.Descriptor instead.

func (*MysqlResource_MysqlResourceOutput) GetReadEndpoint added in v0.368.0 

func (x *MysqlResource_MysqlResourceOutput) GetReadEndpoint() string

func (*MysqlResource_MysqlResourceOutput) GetWriteEndpoint added in v0.368.0 

func (x *MysqlResource_MysqlResourceOutput) GetWriteEndpoint() string

func (*MysqlResource_MysqlResourceOutput) ProtoMessage added in v0.368.0 

func (*MysqlResource_MysqlResourceOutput) ProtoMessage()

func (*MysqlResource_MysqlResourceOutput) ProtoReflect added in v0.368.0 

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

func (*MysqlResource_MysqlResourceOutput) Reset added in v0.368.0 

func (x *MysqlResource_MysqlResourceOutput) Reset()

func (*MysqlResource_MysqlResourceOutput) String added in v0.368.0 

func (x *MysqlResource_MysqlResourceOutput) String() string

type PlanRequest 

type PlanRequest struct {
	Provisioning *ProvisionRequest `protobuf:"bytes,1,opt,name=provisioning,proto3" json:"provisioning,omitempty"`
	// contains filtered or unexported fields
}

func (*PlanRequest) Descriptor deprecated 

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

Deprecated: Use PlanRequest.ProtoReflect.Descriptor instead.

func (*PlanRequest) GetProvisioning 

func (x *PlanRequest) GetProvisioning() *ProvisionRequest

func (*PlanRequest) ProtoMessage 

func (*PlanRequest) ProtoMessage()

func (*PlanRequest) ProtoReflect 

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

func (*PlanRequest) Reset 

func (x *PlanRequest) Reset()

func (*PlanRequest) String 

func (x *PlanRequest) String() string

type PlanResponse 

type PlanResponse struct {

	// a detailed, implementation specific, plan of changes this deployment would do
	Plan string `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan,omitempty"`
	// contains filtered or unexported fields
}

func (*PlanResponse) Descriptor deprecated 

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

Deprecated: Use PlanResponse.ProtoReflect.Descriptor instead.

func (*PlanResponse) GetPlan 

func (x *PlanResponse) GetPlan() string

func (*PlanResponse) ProtoMessage 

func (*PlanResponse) ProtoMessage()

func (*PlanResponse) ProtoReflect 

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

func (*PlanResponse) Reset 

func (x *PlanResponse) Reset()

func (*PlanResponse) String 

func (x *PlanResponse) String() string

type PostgresResource 

type PostgresResource struct {
	Output *PostgresResource_PostgresResourceOutput `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

func (*PostgresResource) Descriptor deprecated 

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

Deprecated: Use PostgresResource.ProtoReflect.Descriptor instead.

func (*PostgresResource) GetOutput added in v0.368.0 

func (x *PostgresResource) GetOutput() *PostgresResource_PostgresResourceOutput

func (*PostgresResource) ProtoMessage 

func (*PostgresResource) ProtoMessage()

func (*PostgresResource) ProtoReflect 

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

func (*PostgresResource) Reset 

func (x *PostgresResource) Reset()

func (*PostgresResource) String 

func (x *PostgresResource) String() string

type PostgresResource_PostgresResourceOutput added in v0.368.0 

type PostgresResource_PostgresResourceOutput struct {
	ReadEndpoint  string `protobuf:"bytes,1,opt,name=read_endpoint,json=readEndpoint,proto3" json:"read_endpoint,omitempty"`
	WriteEndpoint string `protobuf:"bytes,2,opt,name=write_endpoint,json=writeEndpoint,proto3" json:"write_endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*PostgresResource_PostgresResourceOutput) Descriptor deprecated added in v0.368.0 

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

Deprecated: Use PostgresResource_PostgresResourceOutput.ProtoReflect.Descriptor instead.

func (*PostgresResource_PostgresResourceOutput) GetReadEndpoint added in v0.368.0 

func (x *PostgresResource_PostgresResourceOutput) GetReadEndpoint() string

func (*PostgresResource_PostgresResourceOutput) GetWriteEndpoint added in v0.368.0 

func (x *PostgresResource_PostgresResourceOutput) GetWriteEndpoint() string

func (*PostgresResource_PostgresResourceOutput) ProtoMessage added in v0.368.0 

func (*PostgresResource_PostgresResourceOutput) ProtoMessage()

func (*PostgresResource_PostgresResourceOutput) ProtoReflect added in v0.368.0 

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

func (*PostgresResource_PostgresResourceOutput) Reset added in v0.368.0 

func (x *PostgresResource_PostgresResourceOutput) Reset()

func (*PostgresResource_PostgresResourceOutput) String added in v0.368.0 

func (x *PostgresResource_PostgresResourceOutput) String() string

type ProvisionRequest 

type ProvisionRequest struct {
	FtlClusterId string `protobuf:"bytes,1,opt,name=ftl_cluster_id,json=ftlClusterId,proto3" json:"ftl_cluster_id,omitempty"`
	Module       string `protobuf:"bytes,2,opt,name=module,proto3" json:"module,omitempty"`
	// The resource FTL thinks exists currently
	ExistingResources []*Resource `protobuf:"bytes,3,rep,name=existing_resources,json=existingResources,proto3" json:"existing_resources,omitempty"`
	// The resource FTL would like to exist after this provisioning run.
	// This includes all new, existing, and changes resources in this change.
	DesiredResources []*ResourceContext `protobuf:"bytes,4,rep,name=desired_resources,json=desiredResources,proto3" json:"desired_resources,omitempty"`
	// contains filtered or unexported fields
}

func (*ProvisionRequest) Descriptor deprecated 

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

Deprecated: Use ProvisionRequest.ProtoReflect.Descriptor instead.

func (*ProvisionRequest) GetDesiredResources 

func (x *ProvisionRequest) GetDesiredResources() []*ResourceContext

func (*ProvisionRequest) GetExistingResources 

func (x *ProvisionRequest) GetExistingResources() []*Resource

func (*ProvisionRequest) GetFtlClusterId 

func (x *ProvisionRequest) GetFtlClusterId() string

func (*ProvisionRequest) GetModule 

func (x *ProvisionRequest) GetModule() string

func (*ProvisionRequest) ProtoMessage 

func (*ProvisionRequest) ProtoMessage()

func (*ProvisionRequest) ProtoReflect 

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

func (*ProvisionRequest) Reset 

func (x *ProvisionRequest) Reset()

func (*ProvisionRequest) String 

func (x *ProvisionRequest) String() string

type ProvisionResponse 

type ProvisionResponse struct {
	ProvisioningToken string                                    `protobuf:"bytes,1,opt,name=provisioning_token,json=provisioningToken,proto3" json:"provisioning_token,omitempty"`
	Status            ProvisionResponse_ProvisionResponseStatus `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProvisionResponse) Descriptor deprecated 

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

Deprecated: Use ProvisionResponse.ProtoReflect.Descriptor instead.

func (*ProvisionResponse) GetProvisioningToken 

func (x *ProvisionResponse) GetProvisioningToken() string

func (*ProvisionResponse) GetStatus 

func (x *ProvisionResponse) GetStatus() ProvisionResponse_ProvisionResponseStatus

func (*ProvisionResponse) ProtoMessage 

func (*ProvisionResponse) ProtoMessage()

func (*ProvisionResponse) ProtoReflect 

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

func (*ProvisionResponse) Reset 

func (x *ProvisionResponse) Reset()

func (*ProvisionResponse) String 

func (x *ProvisionResponse) String() string

type ProvisionResponse_ProvisionResponseStatus 

type ProvisionResponse_ProvisionResponseStatus int32
const (
	ProvisionResponse_UNKNOWN    ProvisionResponse_ProvisionResponseStatus = 0
	ProvisionResponse_SUBMITTED  ProvisionResponse_ProvisionResponseStatus = 1
	ProvisionResponse_NO_CHANGES ProvisionResponse_ProvisionResponseStatus = 2
)

func (ProvisionResponse_ProvisionResponseStatus) Descriptor 

func (ProvisionResponse_ProvisionResponseStatus) Descriptor() protoreflect.EnumDescriptor

func (ProvisionResponse_ProvisionResponseStatus) Enum 

func (x ProvisionResponse_ProvisionResponseStatus) Enum() *ProvisionResponse_ProvisionResponseStatus

func (ProvisionResponse_ProvisionResponseStatus) EnumDescriptor deprecated 

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

Deprecated: Use ProvisionResponse_ProvisionResponseStatus.Descriptor instead.

func (ProvisionResponse_ProvisionResponseStatus) Number 

func (x ProvisionResponse_ProvisionResponseStatus) Number() protoreflect.EnumNumber

func (ProvisionResponse_ProvisionResponseStatus) String 

func (x ProvisionResponse_ProvisionResponseStatus) String() string

func (ProvisionResponse_ProvisionResponseStatus) Type 

func (ProvisionResponse_ProvisionResponseStatus) Type() protoreflect.EnumType

type Resource 

type Resource struct {

	// id unique within the module
	ResourceId string `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// Types that are assignable to Resource:
	//
	//	*Resource_Postgres
	//	*Resource_Mysql
	Resource isResource_Resource `protobuf_oneof:"resource"`
	// contains filtered or unexported fields
}

Resource is an abstract resource extracted from FTL Schema.

func (*Resource) Descriptor deprecated 

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetMysql 

func (x *Resource) GetMysql() *MysqlResource

func (*Resource) GetPostgres 

func (x *Resource) GetPostgres() *PostgresResource

func (*Resource) GetResource 

func (m *Resource) GetResource() isResource_Resource

func (*Resource) GetResourceId 

func (x *Resource) GetResourceId() string

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect 

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

func (*Resource) Reset 

func (x *Resource) Reset()

func (*Resource) String 

func (x *Resource) String() string

type ResourceContext added in v0.368.0 

type ResourceContext struct {
	Resource     *Resource   `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Dependencies []*Resource `protobuf:"bytes,2,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// contains filtered or unexported fields
}

ResourceContext is the context used to create a new resource This includes the direct dependencies of the new resource, that can impact the resource creation.

func (*ResourceContext) Descriptor deprecated added in v0.368.0 

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

Deprecated: Use ResourceContext.ProtoReflect.Descriptor instead.

func (*ResourceContext) GetDependencies added in v0.368.0 

func (x *ResourceContext) GetDependencies() []*Resource

func (*ResourceContext) GetResource added in v0.368.0 

func (x *ResourceContext) GetResource() *Resource

func (*ResourceContext) ProtoMessage added in v0.368.0 

func (*ResourceContext) ProtoMessage()

func (*ResourceContext) ProtoReflect added in v0.368.0 

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

func (*ResourceContext) Reset added in v0.368.0 

func (x *ResourceContext) Reset()

func (*ResourceContext) String added in v0.368.0 

func (x *ResourceContext) String() string

type Resource_Mysql 

type Resource_Mysql struct {
	Mysql *MysqlResource `protobuf:"bytes,103,opt,name=mysql,proto3,oneof"`
}

type Resource_Postgres 

type Resource_Postgres struct {
	Postgres *PostgresResource `protobuf:"bytes,102,opt,name=postgres,proto3,oneof"`
}

type StatusRequest 

type StatusRequest struct {
	ProvisioningToken string `protobuf:"bytes,1,opt,name=provisioning_token,json=provisioningToken,proto3" json:"provisioning_token,omitempty"`
	// The set of desired_resources used to initiate this provisioning request
	// We need this as input here, so we can populate any resource fields in them
	// when the provisioning finishes
	DesiredResources []*Resource `protobuf:"bytes,2,rep,name=desired_resources,json=desiredResources,proto3" json:"desired_resources,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetDesiredResources added in v0.368.0 

func (x *StatusRequest) GetDesiredResources() []*Resource

func (*StatusRequest) GetProvisioningToken 

func (x *StatusRequest) GetProvisioningToken() string

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {

	// Types that are assignable to Status:
	//
	//	*StatusResponse_Running
	//	*StatusResponse_Failed
	//	*StatusResponse_Success
	Status isStatusResponse_Status `protobuf_oneof:"status"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetFailed 

func (x *StatusResponse) GetFailed() *StatusResponse_ProvisioningFailed

func (*StatusResponse) GetRunning 

func (x *StatusResponse) GetRunning() *StatusResponse_ProvisioningRunning

func (*StatusResponse) GetStatus 

func (m *StatusResponse) GetStatus() isStatusResponse_Status

func (*StatusResponse) GetSuccess 

func (x *StatusResponse) GetSuccess() *StatusResponse_ProvisioningSuccess

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type StatusResponse_Failed 

type StatusResponse_Failed struct {
	Failed *StatusResponse_ProvisioningFailed `protobuf:"bytes,2,opt,name=failed,proto3,oneof"`
}

type StatusResponse_ProvisioningFailed 

type StatusResponse_ProvisioningFailed struct {
	ErrorMessage string `protobuf:"bytes,1,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse_ProvisioningFailed) Descriptor deprecated 

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

Deprecated: Use StatusResponse_ProvisioningFailed.ProtoReflect.Descriptor instead.

func (*StatusResponse_ProvisioningFailed) GetErrorMessage 

func (x *StatusResponse_ProvisioningFailed) GetErrorMessage() string

func (*StatusResponse_ProvisioningFailed) ProtoMessage 

func (*StatusResponse_ProvisioningFailed) ProtoMessage()

func (*StatusResponse_ProvisioningFailed) ProtoReflect 

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

func (*StatusResponse_ProvisioningFailed) Reset 

func (x *StatusResponse_ProvisioningFailed) Reset()

func (*StatusResponse_ProvisioningFailed) String 

func (x *StatusResponse_ProvisioningFailed) String() string

type StatusResponse_ProvisioningRunning 

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

func (*StatusResponse_ProvisioningRunning) Descriptor deprecated 

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

Deprecated: Use StatusResponse_ProvisioningRunning.ProtoReflect.Descriptor instead.

func (*StatusResponse_ProvisioningRunning) ProtoMessage 

func (*StatusResponse_ProvisioningRunning) ProtoMessage()

func (*StatusResponse_ProvisioningRunning) ProtoReflect 

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

func (*StatusResponse_ProvisioningRunning) Reset 

func (x *StatusResponse_ProvisioningRunning) Reset()

func (*StatusResponse_ProvisioningRunning) String 

func (x *StatusResponse_ProvisioningRunning) String() string

type StatusResponse_ProvisioningSuccess 

type StatusResponse_ProvisioningSuccess struct {

	// Some fields in the resources might have been populated
	// during the provisioning. The new state is returned here
	UpdatedResources []*Resource `protobuf:"bytes,1,rep,name=updated_resources,json=updatedResources,proto3" json:"updated_resources,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse_ProvisioningSuccess) Descriptor deprecated 

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

Deprecated: Use StatusResponse_ProvisioningSuccess.ProtoReflect.Descriptor instead.

func (*StatusResponse_ProvisioningSuccess) GetUpdatedResources added in v0.368.0 

func (x *StatusResponse_ProvisioningSuccess) GetUpdatedResources() []*Resource

func (*StatusResponse_ProvisioningSuccess) ProtoMessage 

func (*StatusResponse_ProvisioningSuccess) ProtoMessage()

func (*StatusResponse_ProvisioningSuccess) ProtoReflect 

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

func (*StatusResponse_ProvisioningSuccess) Reset 

func (x *StatusResponse_ProvisioningSuccess) Reset()

func (*StatusResponse_ProvisioningSuccess) String 

func (x *StatusResponse_ProvisioningSuccess) String() string

type StatusResponse_Running 

type StatusResponse_Running struct {
	Running *StatusResponse_ProvisioningRunning `protobuf:"bytes,1,opt,name=running,proto3,oneof"`
}

type StatusResponse_Success 

type StatusResponse_Success struct {
	Success *StatusResponse_ProvisioningSuccess `protobuf:"bytes,3,opt,name=success,proto3,oneof"`
}

Source Files

View all Source files

Directories

Path Synopsis

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.