provisioner

package
v0.407.2 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

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 ModuleResource added in v0.377.0 

type ModuleResource struct {
	Output    *ModuleResource_ModuleResourceOutput `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Schema    *schema.Module                       `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	Artefacts []*v1.DeploymentArtefact             `protobuf:"bytes,3,rep,name=artefacts,proto3" json:"artefacts,omitempty"`
	// Runner labels required to run this deployment.
	Labels *structpb.Struct `protobuf:"bytes,4,opt,name=labels,proto3,oneof" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleResource) Descriptor deprecated added in v0.377.0 

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

Deprecated: Use ModuleResource.ProtoReflect.Descriptor instead.

func (*ModuleResource) GetArtefacts added in v0.377.0 

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

func (*ModuleResource) GetLabels added in v0.377.0 

func (x *ModuleResource) GetLabels() *structpb.Struct

func (*ModuleResource) GetOutput added in v0.377.0 

func (x *ModuleResource) GetOutput() *ModuleResource_ModuleResourceOutput

func (*ModuleResource) GetSchema added in v0.377.0 

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

func (*ModuleResource) ProtoMessage added in v0.377.0 

func (*ModuleResource) ProtoMessage()

func (*ModuleResource) ProtoReflect added in v0.377.0 

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

func (*ModuleResource) Reset added in v0.377.0 

func (x *ModuleResource) Reset()

func (*ModuleResource) String added in v0.377.0 

func (x *ModuleResource) String() string

type ModuleResource_ModuleResourceOutput added in v0.377.0 

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 added in v0.377.0 

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

Deprecated: Use ModuleResource_ModuleResourceOutput.ProtoReflect.Descriptor instead.

func (*ModuleResource_ModuleResourceOutput) GetDeploymentKey added in v0.377.0 

func (x *ModuleResource_ModuleResourceOutput) GetDeploymentKey() string

func (*ModuleResource_ModuleResourceOutput) ProtoMessage added in v0.377.0 

func (*ModuleResource_ModuleResourceOutput) ProtoMessage()

func (*ModuleResource_ModuleResourceOutput) ProtoReflect added in v0.377.0 

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

func (*ModuleResource_ModuleResourceOutput) Reset added in v0.377.0 

func (x *ModuleResource_ModuleResourceOutput) Reset()

func (*ModuleResource_ModuleResourceOutput) String added in v0.377.0 

func (x *ModuleResource_ModuleResourceOutput) String() string

type MysqlResource 

type MysqlResource struct {
	Output *schema.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 added in v0.368.0 

func (x *MysqlResource) GetOutput() *schema.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 *schema.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 added in v0.368.0 

func (x *PostgresResource) GetOutput() *schema.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_UNKNOWN   ProvisionResponse_ProvisionResponseStatus = 0
	ProvisionResponse_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 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 added in v0.377.0 

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) GetSqlMigration added in v0.399.0 

func (x *Resource) GetSqlMigration() *SqlMigrationResource

func (*Resource) GetSubscription added in v0.402.0 

func (x *Resource) GetSubscription() *SubscriptionResource

func (*Resource) GetTopic added in v0.402.0 

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 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_Module added in v0.377.0 

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_SqlMigration added in v0.399.0 

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

type Resource_Subscription added in v0.402.0 

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

type Resource_Topic added in v0.402.0 

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

type SqlMigrationResource added in v0.399.0 

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 added in v0.399.0 

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

Deprecated: Use SqlMigrationResource.ProtoReflect.Descriptor instead.

func (*SqlMigrationResource) GetDigest added in v0.399.0 

func (x *SqlMigrationResource) GetDigest() string

func (*SqlMigrationResource) GetOutput added in v0.399.0 

func (x *SqlMigrationResource) GetOutput() *SqlMigrationResource_SqlMigrationResourceOutput

func (*SqlMigrationResource) ProtoMessage added in v0.399.0 

func (*SqlMigrationResource) ProtoMessage()

func (*SqlMigrationResource) ProtoReflect added in v0.399.0 

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

func (*SqlMigrationResource) Reset added in v0.399.0 

func (x *SqlMigrationResource) Reset()

func (*SqlMigrationResource) String added in v0.399.0 

func (x *SqlMigrationResource) String() string

type SqlMigrationResource_SqlMigrationResourceOutput added in v0.399.0 

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

func (*SqlMigrationResource_SqlMigrationResourceOutput) Descriptor deprecated added in v0.399.0 

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

Deprecated: Use SqlMigrationResource_SqlMigrationResourceOutput.ProtoReflect.Descriptor instead.

func (*SqlMigrationResource_SqlMigrationResourceOutput) ProtoMessage added in v0.399.0 

func (*SqlMigrationResource_SqlMigrationResourceOutput) ProtoMessage()

func (*SqlMigrationResource_SqlMigrationResourceOutput) ProtoReflect added in v0.399.0 

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

func (*SqlMigrationResource_SqlMigrationResourceOutput) Reset added in v0.399.0 

func (x *SqlMigrationResource_SqlMigrationResourceOutput) Reset()

func (*SqlMigrationResource_SqlMigrationResourceOutput) String added in v0.399.0 

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

type SubscriptionResource added in v0.402.0 

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

func (*SubscriptionResource) Descriptor deprecated added in v0.402.0 

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

Deprecated: Use SubscriptionResource.ProtoReflect.Descriptor instead.

func (*SubscriptionResource) GetOutput added in v0.402.0 

func (x *SubscriptionResource) GetOutput() *SubscriptionResource_SubscriptionResourceOutput

func (*SubscriptionResource) GetTopic added in v0.402.0 

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

func (*SubscriptionResource) ProtoMessage added in v0.402.0 

func (*SubscriptionResource) ProtoMessage()

func (*SubscriptionResource) ProtoReflect added in v0.402.0 

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

func (*SubscriptionResource) Reset added in v0.402.0 

func (x *SubscriptionResource) Reset()

func (*SubscriptionResource) String added in v0.402.0 

func (x *SubscriptionResource) String() string

type SubscriptionResource_SubscriptionResourceOutput added in v0.402.0 

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 added in v0.402.0 

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

Deprecated: Use SubscriptionResource_SubscriptionResourceOutput.ProtoReflect.Descriptor instead.

func (*SubscriptionResource_SubscriptionResourceOutput) GetConsumerGroupId added in v0.402.0 

func (x *SubscriptionResource_SubscriptionResourceOutput) GetConsumerGroupId() string

func (*SubscriptionResource_SubscriptionResourceOutput) GetKafkaBrokers added in v0.402.0 

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

func (*SubscriptionResource_SubscriptionResourceOutput) GetTopicId added in v0.402.0 

func (x *SubscriptionResource_SubscriptionResourceOutput) GetTopicId() string

func (*SubscriptionResource_SubscriptionResourceOutput) ProtoMessage added in v0.402.0 

func (*SubscriptionResource_SubscriptionResourceOutput) ProtoMessage()

func (*SubscriptionResource_SubscriptionResourceOutput) ProtoReflect added in v0.402.0 

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

func (*SubscriptionResource_SubscriptionResourceOutput) Reset added in v0.402.0 

func (x *SubscriptionResource_SubscriptionResourceOutput) Reset()

func (*SubscriptionResource_SubscriptionResourceOutput) String added in v0.402.0 

func (x *SubscriptionResource_SubscriptionResourceOutput) String() string

type TopicResource added in v0.402.0 

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 added in v0.402.0 

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

Deprecated: Use TopicResource.ProtoReflect.Descriptor instead.

func (*TopicResource) GetOutput added in v0.402.0 

func (x *TopicResource) GetOutput() *TopicResource_TopicResourceOutput

func (*TopicResource) ProtoMessage added in v0.402.0 

func (*TopicResource) ProtoMessage()

func (*TopicResource) ProtoReflect added in v0.402.0 

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

func (*TopicResource) Reset added in v0.402.0 

func (x *TopicResource) Reset()

func (*TopicResource) String added in v0.402.0 

func (x *TopicResource) String() string

type TopicResource_TopicResourceOutput added in v0.402.0 

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 added in v0.402.0 

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

Deprecated: Use TopicResource_TopicResourceOutput.ProtoReflect.Descriptor instead.

func (*TopicResource_TopicResourceOutput) GetKafkaBrokers added in v0.402.0 

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

func (*TopicResource_TopicResourceOutput) GetTopicId added in v0.402.0 

func (x *TopicResource_TopicResourceOutput) GetTopicId() string

func (*TopicResource_TopicResourceOutput) ProtoMessage added in v0.402.0 

func (*TopicResource_TopicResourceOutput) ProtoMessage()

func (*TopicResource_TopicResourceOutput) ProtoReflect added in v0.402.0 

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

func (*TopicResource_TopicResourceOutput) Reset added in v0.402.0 

func (x *TopicResource_TopicResourceOutput) Reset()

func (*TopicResource_TopicResourceOutput) String added in v0.402.0 

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.