provisionerpb

package
v0.409.0 Latest Latest
Warning

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

 Go to latest Published: Dec 9, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ProvisionResponse_ProvisionResponseStatus_name = map[int32]string{
		0: "PROVISION_RESPONSE_STATUS_UNSPECIFIED",
		1: "PROVISION_RESPONSE_STATUS_SUBMITTED",
	}
	ProvisionResponse_ProvisionResponseStatus_value = map[string]int32{
		"PROVISION_RESPONSE_STATUS_UNSPECIFIED": 0,
		"PROVISION_RESPONSE_STATUS_SUBMITTED":   1,
	}
)

Enum value maps for ProvisionResponse_ProvisionResponseStatus.

View Source 
var File_xyz_block_ftl_provisioner_v1beta1_plugin_proto protoreflect.FileDescriptor
View Source 
var File_xyz_block_ftl_provisioner_v1beta1_resource_proto protoreflect.FileDescriptor
View Source 
var File_xyz_block_ftl_provisioner_v1beta1_service_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ModuleResource 

type ModuleResource struct {
	Output    *ModuleResource_ModuleResourceOutput `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Schema    *v1.Module                           `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	Artefacts []*v11.DeploymentArtefact            `protobuf:"bytes,3,rep,name=artefacts,proto3" json:"artefacts,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleResource) Descriptor deprecated 

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

Deprecated: Use ModuleResource.ProtoReflect.Descriptor instead.

func (*ModuleResource) GetArtefacts 

func (x *ModuleResource) GetArtefacts() []*v11.DeploymentArtefact

func (*ModuleResource) GetOutput 

func (x *ModuleResource) GetOutput() *ModuleResource_ModuleResourceOutput

func (*ModuleResource) GetSchema 

func (x *ModuleResource) GetSchema() *v1.Module

func (*ModuleResource) ProtoMessage 

func (*ModuleResource) ProtoMessage()

func (*ModuleResource) ProtoReflect 

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

func (*ModuleResource) Reset 

func (x *ModuleResource) Reset()

func (*ModuleResource) String 

func (x *ModuleResource) String() string

type ModuleResource_ModuleResourceOutput 

type ModuleResource_ModuleResourceOutput struct {
	DeploymentKey string `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleResource_ModuleResourceOutput) Descriptor deprecated 

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

Deprecated: Use ModuleResource_ModuleResourceOutput.ProtoReflect.Descriptor instead.

func (*ModuleResource_ModuleResourceOutput) GetDeploymentKey 

func (x *ModuleResource_ModuleResourceOutput) GetDeploymentKey() string

func (*ModuleResource_ModuleResourceOutput) ProtoMessage 

func (*ModuleResource_ModuleResourceOutput) ProtoMessage()

func (*ModuleResource_ModuleResourceOutput) ProtoReflect 

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

func (*ModuleResource_ModuleResourceOutput) Reset 

func (x *ModuleResource_ModuleResourceOutput) Reset()

func (*ModuleResource_ModuleResourceOutput) String 

func (x *ModuleResource_ModuleResourceOutput) String() string

type MysqlResource 

type MysqlResource struct {
	Output *v1.DatabaseRuntime `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 

func (x *MysqlResource) GetOutput() *v1.DatabaseRuntime

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 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 *v1.DatabaseRuntime `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 

func (x *PostgresResource) GetOutput() *v1.DatabaseRuntime

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 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_PROVISION_RESPONSE_STATUS_UNSPECIFIED ProvisionResponse_ProvisionResponseStatus = 0
	ProvisionResponse_PROVISION_RESPONSE_STATUS_SUBMITTED   ProvisionResponse_ProvisionResponseStatus = 1
)

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_Module
	//	*Resource_SqlMigration
	//	*Resource_Topic
	//	*Resource_Subscription
	//	*Resource_Runner
	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) GetModule 

func (x *Resource) GetModule() *ModuleResource

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) GetRunner 

func (x *Resource) GetRunner() *RunnerResource

func (*Resource) GetSqlMigration 

func (x *Resource) GetSqlMigration() *SqlMigrationResource

func (*Resource) GetSubscription 

func (x *Resource) GetSubscription() *SubscriptionResource

func (*Resource) GetTopic 

func (x *Resource) GetTopic() *TopicResource

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 

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 

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

Deprecated: Use ResourceContext.ProtoReflect.Descriptor instead.

func (*ResourceContext) GetDependencies 

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

func (*ResourceContext) GetResource 

func (x *ResourceContext) GetResource() *Resource

func (*ResourceContext) ProtoMessage 

func (*ResourceContext) ProtoMessage()

func (*ResourceContext) ProtoReflect 

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

func (*ResourceContext) Reset 

func (x *ResourceContext) Reset()

func (*ResourceContext) String 

func (x *ResourceContext) String() string

type Resource_Module 

type Resource_Module struct {
	Module *ModuleResource `protobuf:"bytes,104,opt,name=module,proto3,oneof"`
}

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 Resource_Runner 

type Resource_Runner struct {
	Runner *RunnerResource `protobuf:"bytes,108,opt,name=runner,proto3,oneof"`
}

type Resource_SqlMigration 

type Resource_SqlMigration struct {
	SqlMigration *SqlMigrationResource `protobuf:"bytes,105,opt,name=sql_migration,json=sqlMigration,proto3,oneof"`
}

type Resource_Subscription 

type Resource_Subscription struct {
	Subscription *SubscriptionResource `protobuf:"bytes,107,opt,name=subscription,proto3,oneof"`
}

type Resource_Topic 

type Resource_Topic struct {
	Topic *TopicResource `protobuf:"bytes,106,opt,name=topic,proto3,oneof"`
}

type RunnerResource 

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

func (*RunnerResource) Descriptor deprecated 

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

Deprecated: Use RunnerResource.ProtoReflect.Descriptor instead.

func (*RunnerResource) GetOutput 

func (x *RunnerResource) GetOutput() *RunnerResource_RunnerResourceOutput

func (*RunnerResource) ProtoMessage 

func (*RunnerResource) ProtoMessage()

func (*RunnerResource) ProtoReflect 

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

func (*RunnerResource) Reset 

func (x *RunnerResource) Reset()

func (*RunnerResource) String 

func (x *RunnerResource) String() string

type RunnerResource_RunnerResourceOutput 

type RunnerResource_RunnerResourceOutput struct {
	RunnerUri     string `protobuf:"bytes,1,opt,name=runner_uri,json=runnerUri,proto3" json:"runner_uri,omitempty"`
	DeploymentKey string `protobuf:"bytes,2,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	// contains filtered or unexported fields
}

func (*RunnerResource_RunnerResourceOutput) Descriptor deprecated 

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

Deprecated: Use RunnerResource_RunnerResourceOutput.ProtoReflect.Descriptor instead.

func (*RunnerResource_RunnerResourceOutput) GetDeploymentKey 

func (x *RunnerResource_RunnerResourceOutput) GetDeploymentKey() string

func (*RunnerResource_RunnerResourceOutput) GetRunnerUri 

func (x *RunnerResource_RunnerResourceOutput) GetRunnerUri() string

func (*RunnerResource_RunnerResourceOutput) ProtoMessage 

func (*RunnerResource_RunnerResourceOutput) ProtoMessage()

func (*RunnerResource_RunnerResourceOutput) ProtoReflect 

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

func (*RunnerResource_RunnerResourceOutput) Reset 

func (x *RunnerResource_RunnerResourceOutput) Reset()

func (*RunnerResource_RunnerResourceOutput) String 

func (x *RunnerResource_RunnerResourceOutput) String() string

type SqlMigrationResource 

type SqlMigrationResource struct {
	Output *SqlMigrationResource_SqlMigrationResourceOutput `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Digest string                                           `protobuf:"bytes,2,opt,name=digest,proto3" json:"digest,omitempty"`
	// contains filtered or unexported fields
}

func (*SqlMigrationResource) Descriptor deprecated 

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

Deprecated: Use SqlMigrationResource.ProtoReflect.Descriptor instead.

func (*SqlMigrationResource) GetDigest 

func (x *SqlMigrationResource) GetDigest() string

func (*SqlMigrationResource) GetOutput 

func (x *SqlMigrationResource) GetOutput() *SqlMigrationResource_SqlMigrationResourceOutput

func (*SqlMigrationResource) ProtoMessage 

func (*SqlMigrationResource) ProtoMessage()

func (*SqlMigrationResource) ProtoReflect 

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

func (*SqlMigrationResource) Reset 

func (x *SqlMigrationResource) Reset()

func (*SqlMigrationResource) String 

func (x *SqlMigrationResource) String() string

type SqlMigrationResource_SqlMigrationResourceOutput 

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

func (*SqlMigrationResource_SqlMigrationResourceOutput) Descriptor deprecated 

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

Deprecated: Use SqlMigrationResource_SqlMigrationResourceOutput.ProtoReflect.Descriptor instead.

func (*SqlMigrationResource_SqlMigrationResourceOutput) ProtoMessage 

func (*SqlMigrationResource_SqlMigrationResourceOutput) ProtoMessage()

func (*SqlMigrationResource_SqlMigrationResourceOutput) ProtoReflect 

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

func (*SqlMigrationResource_SqlMigrationResourceOutput) Reset 

func (x *SqlMigrationResource_SqlMigrationResourceOutput) Reset()

func (*SqlMigrationResource_SqlMigrationResourceOutput) String 

func (x *SqlMigrationResource_SqlMigrationResourceOutput) String() string

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 

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_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) 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_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 

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,2,opt,name=success,proto3,oneof"`
}

type SubscriptionResource 

type SubscriptionResource struct {
	Output *SubscriptionResource_SubscriptionResourceOutput `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Topic  *v1.Ref                                          `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionResource) Descriptor deprecated 

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

Deprecated: Use SubscriptionResource.ProtoReflect.Descriptor instead.

func (*SubscriptionResource) GetOutput 

func (x *SubscriptionResource) GetOutput() *SubscriptionResource_SubscriptionResourceOutput

func (*SubscriptionResource) GetTopic 

func (x *SubscriptionResource) GetTopic() *v1.Ref

func (*SubscriptionResource) ProtoMessage 

func (*SubscriptionResource) ProtoMessage()

func (*SubscriptionResource) ProtoReflect 

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

func (*SubscriptionResource) Reset 

func (x *SubscriptionResource) Reset()

func (*SubscriptionResource) String 

func (x *SubscriptionResource) String() string

type SubscriptionResource_SubscriptionResourceOutput 

type SubscriptionResource_SubscriptionResourceOutput struct {
	KafkaBrokers    []string `protobuf:"bytes,1,rep,name=kafka_brokers,json=kafkaBrokers,proto3" json:"kafka_brokers,omitempty"`
	TopicId         string   `protobuf:"bytes,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	ConsumerGroupId string   `protobuf:"bytes,3,opt,name=consumer_group_id,json=consumerGroupId,proto3" json:"consumer_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionResource_SubscriptionResourceOutput) Descriptor deprecated 

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

Deprecated: Use SubscriptionResource_SubscriptionResourceOutput.ProtoReflect.Descriptor instead.

func (*SubscriptionResource_SubscriptionResourceOutput) GetConsumerGroupId 

func (x *SubscriptionResource_SubscriptionResourceOutput) GetConsumerGroupId() string

func (*SubscriptionResource_SubscriptionResourceOutput) GetKafkaBrokers 

func (x *SubscriptionResource_SubscriptionResourceOutput) GetKafkaBrokers() []string

func (*SubscriptionResource_SubscriptionResourceOutput) GetTopicId 

func (x *SubscriptionResource_SubscriptionResourceOutput) GetTopicId() string

func (*SubscriptionResource_SubscriptionResourceOutput) ProtoMessage 

func (*SubscriptionResource_SubscriptionResourceOutput) ProtoMessage()

func (*SubscriptionResource_SubscriptionResourceOutput) ProtoReflect 

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

func (*SubscriptionResource_SubscriptionResourceOutput) Reset 

func (x *SubscriptionResource_SubscriptionResourceOutput) Reset()

func (*SubscriptionResource_SubscriptionResourceOutput) String 

func (x *SubscriptionResource_SubscriptionResourceOutput) String() string

type TopicResource 

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

func (*TopicResource) Descriptor deprecated 

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

Deprecated: Use TopicResource.ProtoReflect.Descriptor instead.

func (*TopicResource) GetOutput 

func (x *TopicResource) GetOutput() *TopicResource_TopicResourceOutput

func (*TopicResource) ProtoMessage 

func (*TopicResource) ProtoMessage()

func (*TopicResource) ProtoReflect 

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

func (*TopicResource) Reset 

func (x *TopicResource) Reset()

func (*TopicResource) String 

func (x *TopicResource) String() string

type TopicResource_TopicResourceOutput 

type TopicResource_TopicResourceOutput struct {
	KafkaBrokers []string `protobuf:"bytes,1,rep,name=kafka_brokers,json=kafkaBrokers,proto3" json:"kafka_brokers,omitempty"`
	TopicId      string   `protobuf:"bytes,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicResource_TopicResourceOutput) Descriptor deprecated 

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

Deprecated: Use TopicResource_TopicResourceOutput.ProtoReflect.Descriptor instead.

func (*TopicResource_TopicResourceOutput) GetKafkaBrokers 

func (x *TopicResource_TopicResourceOutput) GetKafkaBrokers() []string

func (*TopicResource_TopicResourceOutput) GetTopicId 

func (x *TopicResource_TopicResourceOutput) GetTopicId() string

func (*TopicResource_TopicResourceOutput) ProtoMessage 

func (*TopicResource_TopicResourceOutput) ProtoMessage()

func (*TopicResource_TopicResourceOutput) ProtoReflect 

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

func (*TopicResource_TopicResourceOutput) Reset 

func (x *TopicResource_TopicResourceOutput) Reset()

func (*TopicResource_TopicResourceOutput) String 

func (x *TopicResource_TopicResourceOutput) String() string

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.