yandex

package
v0.96.1 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2023 License: MPL-2.0 Imports: 132 Imported by: 8

Documentation

Overview

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 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)
)
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 ErrUnknownGreenplumVersion = func(version string) error {
	return fmt.Errorf("unknown Greenplum version %s but '6.19' and '6.22' are only available", version)
}
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 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 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 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 Min added in v0.79.0 

func Min(x, y int64) int64

Min returns the smaller of x or y.

func NormalizeJsonString added in v0.55.0 

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

func Provider 

func Provider() *schema.Provider

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 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 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)
	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.ConfigSpec_MongodbSpec
}

func GetMongodbSpecHelper added in v0.74.0 

func GetMongodbSpecHelper(version string) *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 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
mutexkv
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.