yandex

package
v0.63.0 Latest Latest
Warning

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

 Go to latest Published: Sep 7, 2021 License: MPL-2.0 Imports: 101 Imported by: 8

Documentation

Index

Constants

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 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 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 IamServiceAccountSchema = map[string]*schema.Schema{
	"service_account_id": {
		Type:     schema.TypeString,
		Required: true,
		ForceNew: true,
	},
}

Functions

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

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

func Provider 

func Provider() terraform.ResourceProvider

func WebsiteDomainURL added in v0.44.0 

func WebsiteDomainURL() string

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() (*Policy, error)

func (*CloudIamUpdater) SetResourceIamPolicy 

func (u *CloudIamUpdater) SetResourceIamPolicy(policy *Policy) error

type Config 

type Config struct {
	Endpoint                       string
	FolderID                       string
	CloudID                        string
	Zone                           string
	Token                          string
	ServiceAccountKeyFileOrContent string
	Plaintext                      bool
	Insecure                       bool
	MaxRetries                     int
	StorageEndpoint                string
	YMQEndpoint                    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
	// 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() (*Policy, error)

func (*ContainerRegistryIamUpdater) SetResourceIamPolicy added in v0.50.0 

func (u *ContainerRegistryIamUpdater) SetResourceIamPolicy(policy *Policy) 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() (*Policy, error)

func (*ContainerRepositoryIamUpdater) SetResourceIamPolicy added in v0.52.0 

func (u *ContainerRepositoryIamUpdater) SetResourceIamPolicy(policy *Policy) 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() (*Policy, error)

func (*FolderIamUpdater) SetResourceIamPolicy 

func (u *FolderIamUpdater) SetResourceIamPolicy(policy *Policy) 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() (*Policy, error)

func (*FunctionIamUpdater) SetResourceIamPolicy added in v0.44.0 

func (u *FunctionIamUpdater) SetResourceIamPolicy(policy *Policy) 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
}

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
}

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() (*Policy, error)

func (*OrganizationIamUpdater) SetResourceIamPolicy added in v0.62.0 

func (u *OrganizationIamUpdater) SetResourceIamPolicy(policy *Policy) error

type Policy 

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

func (Policy) String 

func (p Policy) String() string

type PostgreSQLHostSpec added in v0.44.0 

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

type ReducedDiskServiceClient 

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

type ResourceIamUpdater 

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

	// Replaces the existing IAM Policy attached to a resource.
	SetResourceIamPolicy(policy *Policy) error

	// 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

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

	// 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 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() (*Policy, error)

func (*ServiceAccountIamUpdater) SetResourceIamPolicy 

func (u *ServiceAccountIamUpdater) SetResourceIamPolicy(policy *Policy) error

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_1.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
}

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.