yandex

package
v0.129.0 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 2024 License: MPL-2.0 Imports: 150 Imported by: 8

Documentation

Overview

Code generated with gentf. DO NOT EDIT.

Code generated with gentf. DO NOT EDIT.

Code generated with gentf. DO NOT EDIT.

Index

Constants

View Source 
const (
	CHALLENGE_TYPE_DNS_CNAME challengeType = 0
	CHALLENGE_TYPE_DNS_TXT   challengeType = 1
	CHALLENGE_TYPE_HTTP      challengeType = 2
)
View Source 
const (
	ReadModeKey key = iota
)
View Source 
const StandardImagesFolderID = "standard-images"

Variables

View Source 
var (
	UserSettings_OverflowMode_name = map[int32]string{
		0: "unspecified",
		1: "throw",
		2: "break",
	}
	UserSettings_OverflowMode_value       = makeReversedMap(UserSettings_OverflowMode_name, clickhouse.UserSettings_OverflowMode_value)
	UserSettings_GroupByOverflowMode_name = map[int32]string{
		0: "unspecified",
		1: "throw",
		2: "break",
		3: "any",
	}
	UserSettings_GroupByOverflowMode_value   = makeReversedMap(UserSettings_GroupByOverflowMode_name, clickhouse.UserSettings_GroupByOverflowMode_value)
	UserSettings_DistributedProductMode_name = map[int32]string{
		0: "unspecified",
		1: "deny",
		2: "local",
		3: "global",
		4: "allow",
	}
	UserSettings_DistributedProductMode_value     = makeReversedMap(UserSettings_DistributedProductMode_name, clickhouse.UserSettings_DistributedProductMode_value)
	UserSettings_CountDistinctImplementation_name = map[int32]string{
		0: "unspecified",
		1: "uniq",
		2: "uniq_combined",
		3: "uniq_combined_64",
		4: "uniq_hll_12",
		5: "uniq_exact",
	}
	UserSettings_CountDistinctImplementation_value = makeReversedMap(UserSettings_CountDistinctImplementation_name, clickhouse.UserSettings_CountDistinctImplementation_value)
	UserSettings_QuotaMode_name                    = map[int32]string{
		0: "unspecified",
		1: "default",
		2: "keyed",
		3: "keyed_by_ip",
	}
	UserSettings_QuotaMode_value                = makeReversedMap(UserSettings_QuotaMode_name, clickhouse.UserSettings_QuotaMode_value)
	UserSettings_LocalFilesystemReadMethod_name = map[int32]string{
		0: "unspecified",
		1: "read",
		2: "pread_threadpool",
		3: "pread",
		4: "nmap",
	}
	UserSettings_RemoteFilesystemReadMethod_name = map[int32]string{
		0: "unspecified",
		1: "read",
		2: "threadpool",
	}
	UserSettings_LoadBalancing_name = map[int32]string{
		0: "unspecified",
		1: "random",
		2: "nearest_hostname",
		3: "in_order",
		4: "first_or_random",
		5: "round_robin",
	}
	UserSettings_LocalFilesystemReadMethod_value  = makeReversedMap(UserSettings_LocalFilesystemReadMethod_name, clickhouse.UserSettings_LocalFilesystemReadMethod_value)
	UserSettings_RemoteFilesystemReadMethod_value = makeReversedMap(UserSettings_RemoteFilesystemReadMethod_name, clickhouse.UserSettings_RemoteFilesystemReadMethod_value)
	UserSettings_LoadBalancing_value              = makeReversedMap(UserSettings_LoadBalancing_name, clickhouse.UserSettings_LoadBalancing_value)
)
View Source 
var (
	Topic_CleanupPolicy_name = map[int32]string{
		0: "CLEANUP_POLICY_UNSPECIFIED",
		1: "CLEANUP_POLICY_DELETE",
		2: "CLEANUP_POLICY_COMPACT",
		3: "CLEANUP_POLICY_COMPACT_AND_DELETE",
	}
	Topic_CleanupPolicy_value = map[string]int32{
		"CLEANUP_POLICY_UNSPECIFIED":        0,
		"CLEANUP_POLICY_DELETE":             1,
		"CLEANUP_POLICY_COMPACT":            2,
		"CLEANUP_POLICY_COMPACT_AND_DELETE": 3,
	}
)

Enum value maps for TopicCleanupPolicy.

View Source 
var IamCloudSchema = map[string]*schema.Schema{
	"cloud_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamContainerRegistrySchema = map[string]*schema.Schema{
	"registry_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamContainerRepositorySchema = map[string]*schema.Schema{
	"repository_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamDnsZoneSchema = map[string]*schema.Schema{
	"dns_zone_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamFolderSchema = map[string]*schema.Schema{
	"folder_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamFunctionSchema = map[string]*schema.Schema{
	"function_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamGroupSchema = map[string]*schema.Schema{
	"group_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamKMSAsymmetricEncryptionKeySchema = map[string]*schema.Schema{
	"asymmetric_encryption_key_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamKMSAsymmetricSignatureKeySchema = map[string]*schema.Schema{
	"asymmetric_signature_key_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamKMSSymmetricKeySchema = map[string]*schema.Schema{
	"symmetric_key_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamLockboxSecretSchema = map[string]*schema.Schema{
	"secret_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamMemberBaseSchema = map[string]*schema.Schema{
	"role": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
	"member": {
		Type:         schema.TypeString,
		Required:     true,
		ForceNew:     true,
		ValidateFunc: validateIamMember,
	},

	"sleep_after": {
		Type:     schema.TypeInt,
		Optional: true,
		ForceNew: true,
	},
}
View Source 
var IamOrganizationSchema = map[string]*schema.Schema{
	"organization_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamPolicyBaseSchema = map[string]*schema.Schema{
	"policy_data": {
		Type:             schema.TypeString,
		Required:         true,
		DiffSuppressFunc: shouldSuppressDiffForPolicies,
		ValidateFunc:     validateIamPolicy,
	},
}
View Source 
var IamServerlessContainerSchema = map[string]*schema.Schema{
	"container_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamServiceAccountSchema = map[string]*schema.Schema{
	"service_account_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}
View Source 
var IamYDBDatabaseSchema = map[string]*schema.Schema{
	"database_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}

Functions

func AllowHostsSortedToStr added in v0.99.0 

func AllowHostsSortedToStr(allowHosts []string) string

func CaseInsensitive added in v0.81.0 

func CaseInsensitive(_, old, new string, _ *schema.ResourceData) bool

func ChartWidgetVisualizationSettingsColorSchemeSettingsAutomaticColorScheme added in v0.88.0 

func ChartWidgetVisualizationSettingsColorSchemeSettingsAutomaticColorScheme(v *monitoring.ChartWidget_VisualizationSettings_ColorSchemeSettings_AutomaticColorScheme) ([]map[string]interface{}, error)

func ChartWidgetVisualizationSettingsColorSchemeSettingsGradientColorScheme added in v0.88.0 

func ChartWidgetVisualizationSettingsColorSchemeSettingsGradientColorScheme(v *monitoring.ChartWidget_VisualizationSettings_ColorSchemeSettings_GradientColorScheme) ([]map[string]interface{}, error)

func ChartWidgetVisualizationSettingsColorSchemeSettingsStandardColorScheme added in v0.88.0 

func ChartWidgetVisualizationSettingsColorSchemeSettingsStandardColorScheme(v *monitoring.ChartWidget_VisualizationSettings_ColorSchemeSettings_StandardColorScheme) ([]map[string]interface{}, error)

func ConvertableToInt added in v0.63.0 

func ConvertableToInt() schema.SchemaValidateFunc

func DestroyOutputToLockboxVersion added in v0.129.0 

func DestroyOutputToLockboxVersion(ctx context.Context, d *schema.ResourceData, config *Config) error

DestroyOutputToLockboxVersion destroys the Lockbox version if output_to_lockbox is being used. Should be called in the resource Delete method.

func ExtendWithOutputToLockbox added in v0.127.0 

func ExtendWithOutputToLockbox(resourceSchema map[string]*schema.Schema, sensitiveAttrs []string) map[string]*schema.Schema

ExtendWithOutputToLockbox adds output_to_lockbox attributes, used by ManageOutputToLockbox

func FloatAtLeast added in v0.5.2 

func FloatAtLeast(min float64) schema.SchemaValidateFunc

FloatAtLeast returns a SchemaValidateFunc which tests if the provided value is of type float64 and is at least min (inclusive)

func FloatGreater added in v0.44.0 

func FloatGreater(min float64) schema.SchemaValidateFunc

FloatAtLeast returns a SchemaValidateFunc which tests if the provided value is of type float64 and is greater than provided min (not inclusive)

func IntGreater added in v0.44.0 

func IntGreater(min int) schema.SchemaValidateFunc

IntGreater returns a SchemaValidateFunc which tests if the provided value is of type int and is greater than provided min (not inclusive)

func IterateKeys added in v0.72.0 

func IterateKeys(d *schema.ResourceData, key string) []string

func LockboxSecretIDParseFunc added in v0.92.0 

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

func ManageOutputToLockbox added in v0.127.0 

func ManageOutputToLockbox(ctx context.Context, d *schema.ResourceData, config *Config, sensitiveAttrs []string) error

ManageOutputToLockbox moves sensitive values between state and Lockbox. If output_to_lockbox is removed: restores the sensitive attributes from the Lockbox secret (and destroys the secret version). If output_to_lockbox is added: moves sensitive attributes to a Lockbox secret (adds a secret version), and removes the sensitive values from the state. If output_to_lockbox is modified: it's equivalent to remove it and then add it (old version will be destroyed, and a new version will be added).

This method should be called at the end of the resource Create and Updated methods (e.g. just after calling Read). If both Create and Updated methods call Read, then we could call ManageOutputToLockbox at the end of the Read method.

func Map added in v0.107.0 

func Map[F, T any](s []F, f func(F) T) []T

func Min added in v0.79.0 

func Min(x, y int64) int64

Min returns the smaller of x or y.

func NewSDKProvider added in v0.97.0 

func NewSDKProvider() *schema.Provider

func NormalizeJsonString added in v0.55.0 

func NormalizeJsonString(jsonString interface{}) (string, error)

func UserPermissionsToStr added in v0.99.0 

func UserPermissionsToStr(permissions []*kafka.Permission) string

func WebsiteDomainURL added in v0.44.0 

func WebsiteDomainURL() string

func WithImporter added in v0.94.0 

func WithImporter(importer *schema.ResourceImporter) func(resource *schema.Resource)

func WithTimeout added in v0.94.0 

func WithTimeout(timeout *schema.ResourceTimeout) func(*schema.Resource)

func ZipPathToBytes added in v0.44.0 

func ZipPathToBytes(root string) ([]byte, error)

Types

type AwsCode added in v0.129.0 

type AwsCode string
const (
	AwsNoSuchBucket                                   AwsCode = s3.ErrCodeNoSuchBucket
	AwsAccessDenied                                   AwsCode = "AccessDenied"
	AwsForbidden                                      AwsCode = "Forbidden"
	AwsMalformedPolicy                                AwsCode = "MalformedPolicy"
	AwsOperationAborted                               AwsCode = "OperationAborted"
	AwsBucketNotEmpty                                 AwsCode = "BucketNotEmpty"
	AwsNoSuchBucketPolicy                             AwsCode = "NoSuchBucketPolicy"
	AwsNoSuchCORSConfiguration                        AwsCode = "NoSuchCORSConfiguration"
	AwsNotImplemented                                 AwsCode = "NotImplemented"
	AwsNoSuchWebsiteConfiguration                     AwsCode = "NoSuchWebsiteConfiguration"
	AwsObjectLockConfigurationNotFoundError           AwsCode = "ObjectLockConfigurationNotFoundError"
	AwsNoSuchLifecycleConfiguration                   AwsCode = "NoSuchLifecycleConfiguration"
	AwsServerSideEncryptionConfigurationNotFoundError AwsCode = "ServerSideEncryptionConfigurationNotFoundError"
	AwsNoSuchEncryptionConfiguration                  AwsCode = "NoSuchEncryptionConfiguration"
)

type CloudIamUpdater 

type CloudIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*CloudIamUpdater) DescribeResource 

func (u *CloudIamUpdater) DescribeResource() string

func (*CloudIamUpdater) GetMutexKey 

func (u *CloudIamUpdater) GetMutexKey() string

func (*CloudIamUpdater) GetResourceID 

func (u *CloudIamUpdater) GetResourceID() string

func (*CloudIamUpdater) GetResourceIamPolicy 

func (u *CloudIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*CloudIamUpdater) SetResourceIamPolicy 

func (u *CloudIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*CloudIamUpdater) UpdateResourceIamPolicy added in v0.94.0 

func (u *CloudIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type Config 

type Config struct {
	Endpoint                       string
	FolderID                       string
	CloudID                        string
	OrganizationID                 string
	Zone                           string
	Token                          string
	ServiceAccountKeyFileOrContent string
	Plaintext                      bool
	Insecure                       bool
	MaxRetries                     int
	StorageEndpoint                string
	YMQEndpoint                    string
	Region                         string

	// These storage access keys are optional and only used when
	// storage data/resource doesn't have own access keys explicitly specified.
	StorageAccessKey string
	StorageSecretKey string

	// These YMQ access keys are optional and only used when
	// Message Queue resource doesn't have own access keys explicitly specified.
	YMQAccessKey string
	YMQSecretKey string

	SharedCredentialsFile string
	Profile               string
	// contains filtered or unexported fields
}

func (*Config) Context added in v0.44.0 

func (c *Config) Context() context.Context

this function return context with added client trace id

func (*Config) ContextWithTimeout added in v0.44.0 

func (c *Config) ContextWithTimeout(timeout time.Duration) (context.Context, context.CancelFunc)

this function returns context with client trace id AND timeout

type ContainerRegistryIamUpdater added in v0.50.0 

type ContainerRegistryIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*ContainerRegistryIamUpdater) DescribeResource added in v0.50.0 

func (u *ContainerRegistryIamUpdater) DescribeResource() string

func (*ContainerRegistryIamUpdater) GetMutexKey added in v0.50.0 

func (u *ContainerRegistryIamUpdater) GetMutexKey() string

func (*ContainerRegistryIamUpdater) GetResourceID added in v0.50.0 

func (u *ContainerRegistryIamUpdater) GetResourceID() string

func (*ContainerRegistryIamUpdater) GetResourceIamPolicy added in v0.50.0 

func (u *ContainerRegistryIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*ContainerRegistryIamUpdater) SetResourceIamPolicy added in v0.50.0 

func (u *ContainerRegistryIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*ContainerRegistryIamUpdater) UpdateResourceIamPolicy added in v0.94.0 

func (u *ContainerRegistryIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type ContainerRepositoryIamUpdater added in v0.52.0 

type ContainerRepositoryIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*ContainerRepositoryIamUpdater) DescribeResource added in v0.52.0 

func (u *ContainerRepositoryIamUpdater) DescribeResource() string

func (*ContainerRepositoryIamUpdater) GetMutexKey added in v0.52.0 

func (u *ContainerRepositoryIamUpdater) GetMutexKey() string

func (*ContainerRepositoryIamUpdater) GetResourceID added in v0.52.0 

func (u *ContainerRepositoryIamUpdater) GetResourceID() string

func (*ContainerRepositoryIamUpdater) GetResourceIamPolicy added in v0.52.0 

func (u *ContainerRepositoryIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*ContainerRepositoryIamUpdater) SetResourceIamPolicy added in v0.52.0 

func (u *ContainerRepositoryIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*ContainerRepositoryIamUpdater) UpdateResourceIamPolicy added in v0.94.0 

func (u *ContainerRepositoryIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type DnsZoneIamUpdater added in v0.110.0 

type DnsZoneIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*DnsZoneIamUpdater) DescribeResource added in v0.110.0 

func (u *DnsZoneIamUpdater) DescribeResource() string

func (*DnsZoneIamUpdater) GetMutexKey added in v0.110.0 

func (u *DnsZoneIamUpdater) GetMutexKey() string

func (*DnsZoneIamUpdater) GetResourceID added in v0.110.0 

func (u *DnsZoneIamUpdater) GetResourceID() string

func (*DnsZoneIamUpdater) GetResourceIamPolicy added in v0.110.0 

func (u *DnsZoneIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*DnsZoneIamUpdater) SetResourceIamPolicy added in v0.110.0 

func (u *DnsZoneIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*DnsZoneIamUpdater) UpdateResourceIamPolicy added in v0.110.0 

func (u *DnsZoneIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type ElasticsearchHost added in v0.60.0 

type ElasticsearchHost struct {
	Name     string
	Type     elasticsearch.Host_Type
	Fqdn     string
	Zone     string
	Subnet   string
	PublicIp bool
}

type ElasticsearchHostList added in v0.60.0 

type ElasticsearchHostList []*ElasticsearchHost

func (ElasticsearchHostList) CountMasters added in v0.62.0 

func (l ElasticsearchHostList) CountMasters() int

func (ElasticsearchHostList) HasMasters added in v0.62.0 

func (l ElasticsearchHostList) HasMasters() bool

func (*ElasticsearchHostList) RemoveBy added in v0.60.0 

func (l *ElasticsearchHostList) RemoveBy(p ElasticsearchHostPredicateFunc) (*ElasticsearchHost, bool)

func (*ElasticsearchHostList) RemoveByFQDN added in v0.60.0 

func (l *ElasticsearchHostList) RemoveByFQDN(fqdn string) (*ElasticsearchHost, bool)

func (*ElasticsearchHostList) RemoveByName added in v0.60.0 

func (l *ElasticsearchHostList) RemoveByName(name string) (*ElasticsearchHost, bool)

type ElasticsearchHostPredicateFunc added in v0.60.0 

type ElasticsearchHostPredicateFunc func(h *ElasticsearchHost) bool

type FolderIamUpdater 

type FolderIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*FolderIamUpdater) DescribeResource 

func (u *FolderIamUpdater) DescribeResource() string

func (*FolderIamUpdater) GetMutexKey 

func (u *FolderIamUpdater) GetMutexKey() string

func (*FolderIamUpdater) GetResourceID 

func (u *FolderIamUpdater) GetResourceID() string

func (*FolderIamUpdater) GetResourceIamPolicy 

func (u *FolderIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*FolderIamUpdater) SetResourceIamPolicy 

func (u *FolderIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*FolderIamUpdater) UpdateResourceIamPolicy added in v0.94.0 

func (u *FolderIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type FunctionIamUpdater added in v0.44.0 

type FunctionIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*FunctionIamUpdater) DescribeResource added in v0.44.0 

func (u *FunctionIamUpdater) DescribeResource() string

func (*FunctionIamUpdater) GetMutexKey added in v0.44.0 

func (u *FunctionIamUpdater) GetMutexKey() string

func (*FunctionIamUpdater) GetResourceID added in v0.44.0 

func (u *FunctionIamUpdater) GetResourceID() string

func (*FunctionIamUpdater) GetResourceIamPolicy added in v0.44.0 

func (u *FunctionIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*FunctionIamUpdater) SetResourceIamPolicy added in v0.44.0 

func (u *FunctionIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*FunctionIamUpdater) UpdateResourceIamPolicy added in v0.94.0 

func (u *FunctionIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type GroupIamUpdater added in v0.80.0 

type GroupIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*GroupIamUpdater) DescribeResource added in v0.80.0 

func (u *GroupIamUpdater) DescribeResource() string

func (*GroupIamUpdater) GetMutexKey added in v0.80.0 

func (u *GroupIamUpdater) GetMutexKey() string

func (*GroupIamUpdater) GetResourceID added in v0.80.0 

func (u *GroupIamUpdater) GetResourceID() string

func (*GroupIamUpdater) GetResourceIamPolicy added in v0.80.0 

func (u *GroupIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*GroupIamUpdater) SetResourceIamPolicy added in v0.80.0 

func (u *GroupIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*GroupIamUpdater) UpdateResourceIamPolicy added in v0.94.0 

func (u *GroupIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type HostUpdateInfo added in v0.76.0 

type HostUpdateInfo struct {
	HostName        string
	ReplicaPriority *wrappers.Int64Value
	AssignPublicIp  bool
	UpdateMask      *field_mask.FieldMask
}

type KMSAsymmetricEncryptionKeyIamUpdater added in v0.95.0 

type KMSAsymmetricEncryptionKeyIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*KMSAsymmetricEncryptionKeyIamUpdater) DescribeResource added in v0.95.0 

func (u *KMSAsymmetricEncryptionKeyIamUpdater) DescribeResource() string

func (*KMSAsymmetricEncryptionKeyIamUpdater) GetMutexKey added in v0.95.0 

func (u *KMSAsymmetricEncryptionKeyIamUpdater) GetMutexKey() string

func (*KMSAsymmetricEncryptionKeyIamUpdater) GetResourceID added in v0.95.0 

func (u *KMSAsymmetricEncryptionKeyIamUpdater) GetResourceID() string

func (*KMSAsymmetricEncryptionKeyIamUpdater) GetResourceIamPolicy added in v0.95.0 

func (u *KMSAsymmetricEncryptionKeyIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*KMSAsymmetricEncryptionKeyIamUpdater) SetResourceIamPolicy added in v0.95.0 

func (u *KMSAsymmetricEncryptionKeyIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*KMSAsymmetricEncryptionKeyIamUpdater) UpdateResourceIamPolicy added in v0.95.0 

func (u *KMSAsymmetricEncryptionKeyIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type KMSAsymmetricSignatureKeyIamUpdater added in v0.95.0 

type KMSAsymmetricSignatureKeyIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*KMSAsymmetricSignatureKeyIamUpdater) DescribeResource added in v0.95.0 

func (u *KMSAsymmetricSignatureKeyIamUpdater) DescribeResource() string

func (*KMSAsymmetricSignatureKeyIamUpdater) GetMutexKey added in v0.95.0 

func (u *KMSAsymmetricSignatureKeyIamUpdater) GetMutexKey() string

func (*KMSAsymmetricSignatureKeyIamUpdater) GetResourceID added in v0.95.0 

func (u *KMSAsymmetricSignatureKeyIamUpdater) GetResourceID() string

func (*KMSAsymmetricSignatureKeyIamUpdater) GetResourceIamPolicy added in v0.95.0 

func (u *KMSAsymmetricSignatureKeyIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*KMSAsymmetricSignatureKeyIamUpdater) SetResourceIamPolicy added in v0.95.0 

func (u *KMSAsymmetricSignatureKeyIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*KMSAsymmetricSignatureKeyIamUpdater) UpdateResourceIamPolicy added in v0.95.0 

func (u *KMSAsymmetricSignatureKeyIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type KMSSymmetricKeyIamUpdater added in v0.65.0 

type KMSSymmetricKeyIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*KMSSymmetricKeyIamUpdater) DescribeResource added in v0.65.0 

func (u *KMSSymmetricKeyIamUpdater) DescribeResource() string

func (*KMSSymmetricKeyIamUpdater) GetMutexKey added in v0.65.0 

func (u *KMSSymmetricKeyIamUpdater) GetMutexKey() string

func (*KMSSymmetricKeyIamUpdater) GetResourceID added in v0.65.0 

func (u *KMSSymmetricKeyIamUpdater) GetResourceID() string

func (*KMSSymmetricKeyIamUpdater) GetResourceIamPolicy added in v0.65.0 

func (u *KMSSymmetricKeyIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*KMSSymmetricKeyIamUpdater) SetResourceIamPolicy added in v0.65.0 

func (u *KMSSymmetricKeyIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*KMSSymmetricKeyIamUpdater) UpdateResourceIamPolicy added in v0.94.0 

func (u *KMSSymmetricKeyIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type KafkaConfig added in v0.63.0 

type KafkaConfig struct {
	CompressionType             kafka.CompressionType
	LogFlushIntervalMessages    *wrappers.Int64Value
	LogFlushIntervalMs          *wrappers.Int64Value
	LogFlushSchedulerIntervalMs *wrappers.Int64Value
	LogRetentionBytes           *wrappers.Int64Value
	LogRetentionHours           *wrappers.Int64Value
	LogRetentionMinutes         *wrappers.Int64Value
	LogRetentionMs              *wrappers.Int64Value
	LogSegmentBytes             *wrappers.Int64Value
	LogPreallocate              *wrappers.BoolValue
	SocketSendBufferBytes       *wrappers.Int64Value
	SocketReceiveBufferBytes    *wrappers.Int64Value
	AutoCreateTopicsEnable      *wrappers.BoolValue
	NumPartitions               *wrappers.Int64Value
	DefaultReplicationFactor    *wrappers.Int64Value
	MessageMaxBytes             *wrappers.Int64Value
	ReplicaFetchMaxBytes        *wrappers.Int64Value
	SslCipherSuites             []string
	OffsetsRetentionMinutes     *wrappers.Int64Value
	SaslEnabledMechanisms       []kafka.SaslMechanism
}

type KafkaConfigSettings added in v0.63.0 

type KafkaConfigSettings interface {
	GetCompressionType() kafka.CompressionType
	GetLogFlushIntervalMessages() *wrappers.Int64Value
	GetLogFlushIntervalMs() *wrappers.Int64Value
	GetLogFlushSchedulerIntervalMs() *wrappers.Int64Value
	GetLogRetentionBytes() *wrappers.Int64Value
	GetLogRetentionHours() *wrappers.Int64Value
	GetLogRetentionMinutes() *wrappers.Int64Value
	GetLogRetentionMs() *wrappers.Int64Value
	GetLogSegmentBytes() *wrappers.Int64Value
	GetLogPreallocate() *wrappers.BoolValue
	GetSocketSendBufferBytes() *wrappers.Int64Value
	GetSocketReceiveBufferBytes() *wrappers.Int64Value
	GetAutoCreateTopicsEnable() *wrappers.BoolValue
	GetNumPartitions() *wrappers.Int64Value
	GetDefaultReplicationFactor() *wrappers.Int64Value
	GetMessageMaxBytes() *wrappers.Int64Value
	GetReplicaFetchMaxBytes() *wrappers.Int64Value
	GetSslCipherSuites() []string
	GetOffsetsRetentionMinutes() *wrappers.Int64Value
	GetSaslEnabledMechanisms() []kafka.SaslMechanism
}

type KafkaTopicManager added in v0.72.0 

type KafkaTopicManager struct {
	Config *Config
}

func NewKafkaTopicManager added in v0.72.0 

func NewKafkaTopicManager(config *Config) *KafkaTopicManager

func (*KafkaTopicManager) CreateKafkaTopic added in v0.72.0 

func (tm *KafkaTopicManager) CreateKafkaTopic(ctx context.Context, d *schema.ResourceData, topicSpec *kafka.TopicSpec) error

func (*KafkaTopicManager) DeleteKafkaTopic added in v0.72.0 

func (tm *KafkaTopicManager) DeleteKafkaTopic(ctx context.Context, d *schema.ResourceData, topicName string) error

func (*KafkaTopicManager) UpdateKafkaTopic added in v0.72.0 

func (tm *KafkaTopicManager) UpdateKafkaTopic(ctx context.Context, d *schema.ResourceData, topicSpec *kafka.TopicSpec, paths []string) error

type KafkaTopicModifier added in v0.72.0 

type KafkaTopicModifier interface {
	CreateKafkaTopic(ctx context.Context, d *schema.ResourceData, topicSpec *kafka.TopicSpec) error
	DeleteKafkaTopic(ctx context.Context, d *schema.ResourceData, topicName string) error
	UpdateKafkaTopic(ctx context.Context, d *schema.ResourceData, topicSpec *kafka.TopicSpec, paths []string) error
}

type LockboxSecretIamUpdater added in v0.92.0 

type LockboxSecretIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*LockboxSecretIamUpdater) DescribeResource added in v0.92.0 

func (u *LockboxSecretIamUpdater) DescribeResource() string

func (*LockboxSecretIamUpdater) GetMutexKey added in v0.92.0 

func (u *LockboxSecretIamUpdater) GetMutexKey() string

func (*LockboxSecretIamUpdater) GetResourceID added in v0.92.0 

func (u *LockboxSecretIamUpdater) GetResourceID() string

func (*LockboxSecretIamUpdater) GetResourceIamPolicy added in v0.92.0 

func (u *LockboxSecretIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*LockboxSecretIamUpdater) SetResourceIamPolicy added in v0.92.0 

func (u *LockboxSecretIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*LockboxSecretIamUpdater) UpdateResourceIamPolicy added in v0.94.0 

func (u *LockboxSecretIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type MongodbSpecHelper added in v0.74.0 

type MongodbSpecHelper struct {
	FlattenResources           func(c *mongodb.ClusterConfig, d *schema.ResourceData) (map[string]interface{}, error)
	FlattenDiskSizeAutoscaling func(c *mongodb.ClusterConfig, d *schema.ResourceData) (map[string]interface{}, error)
	FlattenMongod              func(c *mongodb.ClusterConfig, d *schema.ResourceData) ([]map[string]interface{}, error)
	FlattenMongos              func(c *mongodb.ClusterConfig, d *schema.ResourceData) ([]map[string]interface{}, error)
	FlattenMongocfg            func(c *mongodb.ClusterConfig, d *schema.ResourceData) ([]map[string]interface{}, error)
	Expand                     func(d *schema.ResourceData) *mongodb.MongodbSpec
}

func GetMongodbSpecHelper added in v0.74.0 

func GetMongodbSpecHelper() *MongodbSpecHelper

type MySQLHostSpec added in v0.44.0 

type MySQLHostSpec struct {
	HostSpec              *mysql.HostSpec
	Fqdn                  string
	Name                  string
	ReplicationSourceName string
	Priority              int64
	BackupPriority        int64
}

type OrganizationIamUpdater added in v0.62.0 

type OrganizationIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*OrganizationIamUpdater) DescribeResource added in v0.62.0 

func (u *OrganizationIamUpdater) DescribeResource() string

func (*OrganizationIamUpdater) GetMutexKey added in v0.62.0 

func (u *OrganizationIamUpdater) GetMutexKey() string

func (*OrganizationIamUpdater) GetResourceID added in v0.62.0 

func (u *OrganizationIamUpdater) GetResourceID() string

func (*OrganizationIamUpdater) GetResourceIamPolicy added in v0.62.0 

func (u *OrganizationIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*OrganizationIamUpdater) SetResourceIamPolicy added in v0.62.0 

func (u *OrganizationIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*OrganizationIamUpdater) UpdateResourceIamPolicy added in v0.94.0 

func (u *OrganizationIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type Policy 

type Policy struct {
	Bindings []*access.AccessBinding
}

func (Policy) String 

func (p Policy) String() string

type PolicyDelta added in v0.94.0 

type PolicyDelta struct {
	Deltas []*access.AccessBindingDelta
}

type PostgreSQLHostSpec added in v0.44.0 

type PostgreSQLHostSpec struct {
	HostSpec *postgresql.HostSpec
	Fqdn     string
}

type Profile added in v0.96.0 

type Profile = string

type RawCredentials added in v0.96.0 

type RawCredentials = map[string]string

type ReducedDiskServiceClient 

type ReducedDiskServiceClient interface {
	Get(ctx context.Context, in *compute.GetDiskRequest, opts ...grpc.CallOption) (*compute.Disk, error)
}

type ResourceIamUpdater 

type ResourceIamUpdater interface {
	// GetResourceIamPolicy Fetch the existing IAM policy attached to a resource.
	GetResourceIamPolicy(ctx context.Context) (*Policy, error)

	// SetResourceIamPolicy Replaces the existing IAM Policy attached to a resource.
	// Useful for `iam_binding` and `iam_policy` resources
	SetResourceIamPolicy(ctx context.Context, policy *Policy) error

	// UpdateResourceIamPolicy Updates the existing IAM Policy attached to a resource.
	// Useful for `iam_member` resources
	UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

	// GetMutexKey A mutex guards against concurrent call to the SetResourceIamPolicy method.
	// The mutex key should be made of the resource type and resource id.
	// For example: `iam-folder-{id}`.
	GetMutexKey() string

	// GetResourceID Returns the unique resource identifier.
	GetResourceID() string

	// DescribeResource Textual description of this resource to be used in error message.
	// The description should include the unique resource identifier.
	DescribeResource() string
}

type S3Website added in v0.44.0 

type S3Website struct {
	Endpoint, Domain string
}

func WebsiteEndpoint added in v0.44.0 

func WebsiteEndpoint(bucket string) *S3Website

type SchemaOption added in v0.94.0 

type SchemaOption func(timeouts *schema.Resource)

type ServerlessContainerIamUpdater added in v0.77.0 

type ServerlessContainerIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*ServerlessContainerIamUpdater) DescribeResource added in v0.77.0 

func (u *ServerlessContainerIamUpdater) DescribeResource() string

func (*ServerlessContainerIamUpdater) GetMutexKey added in v0.77.0 

func (u *ServerlessContainerIamUpdater) GetMutexKey() string

func (*ServerlessContainerIamUpdater) GetResourceID added in v0.77.0 

func (u *ServerlessContainerIamUpdater) GetResourceID() string

func (*ServerlessContainerIamUpdater) GetResourceIamPolicy added in v0.77.0 

func (u *ServerlessContainerIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*ServerlessContainerIamUpdater) SetResourceIamPolicy added in v0.77.0 

func (u *ServerlessContainerIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*ServerlessContainerIamUpdater) UpdateResourceIamPolicy added in v0.94.0 

func (u *ServerlessContainerIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type ServiceAccountIamUpdater 

type ServiceAccountIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*ServiceAccountIamUpdater) DescribeResource 

func (u *ServiceAccountIamUpdater) DescribeResource() string

func (*ServiceAccountIamUpdater) GetMutexKey 

func (u *ServiceAccountIamUpdater) GetMutexKey() string

func (*ServiceAccountIamUpdater) GetResourceID 

func (u *ServiceAccountIamUpdater) GetResourceID() string

func (*ServiceAccountIamUpdater) GetResourceIamPolicy 

func (u *ServiceAccountIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*ServiceAccountIamUpdater) SetResourceIamPolicy 

func (u *ServiceAccountIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*ServiceAccountIamUpdater) UpdateResourceIamPolicy added in v0.94.0 

func (u *ServiceAccountIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

type SharedCredentials added in v0.96.0 

type SharedCredentials struct {
	StorageAccessKey string
	StorageSecretKey string
}

func (*SharedCredentials) HasStorageAccessKeys added in v0.96.0 

func (p *SharedCredentials) HasStorageAccessKeys() bool

type SharedCredentialsProvider added in v0.96.0 

type SharedCredentialsProvider struct {
	// Path to the shared credentials file.
	Filename string

	// YC Profile to extract credentials from the shared credentials file.
	Profile string
}

A SharedCredentialsProvider retrieves credentials for the selected profile from the given file.

func (*SharedCredentialsProvider) Retrieve added in v0.96.0 

func (p *SharedCredentialsProvider) Retrieve() (*SharedCredentials, error)

Retrieve reads and extracts the credentials for the selected profile from the given file.

type TopicCleanupPolicy added in v0.49.0 

type TopicCleanupPolicy int32
const (
	Topic_CLEANUP_POLICY_UNSPECIFIED TopicCleanupPolicy = 0
	// this policy discards log segments when either their retention time or log size limit is reached. See also: [KafkaConfig2_8.log_retention_ms] and other similar parameters.
	Topic_CLEANUP_POLICY_DELETE TopicCleanupPolicy = 1
	// this policy compacts messages in log.
	Topic_CLEANUP_POLICY_COMPACT TopicCleanupPolicy = 2
	// this policy use both compaction and deletion for messages and log segments.
	Topic_CLEANUP_POLICY_COMPACT_AND_DELETE TopicCleanupPolicy = 3
)

type TopicConfig added in v0.63.0 

type TopicConfig struct {
	CleanupPolicy      string
	CompressionType    kafka.CompressionType
	DeleteRetentionMs  *wrappers.Int64Value
	FileDeleteDelayMs  *wrappers.Int64Value
	FlushMessages      *wrappers.Int64Value
	FlushMs            *wrappers.Int64Value
	MinCompactionLagMs *wrappers.Int64Value
	RetentionBytes     *wrappers.Int64Value
	RetentionMs        *wrappers.Int64Value
	MaxMessageBytes    *wrappers.Int64Value
	MinInsyncReplicas  *wrappers.Int64Value
	SegmentBytes       *wrappers.Int64Value
	Preallocate        *wrappers.BoolValue
}

type TopicConfigSpec added in v0.63.0 

type TopicConfigSpec interface {
	GetCompressionType() kafka.CompressionType
	GetDeleteRetentionMs() *wrappers.Int64Value
	GetFileDeleteDelayMs() *wrappers.Int64Value
	GetFlushMessages() *wrappers.Int64Value
	GetFlushMs() *wrappers.Int64Value
	GetMinCompactionLagMs() *wrappers.Int64Value
	GetRetentionBytes() *wrappers.Int64Value
	GetRetentionMs() *wrappers.Int64Value
	GetMaxMessageBytes() *wrappers.Int64Value
	GetMinInsyncReplicas() *wrappers.Int64Value
	GetSegmentBytes() *wrappers.Int64Value
	GetPreallocate() *wrappers.BoolValue
}

type Wrapper added in v0.123.0 

type Wrapper[V any, T any] interface {
	GetValue() V
	*T
}

type YDBDatabaseIamUpdater added in v0.77.0 

type YDBDatabaseIamUpdater struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*YDBDatabaseIamUpdater) DescribeResource added in v0.77.0 

func (u *YDBDatabaseIamUpdater) DescribeResource() string

func (*YDBDatabaseIamUpdater) GetMutexKey added in v0.77.0 

func (u *YDBDatabaseIamUpdater) GetMutexKey() string

func (*YDBDatabaseIamUpdater) GetResourceID added in v0.77.0 

func (u *YDBDatabaseIamUpdater) GetResourceID() string

func (*YDBDatabaseIamUpdater) GetResourceIamPolicy added in v0.77.0 

func (u *YDBDatabaseIamUpdater) GetResourceIamPolicy(ctx context.Context) (*Policy, error)

func (*YDBDatabaseIamUpdater) SetResourceIamPolicy added in v0.77.0 

func (u *YDBDatabaseIamUpdater) SetResourceIamPolicy(ctx context.Context, policy *Policy) error

func (*YDBDatabaseIamUpdater) UpdateResourceIamPolicy added in v0.94.0 

func (u *YDBDatabaseIamUpdater) UpdateResourceIamPolicy(ctx context.Context, policy *PolicyDelta) error

Source Files

View all Source files

Directories

Path Synopsis
internal
encryption
hashcode
vault/helper/pgpkeys
vault/sdk/helper/compressutil
vault/sdk/helper/jsonutil
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.

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.