pubsub

package
v5.34.0 Latest Latest
Warning

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

 Go to latest Published: Jun 17, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const PubsubSchemaAssetType string = "pubsub.googleapis.com/Schema"
View Source 
const PubsubSchemaIAMAssetType string = "pubsub.googleapis.com/Schema"

Provide a separate asset type constant so we don't have to worry about name conflicts between IAM and non-IAM converter files

View Source 
const PubsubSubscriptionAssetType string = "pubsub.googleapis.com/Subscription"
View Source 
const PubsubTopicAssetType string = "pubsub.googleapis.com/Topic"
View Source 
const PubsubTopicIAMAssetType string = "pubsub.googleapis.com/Topic"

Provide a separate asset type constant so we don't have to worry about name conflicts between IAM and non-IAM converter files

View Source 
const PubsubTopicRegex = "projects\\/.*\\/topics\\/.*"

Variables

View Source 
var IamPubsubSubscriptionSchema = map[string]*schema.Schema{
	"subscription": {
		Type:             schema.TypeString,
		Required:         true,
		ForceNew:         true,
		DiffSuppressFunc: tpgresource.CompareSelfLinkOrResourceName,
	},
	"project": {
		Type:     schema.TypeString,
		Optional: true,
		Computed: true,
		ForceNew: true,
	},
}
View Source 
var PubsubSchemaIamSchema = map[string]*schema.Schema{
	"project": {
		Type:     schema.TypeString,
		Computed: true,
		Optional: true,
		ForceNew: true,
	},
	"schema": {
		Type:             schema.TypeString,
		Required:         true,
		ForceNew:         true,
		DiffSuppressFunc: tpgresource.CompareSelfLinkOrResourceName,
	},
}
View Source 
var PubsubTopicIamSchema = map[string]*schema.Schema{
	"project": {
		Type:     schema.TypeString,
		Computed: true,
		Optional: true,
		ForceNew: true,
	},
	"topic": {
		Type:             schema.TypeString,
		Required:         true,
		ForceNew:         true,
		DiffSuppressFunc: tpgresource.CompareSelfLinkOrResourceName,
	},
}

Functions

func FetchPubsubSchemaIamPolicy 

func FetchPubsubSchemaIamPolicy(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (cai.Asset, error)

func FetchPubsubSubscriptionIamPolicy 

func FetchPubsubSubscriptionIamPolicy(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (cai.Asset, error)

func FetchPubsubTopicIamPolicy 

func FetchPubsubTopicIamPolicy(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (cai.Asset, error)

func GetComputedSubscriptionName 

func GetComputedSubscriptionName(project, subscription string) string

func GetComputedTopicName 

func GetComputedTopicName(project, topic string) string

func GetPubsubSchemaApiObject 

func GetPubsubSchemaApiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (map[string]interface{}, error)

func GetPubsubSchemaCaiObject 

func GetPubsubSchemaCaiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) ([]cai.Asset, error)

func GetPubsubSchemaIamBindingCaiObject 

func GetPubsubSchemaIamBindingCaiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) ([]cai.Asset, error)

func GetPubsubSchemaIamMemberCaiObject 

func GetPubsubSchemaIamMemberCaiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) ([]cai.Asset, error)

func GetPubsubSchemaIamPolicyCaiObject 

func GetPubsubSchemaIamPolicyCaiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) ([]cai.Asset, error)

func GetPubsubSubscriptionApiObject 

func GetPubsubSubscriptionApiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (map[string]interface{}, error)

func GetPubsubSubscriptionCaiObject 

func GetPubsubSubscriptionCaiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) ([]cai.Asset, error)

func GetPubsubSubscriptionIamBindingCaiObject 

func GetPubsubSubscriptionIamBindingCaiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) ([]cai.Asset, error)

func GetPubsubSubscriptionIamMemberCaiObject 

func GetPubsubSubscriptionIamMemberCaiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) ([]cai.Asset, error)

func GetPubsubSubscriptionIamPolicyCaiObject 

func GetPubsubSubscriptionIamPolicyCaiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) ([]cai.Asset, error)

func GetPubsubTopicApiObject 

func GetPubsubTopicApiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (map[string]interface{}, error)

func GetPubsubTopicCaiObject 

func GetPubsubTopicCaiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) ([]cai.Asset, error)

func GetPubsubTopicIamBindingCaiObject 

func GetPubsubTopicIamBindingCaiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) ([]cai.Asset, error)

func GetPubsubTopicIamMemberCaiObject 

func GetPubsubTopicIamMemberCaiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) ([]cai.Asset, error)

func GetPubsubTopicIamPolicyCaiObject 

func GetPubsubTopicIamPolicyCaiObject(d tpgresource.TerraformResourceData, config *transport_tpg.Config) ([]cai.Asset, error)

func MergePubsubSchemaIamBinding 

func MergePubsubSchemaIamBinding(existing, incoming cai.Asset) cai.Asset

func MergePubsubSchemaIamBindingDelete 

func MergePubsubSchemaIamBindingDelete(existing, incoming cai.Asset) cai.Asset

func MergePubsubSchemaIamMember 

func MergePubsubSchemaIamMember(existing, incoming cai.Asset) cai.Asset

func MergePubsubSchemaIamMemberDelete 

func MergePubsubSchemaIamMemberDelete(existing, incoming cai.Asset) cai.Asset

func MergePubsubSchemaIamPolicy 

func MergePubsubSchemaIamPolicy(existing, incoming cai.Asset) cai.Asset

func MergePubsubSubscriptionIamBinding 

func MergePubsubSubscriptionIamBinding(existing, incoming cai.Asset) cai.Asset

func MergePubsubSubscriptionIamBindingDelete 

func MergePubsubSubscriptionIamBindingDelete(existing, incoming cai.Asset) cai.Asset

func MergePubsubSubscriptionIamMember 

func MergePubsubSubscriptionIamMember(existing, incoming cai.Asset) cai.Asset

func MergePubsubSubscriptionIamMemberDelete 

func MergePubsubSubscriptionIamMemberDelete(existing, incoming cai.Asset) cai.Asset

func MergePubsubSubscriptionIamPolicy 

func MergePubsubSubscriptionIamPolicy(existing, incoming cai.Asset) cai.Asset

func MergePubsubTopicIamBinding 

func MergePubsubTopicIamBinding(existing, incoming cai.Asset) cai.Asset

func MergePubsubTopicIamBindingDelete 

func MergePubsubTopicIamBindingDelete(existing, incoming cai.Asset) cai.Asset

func MergePubsubTopicIamMember 

func MergePubsubTopicIamMember(existing, incoming cai.Asset) cai.Asset

func MergePubsubTopicIamMemberDelete 

func MergePubsubTopicIamMemberDelete(existing, incoming cai.Asset) cai.Asset

func MergePubsubTopicIamPolicy 

func MergePubsubTopicIamPolicy(existing, incoming cai.Asset) cai.Asset

func NewPubsubSubscriptionIamUpdater 

func NewPubsubSubscriptionIamUpdater(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (tpgiamresource.ResourceIamUpdater, error)

func PubsubSchemaIamUpdaterProducer 

func PubsubSchemaIamUpdaterProducer(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (tpgiamresource.ResourceIamUpdater, error)

func PubsubSchemaIdParseFunc 

func PubsubSchemaIdParseFunc(d *schema.ResourceData, config *transport_tpg.Config) error

func PubsubSubscriptionIdParseFunc 

func PubsubSubscriptionIdParseFunc(d *schema.ResourceData, _ *transport_tpg.Config) error

func PubsubTopicIamUpdaterProducer 

func PubsubTopicIamUpdaterProducer(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (tpgiamresource.ResourceIamUpdater, error)

func PubsubTopicIdParseFunc 

func PubsubTopicIdParseFunc(d *schema.ResourceData, config *transport_tpg.Config) error

func ResourceConverterPubsubSchema 

func ResourceConverterPubsubSchema() cai.ResourceConverter

func ResourceConverterPubsubSchemaIamBinding 

func ResourceConverterPubsubSchemaIamBinding() cai.ResourceConverter

func ResourceConverterPubsubSchemaIamMember 

func ResourceConverterPubsubSchemaIamMember() cai.ResourceConverter

func ResourceConverterPubsubSchemaIamPolicy 

func ResourceConverterPubsubSchemaIamPolicy() cai.ResourceConverter

func ResourceConverterPubsubSubscription 

func ResourceConverterPubsubSubscription() cai.ResourceConverter

func ResourceConverterPubsubSubscriptionIamBinding 

func ResourceConverterPubsubSubscriptionIamBinding() cai.ResourceConverter

func ResourceConverterPubsubSubscriptionIamMember 

func ResourceConverterPubsubSubscriptionIamMember() cai.ResourceConverter

func ResourceConverterPubsubSubscriptionIamPolicy 

func ResourceConverterPubsubSubscriptionIamPolicy() cai.ResourceConverter

func ResourceConverterPubsubTopic 

func ResourceConverterPubsubTopic() cai.ResourceConverter

func ResourceConverterPubsubTopicIamBinding 

func ResourceConverterPubsubTopicIamBinding() cai.ResourceConverter

func ResourceConverterPubsubTopicIamMember 

func ResourceConverterPubsubTopicIamMember() cai.ResourceConverter

func ResourceConverterPubsubTopicIamPolicy 

func ResourceConverterPubsubTopicIamPolicy() cai.ResourceConverter

Types

type PubsubSchemaIamUpdater 

type PubsubSchemaIamUpdater struct {
	Config *transport_tpg.Config
	// contains filtered or unexported fields
}

func (*PubsubSchemaIamUpdater) DescribeResource 

func (u *PubsubSchemaIamUpdater) DescribeResource() string

func (*PubsubSchemaIamUpdater) GetMutexKey 

func (u *PubsubSchemaIamUpdater) GetMutexKey() string

func (*PubsubSchemaIamUpdater) GetResourceIamPolicy 

func (u *PubsubSchemaIamUpdater) GetResourceIamPolicy() (*cloudresourcemanager.Policy, error)

func (*PubsubSchemaIamUpdater) GetResourceId 

func (u *PubsubSchemaIamUpdater) GetResourceId() string

func (*PubsubSchemaIamUpdater) SetResourceIamPolicy 

func (u *PubsubSchemaIamUpdater) SetResourceIamPolicy(policy *cloudresourcemanager.Policy) error

type PubsubSubscriptionIamUpdater 

type PubsubSubscriptionIamUpdater struct {
	Config *transport_tpg.Config
	// contains filtered or unexported fields
}

func (*PubsubSubscriptionIamUpdater) DescribeResource 

func (u *PubsubSubscriptionIamUpdater) DescribeResource() string

func (*PubsubSubscriptionIamUpdater) GetMutexKey 

func (u *PubsubSubscriptionIamUpdater) GetMutexKey() string

func (*PubsubSubscriptionIamUpdater) GetResourceIamPolicy 

func (u *PubsubSubscriptionIamUpdater) GetResourceIamPolicy() (*cloudresourcemanager.Policy, error)

func (*PubsubSubscriptionIamUpdater) GetResourceId 

func (u *PubsubSubscriptionIamUpdater) GetResourceId() string

func (*PubsubSubscriptionIamUpdater) SetResourceIamPolicy 

func (u *PubsubSubscriptionIamUpdater) SetResourceIamPolicy(policy *cloudresourcemanager.Policy) error

type PubsubTopicIamUpdater 

type PubsubTopicIamUpdater struct {
	Config *transport_tpg.Config
	// contains filtered or unexported fields
}

func (*PubsubTopicIamUpdater) DescribeResource 

func (u *PubsubTopicIamUpdater) DescribeResource() string

func (*PubsubTopicIamUpdater) GetMutexKey 

func (u *PubsubTopicIamUpdater) GetMutexKey() string

func (*PubsubTopicIamUpdater) GetResourceIamPolicy 

func (u *PubsubTopicIamUpdater) GetResourceIamPolicy() (*cloudresourcemanager.Policy, error)

func (*PubsubTopicIamUpdater) GetResourceId 

func (u *PubsubTopicIamUpdater) GetResourceId() string

func (*PubsubTopicIamUpdater) SetResourceIamPolicy 

func (u *PubsubTopicIamUpdater) SetResourceIamPolicy(policy *cloudresourcemanager.Policy) error

Source Files

View all Source files

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.