metastorev1

package
v1.36.11-2024050211440... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const MetadataExport_DestinationGcsUri_case case_MetadataExport_Destination = 4
View Source 
const MetadataExport_Destination_not_set_case case_MetadataExport_Destination = 0
View Source 
const MetadataImport_DatabaseDump_case case_MetadataImport_Metadata = 6
View Source 
const MetadataImport_Metadata_not_set_case case_MetadataImport_Metadata = 0
View Source 
const NetworkConfig_Consumer_Subnetwork_case case_NetworkConfig_Consumer_VpcResource = 1
View Source 
const NetworkConfig_Consumer_VpcResource_not_set_case case_NetworkConfig_Consumer_VpcResource = 0
View Source 
const ScalingConfig_InstanceSize_case case_ScalingConfig_ScalingModel = 1
View Source 
const ScalingConfig_ScalingFactor_case case_ScalingConfig_ScalingModel = 2
View Source 
const ScalingConfig_ScalingModel_not_set_case case_ScalingConfig_ScalingModel = 0
View Source 
const Secret_CloudSecret_case case_Secret_Value = 2
View Source 
const Secret_Value_not_set_case case_Secret_Value = 0
View Source 
const Service_HiveMetastoreConfig_case case_Service_MetastoreConfig = 5
View Source 
const Service_MetastoreConfig_not_set_case case_Service_MetastoreConfig = 0

Variables

View Source 
var (
	Federation_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CREATING",
		2: "ACTIVE",
		3: "UPDATING",
		4: "DELETING",
		5: "ERROR",
	}
	Federation_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"CREATING":          1,
		"ACTIVE":            2,
		"UPDATING":          3,
		"DELETING":          4,
		"ERROR":             5,
	}
)

Enum value maps for Federation_State.

View Source 
var (
	BackendMetastore_MetastoreType_name = map[int32]string{
		0: "METASTORE_TYPE_UNSPECIFIED",
		3: "DATAPROC_METASTORE",
	}
	BackendMetastore_MetastoreType_value = map[string]int32{
		"METASTORE_TYPE_UNSPECIFIED": 0,
		"DATAPROC_METASTORE":         3,
	}
)

Enum value maps for BackendMetastore_MetastoreType.

View Source 
var (
	Service_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CREATING",
		2: "ACTIVE",
		3: "SUSPENDING",
		4: "SUSPENDED",
		5: "UPDATING",
		6: "DELETING",
		7: "ERROR",
	}
	Service_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"CREATING":          1,
		"ACTIVE":            2,
		"SUSPENDING":        3,
		"SUSPENDED":         4,
		"UPDATING":          5,
		"DELETING":          6,
		"ERROR":             7,
	}
)

Enum value maps for Service_State.

View Source 
var (
	Service_Tier_name = map[int32]string{
		0: "TIER_UNSPECIFIED",
		1: "DEVELOPER",
		3: "ENTERPRISE",
	}
	Service_Tier_value = map[string]int32{
		"TIER_UNSPECIFIED": 0,
		"DEVELOPER":        1,
		"ENTERPRISE":       3,
	}
)

Enum value maps for Service_Tier.

View Source 
var (
	Service_ReleaseChannel_name = map[int32]string{
		0: "RELEASE_CHANNEL_UNSPECIFIED",
		1: "CANARY",
		2: "STABLE",
	}
	Service_ReleaseChannel_value = map[string]int32{
		"RELEASE_CHANNEL_UNSPECIFIED": 0,
		"CANARY":                      1,
		"STABLE":                      2,
	}
)

Enum value maps for Service_ReleaseChannel.

View Source 
var (
	Service_DatabaseType_name = map[int32]string{
		0: "DATABASE_TYPE_UNSPECIFIED",
		1: "MYSQL",
		2: "SPANNER",
	}
	Service_DatabaseType_value = map[string]int32{
		"DATABASE_TYPE_UNSPECIFIED": 0,
		"MYSQL":                     1,
		"SPANNER":                   2,
	}
)

Enum value maps for Service_DatabaseType.

View Source 
var (
	TelemetryConfig_LogFormat_name = map[int32]string{
		0: "LOG_FORMAT_UNSPECIFIED",
		1: "LEGACY",
		2: "JSON",
	}
	TelemetryConfig_LogFormat_value = map[string]int32{
		"LOG_FORMAT_UNSPECIFIED": 0,
		"LEGACY":                 1,
		"JSON":                   2,
	}
)

Enum value maps for TelemetryConfig_LogFormat.

View Source 
var (
	MetadataImport_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "RUNNING",
		2: "SUCCEEDED",
		3: "UPDATING",
		4: "FAILED",
	}
	MetadataImport_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"RUNNING":           1,
		"SUCCEEDED":         2,
		"UPDATING":          3,
		"FAILED":            4,
	}
)

Enum value maps for MetadataImport_State.

View Source 
var (
	MetadataImport_DatabaseDump_DatabaseType_name = map[int32]string{
		0: "DATABASE_TYPE_UNSPECIFIED",
		1: "MYSQL",
	}
	MetadataImport_DatabaseDump_DatabaseType_value = map[string]int32{
		"DATABASE_TYPE_UNSPECIFIED": 0,
		"MYSQL":                     1,
	}
)

Enum value maps for MetadataImport_DatabaseDump_DatabaseType.

View Source 
var (
	MetadataExport_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "RUNNING",
		2: "SUCCEEDED",
		3: "FAILED",
		4: "CANCELLED",
	}
	MetadataExport_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"RUNNING":           1,
		"SUCCEEDED":         2,
		"FAILED":            3,
		"CANCELLED":         4,
	}
)

Enum value maps for MetadataExport_State.

View Source 
var (
	Backup_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CREATING",
		2: "DELETING",
		3: "ACTIVE",
		4: "FAILED",
		5: "RESTORING",
	}
	Backup_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"CREATING":          1,
		"DELETING":          2,
		"ACTIVE":            3,
		"FAILED":            4,
		"RESTORING":         5,
	}
)

Enum value maps for Backup_State.

View Source 
var (
	Restore_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "RUNNING",
		2: "SUCCEEDED",
		3: "FAILED",
		4: "CANCELLED",
	}
	Restore_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"RUNNING":           1,
		"SUCCEEDED":         2,
		"FAILED":            3,
		"CANCELLED":         4,
	}
)

Enum value maps for Restore_State.

View Source 
var (
	Restore_RestoreType_name = map[int32]string{
		0: "RESTORE_TYPE_UNSPECIFIED",
		1: "FULL",
		2: "METADATA_ONLY",
	}
	Restore_RestoreType_value = map[string]int32{
		"RESTORE_TYPE_UNSPECIFIED": 0,
		"FULL":                     1,
		"METADATA_ONLY":            2,
	}
)

Enum value maps for Restore_RestoreType.

View Source 
var (
	ScalingConfig_InstanceSize_name = map[int32]string{
		0: "INSTANCE_SIZE_UNSPECIFIED",
		1: "EXTRA_SMALL",
		2: "SMALL",
		3: "MEDIUM",
		4: "LARGE",
		5: "EXTRA_LARGE",
	}
	ScalingConfig_InstanceSize_value = map[string]int32{
		"INSTANCE_SIZE_UNSPECIFIED": 0,
		"EXTRA_SMALL":               1,
		"SMALL":                     2,
		"MEDIUM":                    3,
		"LARGE":                     4,
		"EXTRA_LARGE":               5,
	}
)

Enum value maps for ScalingConfig_InstanceSize.

View Source 
var (
	DatabaseDumpSpec_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "MYSQL",
		2: "AVRO",
	}
	DatabaseDumpSpec_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"MYSQL":            1,
		"AVRO":             2,
	}
)

Enum value maps for DatabaseDumpSpec_Type.

View Source 
var File_google_events_cloud_metastore_v1_data_proto protoreflect.FileDescriptor
View Source 
var File_google_events_cloud_metastore_v1_events_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AuxiliaryVersionConfig 

type AuxiliaryVersionConfig struct {

	// The Hive metastore version of the auxiliary service. It must be less
	// than the primary Hive metastore service's version.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// A mapping of Hive metastore configuration key-value pairs to apply to the
	// auxiliary Hive metastore (configured in `hive-site.xml`) in addition to
	// the primary version's overrides. If keys are present in both the auxiliary
	// version's overrides and the primary version's overrides, the value from
	// the auxiliary version's overrides takes precedence.
	ConfigOverrides map[string]string `` /* 180-byte string literal not displayed */
	// Output only. The network configuration contains the endpoint URI(s) of the
	// auxiliary Hive metastore service.
	NetworkConfig *NetworkConfig `protobuf:"bytes,3,opt,name=network_config,json=networkConfig,proto3" json:"network_config,omitempty"`
	// contains filtered or unexported fields
}

Configuration information for the auxiliary service versions.

func (*AuxiliaryVersionConfig) ClearNetworkConfig 

func (x *AuxiliaryVersionConfig) ClearNetworkConfig()

func (*AuxiliaryVersionConfig) GetConfigOverrides 

func (x *AuxiliaryVersionConfig) GetConfigOverrides() map[string]string

func (*AuxiliaryVersionConfig) GetNetworkConfig 

func (x *AuxiliaryVersionConfig) GetNetworkConfig() *NetworkConfig

func (*AuxiliaryVersionConfig) GetVersion 

func (x *AuxiliaryVersionConfig) GetVersion() string

func (*AuxiliaryVersionConfig) HasNetworkConfig 

func (x *AuxiliaryVersionConfig) HasNetworkConfig() bool

func (*AuxiliaryVersionConfig) ProtoMessage 

func (*AuxiliaryVersionConfig) ProtoMessage()

func (*AuxiliaryVersionConfig) ProtoReflect 

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

func (*AuxiliaryVersionConfig) Reset 

func (x *AuxiliaryVersionConfig) Reset()

func (*AuxiliaryVersionConfig) SetConfigOverrides 

func (x *AuxiliaryVersionConfig) SetConfigOverrides(v map[string]string)

func (*AuxiliaryVersionConfig) SetNetworkConfig 

func (x *AuxiliaryVersionConfig) SetNetworkConfig(v *NetworkConfig)

func (*AuxiliaryVersionConfig) SetVersion 

func (x *AuxiliaryVersionConfig) SetVersion(v string)

func (*AuxiliaryVersionConfig) String 

func (x *AuxiliaryVersionConfig) String() string

type AuxiliaryVersionConfig_builder 

type AuxiliaryVersionConfig_builder struct {

	// The Hive metastore version of the auxiliary service. It must be less
	// than the primary Hive metastore service's version.
	Version string
	// A mapping of Hive metastore configuration key-value pairs to apply to the
	// auxiliary Hive metastore (configured in `hive-site.xml`) in addition to
	// the primary version's overrides. If keys are present in both the auxiliary
	// version's overrides and the primary version's overrides, the value from
	// the auxiliary version's overrides takes precedence.
	ConfigOverrides map[string]string
	// Output only. The network configuration contains the endpoint URI(s) of the
	// auxiliary Hive metastore service.
	NetworkConfig *NetworkConfig
	// contains filtered or unexported fields
}

func (AuxiliaryVersionConfig_builder) Build 

func (b0 AuxiliaryVersionConfig_builder) Build() *AuxiliaryVersionConfig

type BackendMetastore 

type BackendMetastore struct {

	// The relative resource name of the metastore that is being federated.
	// The formats of the relative resource names for the currently supported
	// metastores are listed below:
	//
	// * BigQuery
	//   - `projects/{project_id}`
	//
	// * Dataproc Metastore
	//   - `projects/{project_id}/locations/{location}/services/{service_id}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The type of the backend metastore.
	MetastoreType BackendMetastore_MetastoreType `` /* 170-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represents a backend metastore for the federation.

func (*BackendMetastore) GetMetastoreType 

func (x *BackendMetastore) GetMetastoreType() BackendMetastore_MetastoreType

func (*BackendMetastore) GetName 

func (x *BackendMetastore) GetName() string

func (*BackendMetastore) ProtoMessage 

func (*BackendMetastore) ProtoMessage()

func (*BackendMetastore) ProtoReflect 

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

func (*BackendMetastore) Reset 

func (x *BackendMetastore) Reset()

func (*BackendMetastore) SetMetastoreType 

func (x *BackendMetastore) SetMetastoreType(v BackendMetastore_MetastoreType)

func (*BackendMetastore) SetName 

func (x *BackendMetastore) SetName(v string)

func (*BackendMetastore) String 

func (x *BackendMetastore) String() string

type BackendMetastore_MetastoreType 

type BackendMetastore_MetastoreType int32

The type of the backend metastore. 

const (
	// The metastore type is not set.
	BackendMetastore_METASTORE_TYPE_UNSPECIFIED BackendMetastore_MetastoreType = 0
	// The backend metastore is Dataproc Metastore.
	BackendMetastore_DATAPROC_METASTORE BackendMetastore_MetastoreType = 3
)

func (BackendMetastore_MetastoreType) Descriptor 

func (BackendMetastore_MetastoreType) Descriptor() protoreflect.EnumDescriptor

func (BackendMetastore_MetastoreType) Enum 

func (x BackendMetastore_MetastoreType) Enum() *BackendMetastore_MetastoreType

func (BackendMetastore_MetastoreType) Number 

func (x BackendMetastore_MetastoreType) Number() protoreflect.EnumNumber

func (BackendMetastore_MetastoreType) String 

func (x BackendMetastore_MetastoreType) String() string

func (BackendMetastore_MetastoreType) Type 

func (BackendMetastore_MetastoreType) Type() protoreflect.EnumType

type BackendMetastore_builder 

type BackendMetastore_builder struct {

	// The relative resource name of the metastore that is being federated.
	// The formats of the relative resource names for the currently supported
	// metastores are listed below:
	//
	// * BigQuery
	//   - `projects/{project_id}`
	//
	// * Dataproc Metastore
	//   - `projects/{project_id}/locations/{location}/services/{service_id}`
	Name string
	// The type of the backend metastore.
	MetastoreType BackendMetastore_MetastoreType
	// contains filtered or unexported fields
}

func (BackendMetastore_builder) Build 

func (b0 BackendMetastore_builder) Build() *BackendMetastore

type Backup 

type Backup struct {

	// Immutable. The relative resource name of the backup, in the following form:
	//
	// `projects/{project_number}/locations/{location_id}/services/{service_id}/backups/{backup_id}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The time when the backup was started.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time when the backup finished creating.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Output only. The current state of the backup.
	State Backup_State `protobuf:"varint,4,opt,name=state,proto3,enum=google.events.cloud.metastore.v1.Backup_State" json:"state,omitempty"`
	// Output only. The revision of the service at the time of backup.
	ServiceRevision *Service `protobuf:"bytes,5,opt,name=service_revision,json=serviceRevision,proto3" json:"service_revision,omitempty"`
	// The description of the backup.
	Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// Output only. Services that are restoring from the backup.
	RestoringServices []string `protobuf:"bytes,7,rep,name=restoring_services,json=restoringServices,proto3" json:"restoring_services,omitempty"`
	// contains filtered or unexported fields
}

The details of a backup resource.

func (*Backup) ClearCreateTime 

func (x *Backup) ClearCreateTime()

func (*Backup) ClearEndTime 

func (x *Backup) ClearEndTime()

func (*Backup) ClearServiceRevision 

func (x *Backup) ClearServiceRevision()

func (*Backup) GetCreateTime 

func (x *Backup) GetCreateTime() *timestamppb.Timestamp

func (*Backup) GetDescription 

func (x *Backup) GetDescription() string

func (*Backup) GetEndTime 

func (x *Backup) GetEndTime() *timestamppb.Timestamp

func (*Backup) GetName 

func (x *Backup) GetName() string

func (*Backup) GetRestoringServices 

func (x *Backup) GetRestoringServices() []string

func (*Backup) GetServiceRevision 

func (x *Backup) GetServiceRevision() *Service

func (*Backup) GetState 

func (x *Backup) GetState() Backup_State

func (*Backup) HasCreateTime 

func (x *Backup) HasCreateTime() bool

func (*Backup) HasEndTime 

func (x *Backup) HasEndTime() bool

func (*Backup) HasServiceRevision 

func (x *Backup) HasServiceRevision() bool

func (*Backup) ProtoMessage 

func (*Backup) ProtoMessage()

func (*Backup) ProtoReflect 

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

func (*Backup) Reset 

func (x *Backup) Reset()

func (*Backup) SetCreateTime 

func (x *Backup) SetCreateTime(v *timestamppb.Timestamp)

func (*Backup) SetDescription 

func (x *Backup) SetDescription(v string)

func (*Backup) SetEndTime 

func (x *Backup) SetEndTime(v *timestamppb.Timestamp)

func (*Backup) SetName 

func (x *Backup) SetName(v string)

func (*Backup) SetRestoringServices 

func (x *Backup) SetRestoringServices(v []string)

func (*Backup) SetServiceRevision 

func (x *Backup) SetServiceRevision(v *Service)

func (*Backup) SetState 

func (x *Backup) SetState(v Backup_State)

func (*Backup) String 

func (x *Backup) String() string

type BackupCreatedEvent 

type BackupCreatedEvent struct {

	// The data associated with the event.
	Data *BackupEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Backup is created.

func (*BackupCreatedEvent) ClearData 

func (x *BackupCreatedEvent) ClearData()

func (*BackupCreatedEvent) GetData 

func (x *BackupCreatedEvent) GetData() *BackupEventData

func (*BackupCreatedEvent) HasData 

func (x *BackupCreatedEvent) HasData() bool

func (*BackupCreatedEvent) ProtoMessage 

func (*BackupCreatedEvent) ProtoMessage()

func (*BackupCreatedEvent) ProtoReflect 

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

func (*BackupCreatedEvent) Reset 

func (x *BackupCreatedEvent) Reset()

func (*BackupCreatedEvent) SetData 

func (x *BackupCreatedEvent) SetData(v *BackupEventData)

func (*BackupCreatedEvent) String 

func (x *BackupCreatedEvent) String() string

type BackupCreatedEvent_builder 

type BackupCreatedEvent_builder struct {

	// The data associated with the event.
	Data *BackupEventData
	// contains filtered or unexported fields
}

func (BackupCreatedEvent_builder) Build 

func (b0 BackupCreatedEvent_builder) Build() *BackupCreatedEvent

type BackupDeletedEvent 

type BackupDeletedEvent struct {

	// The data associated with the event.
	Data *BackupEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Backup is deleted.

func (*BackupDeletedEvent) ClearData 

func (x *BackupDeletedEvent) ClearData()

func (*BackupDeletedEvent) GetData 

func (x *BackupDeletedEvent) GetData() *BackupEventData

func (*BackupDeletedEvent) HasData 

func (x *BackupDeletedEvent) HasData() bool

func (*BackupDeletedEvent) ProtoMessage 

func (*BackupDeletedEvent) ProtoMessage()

func (*BackupDeletedEvent) ProtoReflect 

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

func (*BackupDeletedEvent) Reset 

func (x *BackupDeletedEvent) Reset()

func (*BackupDeletedEvent) SetData 

func (x *BackupDeletedEvent) SetData(v *BackupEventData)

func (*BackupDeletedEvent) String 

func (x *BackupDeletedEvent) String() string

type BackupDeletedEvent_builder 

type BackupDeletedEvent_builder struct {

	// The data associated with the event.
	Data *BackupEventData
	// contains filtered or unexported fields
}

func (BackupDeletedEvent_builder) Build 

func (b0 BackupDeletedEvent_builder) Build() *BackupDeletedEvent

type BackupEventData 

type BackupEventData struct {

	// Optional. The Backup event payload. Unset for deletion events.
	Payload *Backup `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Backup events.

func (*BackupEventData) ClearPayload 

func (x *BackupEventData) ClearPayload()

func (*BackupEventData) GetPayload 

func (x *BackupEventData) GetPayload() *Backup

func (*BackupEventData) HasPayload 

func (x *BackupEventData) HasPayload() bool

func (*BackupEventData) ProtoMessage 

func (*BackupEventData) ProtoMessage()

func (*BackupEventData) ProtoReflect 

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

func (*BackupEventData) Reset 

func (x *BackupEventData) Reset()

func (*BackupEventData) SetPayload 

func (x *BackupEventData) SetPayload(v *Backup)

func (*BackupEventData) String 

func (x *BackupEventData) String() string

type BackupEventData_builder 

type BackupEventData_builder struct {

	// Optional. The Backup event payload. Unset for deletion events.
	Payload *Backup
	// contains filtered or unexported fields
}

func (BackupEventData_builder) Build 

func (b0 BackupEventData_builder) Build() *BackupEventData

type Backup_State 

type Backup_State int32

The current state of the backup. 

const (
	// The state of the backup is unknown.
	Backup_STATE_UNSPECIFIED Backup_State = 0
	// The backup is being created.
	Backup_CREATING Backup_State = 1
	// The backup is being deleted.
	Backup_DELETING Backup_State = 2
	// The backup is active and ready to use.
	Backup_ACTIVE Backup_State = 3
	// The backup failed.
	Backup_FAILED Backup_State = 4
	// The backup is being restored.
	Backup_RESTORING Backup_State = 5
)

func (Backup_State) Descriptor 

func (Backup_State) Descriptor() protoreflect.EnumDescriptor

func (Backup_State) Enum 

func (x Backup_State) Enum() *Backup_State

func (Backup_State) Number 

func (x Backup_State) Number() protoreflect.EnumNumber

func (Backup_State) String 

func (x Backup_State) String() string

func (Backup_State) Type 

func (Backup_State) Type() protoreflect.EnumType

type Backup_builder 

type Backup_builder struct {

	// Immutable. The relative resource name of the backup, in the following form:
	//
	// `projects/{project_number}/locations/{location_id}/services/{service_id}/backups/{backup_id}`
	Name string
	// Output only. The time when the backup was started.
	CreateTime *timestamppb.Timestamp
	// Output only. The time when the backup finished creating.
	EndTime *timestamppb.Timestamp
	// Output only. The current state of the backup.
	State Backup_State
	// Output only. The revision of the service at the time of backup.
	ServiceRevision *Service
	// The description of the backup.
	Description string
	// Output only. Services that are restoring from the backup.
	RestoringServices []string
	// contains filtered or unexported fields
}

func (Backup_builder) Build 

func (b0 Backup_builder) Build() *Backup

type DatabaseDumpSpec 

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

The specification of database dump to import from or export to.

func (*DatabaseDumpSpec) ProtoMessage 

func (*DatabaseDumpSpec) ProtoMessage()

func (*DatabaseDumpSpec) ProtoReflect 

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

func (*DatabaseDumpSpec) Reset 

func (x *DatabaseDumpSpec) Reset()

func (*DatabaseDumpSpec) String 

func (x *DatabaseDumpSpec) String() string

type DatabaseDumpSpec_Type 

type DatabaseDumpSpec_Type int32

The type of the database dump. 

const (
	// The type of the database dump is unknown.
	DatabaseDumpSpec_TYPE_UNSPECIFIED DatabaseDumpSpec_Type = 0
	// Database dump is a MySQL dump file.
	DatabaseDumpSpec_MYSQL DatabaseDumpSpec_Type = 1
	// Database dump contains Avro files.
	DatabaseDumpSpec_AVRO DatabaseDumpSpec_Type = 2
)

func (DatabaseDumpSpec_Type) Descriptor 

func (DatabaseDumpSpec_Type) Descriptor() protoreflect.EnumDescriptor

func (DatabaseDumpSpec_Type) Enum 

func (x DatabaseDumpSpec_Type) Enum() *DatabaseDumpSpec_Type

func (DatabaseDumpSpec_Type) Number 

func (x DatabaseDumpSpec_Type) Number() protoreflect.EnumNumber

func (DatabaseDumpSpec_Type) String 

func (x DatabaseDumpSpec_Type) String() string

func (DatabaseDumpSpec_Type) Type 

func (DatabaseDumpSpec_Type) Type() protoreflect.EnumType

type DatabaseDumpSpec_builder 

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

func (DatabaseDumpSpec_builder) Build 

func (b0 DatabaseDumpSpec_builder) Build() *DatabaseDumpSpec

type EncryptionConfig 

type EncryptionConfig struct {

	// The fully qualified customer provided Cloud KMS key name to use for
	// customer data encryption, in the following form:
	//
	// `projects/{project_number}/locations/{location_id}/keyRings/{key_ring_id}/cryptoKeys/{crypto_key_id}`.
	KmsKey string `protobuf:"bytes,1,opt,name=kms_key,json=kmsKey,proto3" json:"kms_key,omitempty"`
	// contains filtered or unexported fields
}

Encryption settings for the service.

func (*EncryptionConfig) GetKmsKey 

func (x *EncryptionConfig) GetKmsKey() string

func (*EncryptionConfig) ProtoMessage 

func (*EncryptionConfig) ProtoMessage()

func (*EncryptionConfig) ProtoReflect 

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

func (*EncryptionConfig) Reset 

func (x *EncryptionConfig) Reset()

func (*EncryptionConfig) SetKmsKey 

func (x *EncryptionConfig) SetKmsKey(v string)

func (*EncryptionConfig) String 

func (x *EncryptionConfig) String() string

type EncryptionConfig_builder 

type EncryptionConfig_builder struct {

	// The fully qualified customer provided Cloud KMS key name to use for
	// customer data encryption, in the following form:
	//
	// `projects/{project_number}/locations/{location_id}/keyRings/{key_ring_id}/cryptoKeys/{crypto_key_id}`.
	KmsKey string
	// contains filtered or unexported fields
}

func (EncryptionConfig_builder) Build 

func (b0 EncryptionConfig_builder) Build() *EncryptionConfig

type Federation 

type Federation struct {

	// Immutable. The relative resource name of the federation, of the
	// form:
	// projects/{project_number}/locations/{location_id}/federations/{federation_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The time when the metastore federation was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time when the metastore federation was last updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// User-defined labels for the metastore federation.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Immutable. The Apache Hive metastore version of the federation. All backend
	// metastore versions must be compatible with the federation version.
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// A map from `BackendMetastore` rank to `BackendMetastore`s from which the
	// federation service serves metadata at query time. The map key represents
	// the order in which `BackendMetastore`s should be evaluated to resolve
	// database names at query time and should be greater than or equal to zero. A
	// `BackendMetastore` with a lower number will be evaluated before a
	// `BackendMetastore` with a higher number.
	BackendMetastores map[int32]*BackendMetastore `` /* 187-byte string literal not displayed */
	// Output only. The federation endpoint.
	EndpointUri string `protobuf:"bytes,7,opt,name=endpoint_uri,json=endpointUri,proto3" json:"endpoint_uri,omitempty"`
	// Output only. The current state of the federation.
	State Federation_State `protobuf:"varint,8,opt,name=state,proto3,enum=google.events.cloud.metastore.v1.Federation_State" json:"state,omitempty"`
	// Output only. Additional information about the current state of the
	// metastore federation, if available.
	StateMessage string `protobuf:"bytes,9,opt,name=state_message,json=stateMessage,proto3" json:"state_message,omitempty"`
	// Output only. The globally unique resource identifier of the metastore
	// federation.
	Uid string `protobuf:"bytes,10,opt,name=uid,proto3" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

Represents a federation of multiple backend metastores.

func (*Federation) ClearCreateTime 

func (x *Federation) ClearCreateTime()

func (*Federation) ClearUpdateTime 

func (x *Federation) ClearUpdateTime()

func (*Federation) GetBackendMetastores 

func (x *Federation) GetBackendMetastores() map[int32]*BackendMetastore

func (*Federation) GetCreateTime 

func (x *Federation) GetCreateTime() *timestamppb.Timestamp

func (*Federation) GetEndpointUri 

func (x *Federation) GetEndpointUri() string

func (*Federation) GetLabels 

func (x *Federation) GetLabels() map[string]string

func (*Federation) GetName 

func (x *Federation) GetName() string

func (*Federation) GetState 

func (x *Federation) GetState() Federation_State

func (*Federation) GetStateMessage 

func (x *Federation) GetStateMessage() string

func (*Federation) GetUid 

func (x *Federation) GetUid() string

func (*Federation) GetUpdateTime 

func (x *Federation) GetUpdateTime() *timestamppb.Timestamp

func (*Federation) GetVersion 

func (x *Federation) GetVersion() string

func (*Federation) HasCreateTime 

func (x *Federation) HasCreateTime() bool

func (*Federation) HasUpdateTime 

func (x *Federation) HasUpdateTime() bool

func (*Federation) ProtoMessage 

func (*Federation) ProtoMessage()

func (*Federation) ProtoReflect 

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

func (*Federation) Reset 

func (x *Federation) Reset()

func (*Federation) SetBackendMetastores 

func (x *Federation) SetBackendMetastores(v map[int32]*BackendMetastore)

func (*Federation) SetCreateTime 

func (x *Federation) SetCreateTime(v *timestamppb.Timestamp)

func (*Federation) SetEndpointUri 

func (x *Federation) SetEndpointUri(v string)

func (*Federation) SetLabels 

func (x *Federation) SetLabels(v map[string]string)

func (*Federation) SetName 

func (x *Federation) SetName(v string)

func (*Federation) SetState 

func (x *Federation) SetState(v Federation_State)

func (*Federation) SetStateMessage 

func (x *Federation) SetStateMessage(v string)

func (*Federation) SetUid 

func (x *Federation) SetUid(v string)

func (*Federation) SetUpdateTime 

func (x *Federation) SetUpdateTime(v *timestamppb.Timestamp)

func (*Federation) SetVersion 

func (x *Federation) SetVersion(v string)

func (*Federation) String 

func (x *Federation) String() string

type FederationCreatedEvent 

type FederationCreatedEvent struct {

	// The data associated with the event.
	Data *FederationEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Federation is created.

func (*FederationCreatedEvent) ClearData 

func (x *FederationCreatedEvent) ClearData()

func (*FederationCreatedEvent) GetData 

func (x *FederationCreatedEvent) GetData() *FederationEventData

func (*FederationCreatedEvent) HasData 

func (x *FederationCreatedEvent) HasData() bool

func (*FederationCreatedEvent) ProtoMessage 

func (*FederationCreatedEvent) ProtoMessage()

func (*FederationCreatedEvent) ProtoReflect 

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

func (*FederationCreatedEvent) Reset 

func (x *FederationCreatedEvent) Reset()

func (*FederationCreatedEvent) SetData 

func (x *FederationCreatedEvent) SetData(v *FederationEventData)

func (*FederationCreatedEvent) String 

func (x *FederationCreatedEvent) String() string

type FederationCreatedEvent_builder 

type FederationCreatedEvent_builder struct {

	// The data associated with the event.
	Data *FederationEventData
	// contains filtered or unexported fields
}

func (FederationCreatedEvent_builder) Build 

func (b0 FederationCreatedEvent_builder) Build() *FederationCreatedEvent

type FederationDeletedEvent 

type FederationDeletedEvent struct {

	// The data associated with the event.
	Data *FederationEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Federation is deleted.

func (*FederationDeletedEvent) ClearData 

func (x *FederationDeletedEvent) ClearData()

func (*FederationDeletedEvent) GetData 

func (x *FederationDeletedEvent) GetData() *FederationEventData

func (*FederationDeletedEvent) HasData 

func (x *FederationDeletedEvent) HasData() bool

func (*FederationDeletedEvent) ProtoMessage 

func (*FederationDeletedEvent) ProtoMessage()

func (*FederationDeletedEvent) ProtoReflect 

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

func (*FederationDeletedEvent) Reset 

func (x *FederationDeletedEvent) Reset()

func (*FederationDeletedEvent) SetData 

func (x *FederationDeletedEvent) SetData(v *FederationEventData)

func (*FederationDeletedEvent) String 

func (x *FederationDeletedEvent) String() string

type FederationDeletedEvent_builder 

type FederationDeletedEvent_builder struct {

	// The data associated with the event.
	Data *FederationEventData
	// contains filtered or unexported fields
}

func (FederationDeletedEvent_builder) Build 

func (b0 FederationDeletedEvent_builder) Build() *FederationDeletedEvent

type FederationEventData 

type FederationEventData struct {

	// Optional. The Federation event payload. Unset for deletion events.
	Payload *Federation `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Federation events.

func (*FederationEventData) ClearPayload 

func (x *FederationEventData) ClearPayload()

func (*FederationEventData) GetPayload 

func (x *FederationEventData) GetPayload() *Federation

func (*FederationEventData) HasPayload 

func (x *FederationEventData) HasPayload() bool

func (*FederationEventData) ProtoMessage 

func (*FederationEventData) ProtoMessage()

func (*FederationEventData) ProtoReflect 

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

func (*FederationEventData) Reset 

func (x *FederationEventData) Reset()

func (*FederationEventData) SetPayload 

func (x *FederationEventData) SetPayload(v *Federation)

func (*FederationEventData) String 

func (x *FederationEventData) String() string

type FederationEventData_builder 

type FederationEventData_builder struct {

	// Optional. The Federation event payload. Unset for deletion events.
	Payload *Federation
	// contains filtered or unexported fields
}

func (FederationEventData_builder) Build 

func (b0 FederationEventData_builder) Build() *FederationEventData

type FederationUpdatedEvent 

type FederationUpdatedEvent struct {

	// The data associated with the event.
	Data *FederationEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Federation is updated.

func (*FederationUpdatedEvent) ClearData 

func (x *FederationUpdatedEvent) ClearData()

func (*FederationUpdatedEvent) GetData 

func (x *FederationUpdatedEvent) GetData() *FederationEventData

func (*FederationUpdatedEvent) HasData 

func (x *FederationUpdatedEvent) HasData() bool

func (*FederationUpdatedEvent) ProtoMessage 

func (*FederationUpdatedEvent) ProtoMessage()

func (*FederationUpdatedEvent) ProtoReflect 

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

func (*FederationUpdatedEvent) Reset 

func (x *FederationUpdatedEvent) Reset()

func (*FederationUpdatedEvent) SetData 

func (x *FederationUpdatedEvent) SetData(v *FederationEventData)

func (*FederationUpdatedEvent) String 

func (x *FederationUpdatedEvent) String() string

type FederationUpdatedEvent_builder 

type FederationUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *FederationEventData
	// contains filtered or unexported fields
}

func (FederationUpdatedEvent_builder) Build 

func (b0 FederationUpdatedEvent_builder) Build() *FederationUpdatedEvent

type Federation_State 

type Federation_State int32

The current state of the federation. 

const (
	// The state of the metastore federation is unknown.
	Federation_STATE_UNSPECIFIED Federation_State = 0
	// The metastore federation is in the process of being created.
	Federation_CREATING Federation_State = 1
	// The metastore federation is running and ready to serve queries.
	Federation_ACTIVE Federation_State = 2
	// The metastore federation is being updated. It remains usable but cannot
	// accept additional update requests or be deleted at this time.
	Federation_UPDATING Federation_State = 3
	// The metastore federation is undergoing deletion. It cannot be used.
	Federation_DELETING Federation_State = 4
	// The metastore federation has encountered an error and cannot be used. The
	// metastore federation should be deleted.
	Federation_ERROR Federation_State = 5
)

func (Federation_State) Descriptor 

func (Federation_State) Descriptor() protoreflect.EnumDescriptor

func (Federation_State) Enum 

func (x Federation_State) Enum() *Federation_State

func (Federation_State) Number 

func (x Federation_State) Number() protoreflect.EnumNumber

func (Federation_State) String 

func (x Federation_State) String() string

func (Federation_State) Type 

func (Federation_State) Type() protoreflect.EnumType

type Federation_builder 

type Federation_builder struct {

	// Immutable. The relative resource name of the federation, of the
	// form:
	// projects/{project_number}/locations/{location_id}/federations/{federation_id}`.
	Name string
	// Output only. The time when the metastore federation was created.
	CreateTime *timestamppb.Timestamp
	// Output only. The time when the metastore federation was last updated.
	UpdateTime *timestamppb.Timestamp
	// User-defined labels for the metastore federation.
	Labels map[string]string
	// Immutable. The Apache Hive metastore version of the federation. All backend
	// metastore versions must be compatible with the federation version.
	Version string
	// A map from `BackendMetastore` rank to `BackendMetastore`s from which the
	// federation service serves metadata at query time. The map key represents
	// the order in which `BackendMetastore`s should be evaluated to resolve
	// database names at query time and should be greater than or equal to zero. A
	// `BackendMetastore` with a lower number will be evaluated before a
	// `BackendMetastore` with a higher number.
	BackendMetastores map[int32]*BackendMetastore
	// Output only. The federation endpoint.
	EndpointUri string
	// Output only. The current state of the federation.
	State Federation_State
	// Output only. Additional information about the current state of the
	// metastore federation, if available.
	StateMessage string
	// Output only. The globally unique resource identifier of the metastore
	// federation.
	Uid string
	// contains filtered or unexported fields
}

func (Federation_builder) Build 

func (b0 Federation_builder) Build() *Federation

type HiveMetastoreConfig 

type HiveMetastoreConfig struct {

	// Immutable. The Hive metastore schema version.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// A mapping of Hive metastore configuration key-value pairs to apply to the
	// Hive metastore (configured in `hive-site.xml`). The mappings
	// override system defaults (some keys cannot be overridden). These
	// overrides are also applied to auxiliary versions and can be further
	// customized in the auxiliary version's `AuxiliaryVersionConfig`.
	ConfigOverrides map[string]string `` /* 180-byte string literal not displayed */
	// Information used to configure the Hive metastore service as a service
	// principal in a Kerberos realm. To disable Kerberos, use the `UpdateService`
	// method and specify this field's path
	// (`hive_metastore_config.kerberos_config`) in the request's `update_mask`
	// while omitting this field from the request's `service`.
	KerberosConfig *KerberosConfig `protobuf:"bytes,3,opt,name=kerberos_config,json=kerberosConfig,proto3" json:"kerberos_config,omitempty"`
	// A mapping of Hive metastore version to the auxiliary version
	// configuration. When specified, a secondary Hive metastore service is
	// created along with the primary service. All auxiliary versions must be less
	// than the service's primary version. The key is the auxiliary service name
	// and it must match the regular expression [a-z]([-a-z0-9]*[a-z0-9])?. This
	// means that the first character must be a lowercase letter, and all the
	// following characters must be hyphens, lowercase letters, or digits, except
	// the last character, which cannot be a hyphen.
	AuxiliaryVersions map[string]*AuxiliaryVersionConfig `` /* 186-byte string literal not displayed */
	// contains filtered or unexported fields
}

Specifies configuration information specific to running Hive metastore software as the metastore service.

func (*HiveMetastoreConfig) ClearKerberosConfig 

func (x *HiveMetastoreConfig) ClearKerberosConfig()

func (*HiveMetastoreConfig) GetAuxiliaryVersions 

func (x *HiveMetastoreConfig) GetAuxiliaryVersions() map[string]*AuxiliaryVersionConfig

func (*HiveMetastoreConfig) GetConfigOverrides 

func (x *HiveMetastoreConfig) GetConfigOverrides() map[string]string

func (*HiveMetastoreConfig) GetKerberosConfig 

func (x *HiveMetastoreConfig) GetKerberosConfig() *KerberosConfig

func (*HiveMetastoreConfig) GetVersion 

func (x *HiveMetastoreConfig) GetVersion() string

func (*HiveMetastoreConfig) HasKerberosConfig 

func (x *HiveMetastoreConfig) HasKerberosConfig() bool

func (*HiveMetastoreConfig) ProtoMessage 

func (*HiveMetastoreConfig) ProtoMessage()

func (*HiveMetastoreConfig) ProtoReflect 

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

func (*HiveMetastoreConfig) Reset 

func (x *HiveMetastoreConfig) Reset()

func (*HiveMetastoreConfig) SetAuxiliaryVersions 

func (x *HiveMetastoreConfig) SetAuxiliaryVersions(v map[string]*AuxiliaryVersionConfig)

func (*HiveMetastoreConfig) SetConfigOverrides 

func (x *HiveMetastoreConfig) SetConfigOverrides(v map[string]string)

func (*HiveMetastoreConfig) SetKerberosConfig 

func (x *HiveMetastoreConfig) SetKerberosConfig(v *KerberosConfig)

func (*HiveMetastoreConfig) SetVersion 

func (x *HiveMetastoreConfig) SetVersion(v string)

func (*HiveMetastoreConfig) String 

func (x *HiveMetastoreConfig) String() string

type HiveMetastoreConfig_builder 

type HiveMetastoreConfig_builder struct {

	// Immutable. The Hive metastore schema version.
	Version string
	// A mapping of Hive metastore configuration key-value pairs to apply to the
	// Hive metastore (configured in `hive-site.xml`). The mappings
	// override system defaults (some keys cannot be overridden). These
	// overrides are also applied to auxiliary versions and can be further
	// customized in the auxiliary version's `AuxiliaryVersionConfig`.
	ConfigOverrides map[string]string
	// Information used to configure the Hive metastore service as a service
	// principal in a Kerberos realm. To disable Kerberos, use the `UpdateService`
	// method and specify this field's path
	// (`hive_metastore_config.kerberos_config`) in the request's `update_mask`
	// while omitting this field from the request's `service`.
	KerberosConfig *KerberosConfig
	// A mapping of Hive metastore version to the auxiliary version
	// configuration. When specified, a secondary Hive metastore service is
	// created along with the primary service. All auxiliary versions must be less
	// than the service's primary version. The key is the auxiliary service name
	// and it must match the regular expression [a-z]([-a-z0-9]*[a-z0-9])?. This
	// means that the first character must be a lowercase letter, and all the
	// following characters must be hyphens, lowercase letters, or digits, except
	// the last character, which cannot be a hyphen.
	AuxiliaryVersions map[string]*AuxiliaryVersionConfig
	// contains filtered or unexported fields
}

func (HiveMetastoreConfig_builder) Build 

func (b0 HiveMetastoreConfig_builder) Build() *HiveMetastoreConfig

type KerberosConfig 

type KerberosConfig struct {

	// A Kerberos keytab file that can be used to authenticate a service principal
	// with a Kerberos Key Distribution Center (KDC).
	Keytab *Secret `protobuf:"bytes,1,opt,name=keytab,proto3" json:"keytab,omitempty"`
	// A Kerberos principal that exists in the both the keytab the KDC
	// to authenticate as. A typical principal is of the form
	// `primary/instance@REALM`, but there is no exact format.
	Principal string `protobuf:"bytes,2,opt,name=principal,proto3" json:"principal,omitempty"`
	// A Cloud Storage URI that specifies the path to a
	// krb5.conf file. It is of the form `gs://{bucket_name}/path/to/krb5.conf`,
	// although the file does not need to be named krb5.conf explicitly.
	Krb5ConfigGcsUri string `protobuf:"bytes,3,opt,name=krb5_config_gcs_uri,json=krb5ConfigGcsUri,proto3" json:"krb5_config_gcs_uri,omitempty"`
	// contains filtered or unexported fields
}

Configuration information for a Kerberos principal.

func (*KerberosConfig) ClearKeytab 

func (x *KerberosConfig) ClearKeytab()

func (*KerberosConfig) GetKeytab 

func (x *KerberosConfig) GetKeytab() *Secret

func (*KerberosConfig) GetKrb5ConfigGcsUri 

func (x *KerberosConfig) GetKrb5ConfigGcsUri() string

func (*KerberosConfig) GetPrincipal 

func (x *KerberosConfig) GetPrincipal() string

func (*KerberosConfig) HasKeytab 

func (x *KerberosConfig) HasKeytab() bool

func (*KerberosConfig) ProtoMessage 

func (*KerberosConfig) ProtoMessage()

func (*KerberosConfig) ProtoReflect 

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

func (*KerberosConfig) Reset 

func (x *KerberosConfig) Reset()

func (*KerberosConfig) SetKeytab 

func (x *KerberosConfig) SetKeytab(v *Secret)

func (*KerberosConfig) SetKrb5ConfigGcsUri 

func (x *KerberosConfig) SetKrb5ConfigGcsUri(v string)

func (*KerberosConfig) SetPrincipal 

func (x *KerberosConfig) SetPrincipal(v string)

func (*KerberosConfig) String 

func (x *KerberosConfig) String() string

type KerberosConfig_builder 

type KerberosConfig_builder struct {

	// A Kerberos keytab file that can be used to authenticate a service principal
	// with a Kerberos Key Distribution Center (KDC).
	Keytab *Secret
	// A Kerberos principal that exists in the both the keytab the KDC
	// to authenticate as. A typical principal is of the form
	// `primary/instance@REALM`, but there is no exact format.
	Principal string
	// A Cloud Storage URI that specifies the path to a
	// krb5.conf file. It is of the form `gs://{bucket_name}/path/to/krb5.conf`,
	// although the file does not need to be named krb5.conf explicitly.
	Krb5ConfigGcsUri string
	// contains filtered or unexported fields
}

func (KerberosConfig_builder) Build 

func (b0 KerberosConfig_builder) Build() *KerberosConfig

type MaintenanceWindow 

type MaintenanceWindow struct {

	// The hour of day (0-23) when the window starts.
	HourOfDay *wrapperspb.Int32Value `protobuf:"bytes,1,opt,name=hour_of_day,json=hourOfDay,proto3" json:"hour_of_day,omitempty"`
	// The day of week, when the window starts.
	DayOfWeek dayofweek.DayOfWeek `protobuf:"varint,2,opt,name=day_of_week,json=dayOfWeek,proto3,enum=google.type.DayOfWeek" json:"day_of_week,omitempty"`
	// contains filtered or unexported fields
}

Maintenance window. This specifies when Dataproc Metastore may perform system maintenance operation to the service.

func (*MaintenanceWindow) ClearHourOfDay 

func (x *MaintenanceWindow) ClearHourOfDay()

func (*MaintenanceWindow) GetDayOfWeek 

func (x *MaintenanceWindow) GetDayOfWeek() dayofweek.DayOfWeek

func (*MaintenanceWindow) GetHourOfDay 

func (x *MaintenanceWindow) GetHourOfDay() *wrapperspb.Int32Value

func (*MaintenanceWindow) HasHourOfDay 

func (x *MaintenanceWindow) HasHourOfDay() bool

func (*MaintenanceWindow) ProtoMessage 

func (*MaintenanceWindow) ProtoMessage()

func (*MaintenanceWindow) ProtoReflect 

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

func (*MaintenanceWindow) Reset 

func (x *MaintenanceWindow) Reset()

func (*MaintenanceWindow) SetDayOfWeek 

func (x *MaintenanceWindow) SetDayOfWeek(v dayofweek.DayOfWeek)

func (*MaintenanceWindow) SetHourOfDay 

func (x *MaintenanceWindow) SetHourOfDay(v *wrapperspb.Int32Value)

func (*MaintenanceWindow) String 

func (x *MaintenanceWindow) String() string

type MaintenanceWindow_builder 

type MaintenanceWindow_builder struct {

	// The hour of day (0-23) when the window starts.
	HourOfDay *wrapperspb.Int32Value
	// The day of week, when the window starts.
	DayOfWeek dayofweek.DayOfWeek
	// contains filtered or unexported fields
}

func (MaintenanceWindow_builder) Build 

func (b0 MaintenanceWindow_builder) Build() *MaintenanceWindow

type MetadataExport 

type MetadataExport struct {

	// Types that are valid to be assigned to Destination:
	//
	//	*MetadataExport_DestinationGcsUri
	Destination isMetadataExport_Destination `protobuf_oneof:"destination"`
	// Output only. The time when the export started.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Output only. The time when the export ended.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Output only. The current state of the export.
	State MetadataExport_State `protobuf:"varint,3,opt,name=state,proto3,enum=google.events.cloud.metastore.v1.MetadataExport_State" json:"state,omitempty"`
	// Output only. The type of the database dump.
	DatabaseDumpType DatabaseDumpSpec_Type `` /* 172-byte string literal not displayed */
	// contains filtered or unexported fields
}

The details of a metadata export operation.

func (*MetadataExport) ClearDestination 

func (x *MetadataExport) ClearDestination()

func (*MetadataExport) ClearDestinationGcsUri 

func (x *MetadataExport) ClearDestinationGcsUri()

func (*MetadataExport) ClearEndTime 

func (x *MetadataExport) ClearEndTime()

func (*MetadataExport) ClearStartTime 

func (x *MetadataExport) ClearStartTime()

func (*MetadataExport) GetDatabaseDumpType 

func (x *MetadataExport) GetDatabaseDumpType() DatabaseDumpSpec_Type

func (*MetadataExport) GetDestination 

func (x *MetadataExport) GetDestination() isMetadataExport_Destination

func (*MetadataExport) GetDestinationGcsUri 

func (x *MetadataExport) GetDestinationGcsUri() string

func (*MetadataExport) GetEndTime 

func (x *MetadataExport) GetEndTime() *timestamppb.Timestamp

func (*MetadataExport) GetStartTime 

func (x *MetadataExport) GetStartTime() *timestamppb.Timestamp

func (*MetadataExport) GetState 

func (x *MetadataExport) GetState() MetadataExport_State

func (*MetadataExport) HasDestination 

func (x *MetadataExport) HasDestination() bool

func (*MetadataExport) HasDestinationGcsUri 

func (x *MetadataExport) HasDestinationGcsUri() bool

func (*MetadataExport) HasEndTime 

func (x *MetadataExport) HasEndTime() bool

func (*MetadataExport) HasStartTime 

func (x *MetadataExport) HasStartTime() bool

func (*MetadataExport) ProtoMessage 

func (*MetadataExport) ProtoMessage()

func (*MetadataExport) ProtoReflect 

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

func (*MetadataExport) Reset 

func (x *MetadataExport) Reset()

func (*MetadataExport) SetDatabaseDumpType 

func (x *MetadataExport) SetDatabaseDumpType(v DatabaseDumpSpec_Type)

func (*MetadataExport) SetDestinationGcsUri 

func (x *MetadataExport) SetDestinationGcsUri(v string)

func (*MetadataExport) SetEndTime 

func (x *MetadataExport) SetEndTime(v *timestamppb.Timestamp)

func (*MetadataExport) SetStartTime 

func (x *MetadataExport) SetStartTime(v *timestamppb.Timestamp)

func (*MetadataExport) SetState 

func (x *MetadataExport) SetState(v MetadataExport_State)

func (*MetadataExport) String 

func (x *MetadataExport) String() string

func (*MetadataExport) WhichDestination 

func (x *MetadataExport) WhichDestination() case_MetadataExport_Destination

type MetadataExport_DestinationGcsUri 

type MetadataExport_DestinationGcsUri struct {
	// Output only. A Cloud Storage URI of a folder that metadata are exported
	// to, in the form of
	// `gs://<bucket_name>/<path_inside_bucket>/<export_folder>`, where
	// `<export_folder>` is automatically generated.
	DestinationGcsUri string `protobuf:"bytes,4,opt,name=destination_gcs_uri,json=destinationGcsUri,proto3,oneof"`
}

type MetadataExport_State 

type MetadataExport_State int32

The current state of the metadata export. 

const (
	// The state of the metadata export is unknown.
	MetadataExport_STATE_UNSPECIFIED MetadataExport_State = 0
	// The metadata export is running.
	MetadataExport_RUNNING MetadataExport_State = 1
	// The metadata export completed successfully.
	MetadataExport_SUCCEEDED MetadataExport_State = 2
	// The metadata export failed.
	MetadataExport_FAILED MetadataExport_State = 3
	// The metadata export is cancelled.
	MetadataExport_CANCELLED MetadataExport_State = 4
)

func (MetadataExport_State) Descriptor 

func (MetadataExport_State) Descriptor() protoreflect.EnumDescriptor

func (MetadataExport_State) Enum 

func (x MetadataExport_State) Enum() *MetadataExport_State

func (MetadataExport_State) Number 

func (x MetadataExport_State) Number() protoreflect.EnumNumber

func (MetadataExport_State) String 

func (x MetadataExport_State) String() string

func (MetadataExport_State) Type 

func (MetadataExport_State) Type() protoreflect.EnumType

type MetadataExport_builder 

type MetadataExport_builder struct {

	// Fields of oneof Destination:
	// Output only. A Cloud Storage URI of a folder that metadata are exported
	// to, in the form of
	// `gs://<bucket_name>/<path_inside_bucket>/<export_folder>`, where
	// `<export_folder>` is automatically generated.
	DestinationGcsUri *string
	// -- end of Destination
	// Output only. The time when the export started.
	StartTime *timestamppb.Timestamp
	// Output only. The time when the export ended.
	EndTime *timestamppb.Timestamp
	// Output only. The current state of the export.
	State MetadataExport_State
	// Output only. The type of the database dump.
	DatabaseDumpType DatabaseDumpSpec_Type
	// contains filtered or unexported fields
}

func (MetadataExport_builder) Build 

func (b0 MetadataExport_builder) Build() *MetadataExport

type MetadataImport 

type MetadataImport struct {

	// The metadata to be imported.
	//
	// Types that are valid to be assigned to Metadata:
	//
	//	*MetadataImport_DatabaseDump_
	Metadata isMetadataImport_Metadata `protobuf_oneof:"metadata"`
	// Immutable. The relative resource name of the metadata import, of the form:
	//
	// `projects/{project_number}/locations/{location_id}/services/{service_id}/metadataImports/{metadata_import_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The description of the metadata import.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Output only. The time when the metadata import was started.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time when the metadata import was last updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Output only. The time when the metadata import finished.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Output only. The current state of the metadata import.
	State MetadataImport_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.events.cloud.metastore.v1.MetadataImport_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

A metastore resource that imports metadata.

func (*MetadataImport) ClearCreateTime 

func (x *MetadataImport) ClearCreateTime()

func (*MetadataImport) ClearDatabaseDump 

func (x *MetadataImport) ClearDatabaseDump()

func (*MetadataImport) ClearEndTime 

func (x *MetadataImport) ClearEndTime()

func (*MetadataImport) ClearMetadata 

func (x *MetadataImport) ClearMetadata()

func (*MetadataImport) ClearUpdateTime 

func (x *MetadataImport) ClearUpdateTime()

func (*MetadataImport) GetCreateTime 

func (x *MetadataImport) GetCreateTime() *timestamppb.Timestamp

func (*MetadataImport) GetDatabaseDump 

func (x *MetadataImport) GetDatabaseDump() *MetadataImport_DatabaseDump

func (*MetadataImport) GetDescription 

func (x *MetadataImport) GetDescription() string

func (*MetadataImport) GetEndTime 

func (x *MetadataImport) GetEndTime() *timestamppb.Timestamp

func (*MetadataImport) GetMetadata 

func (x *MetadataImport) GetMetadata() isMetadataImport_Metadata

func (*MetadataImport) GetName 

func (x *MetadataImport) GetName() string

func (*MetadataImport) GetState 

func (x *MetadataImport) GetState() MetadataImport_State

func (*MetadataImport) GetUpdateTime 

func (x *MetadataImport) GetUpdateTime() *timestamppb.Timestamp

func (*MetadataImport) HasCreateTime 

func (x *MetadataImport) HasCreateTime() bool

func (*MetadataImport) HasDatabaseDump 

func (x *MetadataImport) HasDatabaseDump() bool

func (*MetadataImport) HasEndTime 

func (x *MetadataImport) HasEndTime() bool

func (*MetadataImport) HasMetadata 

func (x *MetadataImport) HasMetadata() bool

func (*MetadataImport) HasUpdateTime 

func (x *MetadataImport) HasUpdateTime() bool

func (*MetadataImport) ProtoMessage 

func (*MetadataImport) ProtoMessage()

func (*MetadataImport) ProtoReflect 

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

func (*MetadataImport) Reset 

func (x *MetadataImport) Reset()

func (*MetadataImport) SetCreateTime 

func (x *MetadataImport) SetCreateTime(v *timestamppb.Timestamp)

func (*MetadataImport) SetDatabaseDump 

func (x *MetadataImport) SetDatabaseDump(v *MetadataImport_DatabaseDump)

func (*MetadataImport) SetDescription 

func (x *MetadataImport) SetDescription(v string)

func (*MetadataImport) SetEndTime 

func (x *MetadataImport) SetEndTime(v *timestamppb.Timestamp)

func (*MetadataImport) SetName 

func (x *MetadataImport) SetName(v string)

func (*MetadataImport) SetState 

func (x *MetadataImport) SetState(v MetadataImport_State)

func (*MetadataImport) SetUpdateTime 

func (x *MetadataImport) SetUpdateTime(v *timestamppb.Timestamp)

func (*MetadataImport) String 

func (x *MetadataImport) String() string

func (*MetadataImport) WhichMetadata 

func (x *MetadataImport) WhichMetadata() case_MetadataImport_Metadata

type MetadataImportCreatedEvent 

type MetadataImportCreatedEvent struct {

	// The data associated with the event.
	Data *MetadataImportEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a MetadataImport is created.

func (*MetadataImportCreatedEvent) ClearData 

func (x *MetadataImportCreatedEvent) ClearData()

func (*MetadataImportCreatedEvent) GetData 

func (x *MetadataImportCreatedEvent) GetData() *MetadataImportEventData

func (*MetadataImportCreatedEvent) HasData 

func (x *MetadataImportCreatedEvent) HasData() bool

func (*MetadataImportCreatedEvent) ProtoMessage 

func (*MetadataImportCreatedEvent) ProtoMessage()

func (*MetadataImportCreatedEvent) ProtoReflect 

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

func (*MetadataImportCreatedEvent) Reset 

func (x *MetadataImportCreatedEvent) Reset()

func (*MetadataImportCreatedEvent) SetData 

func (x *MetadataImportCreatedEvent) SetData(v *MetadataImportEventData)

func (*MetadataImportCreatedEvent) String 

func (x *MetadataImportCreatedEvent) String() string

type MetadataImportCreatedEvent_builder 

type MetadataImportCreatedEvent_builder struct {

	// The data associated with the event.
	Data *MetadataImportEventData
	// contains filtered or unexported fields
}

func (MetadataImportCreatedEvent_builder) Build 

func (b0 MetadataImportCreatedEvent_builder) Build() *MetadataImportCreatedEvent

type MetadataImportEventData 

type MetadataImportEventData struct {

	// The MetadataImport event payload.
	Payload *MetadataImport `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all MetadataImport events.

func (*MetadataImportEventData) ClearPayload 

func (x *MetadataImportEventData) ClearPayload()

func (*MetadataImportEventData) GetPayload 

func (x *MetadataImportEventData) GetPayload() *MetadataImport

func (*MetadataImportEventData) HasPayload 

func (x *MetadataImportEventData) HasPayload() bool

func (*MetadataImportEventData) ProtoMessage 

func (*MetadataImportEventData) ProtoMessage()

func (*MetadataImportEventData) ProtoReflect 

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

func (*MetadataImportEventData) Reset 

func (x *MetadataImportEventData) Reset()

func (*MetadataImportEventData) SetPayload 

func (x *MetadataImportEventData) SetPayload(v *MetadataImport)

func (*MetadataImportEventData) String 

func (x *MetadataImportEventData) String() string

type MetadataImportEventData_builder 

type MetadataImportEventData_builder struct {

	// The MetadataImport event payload.
	Payload *MetadataImport
	// contains filtered or unexported fields
}

func (MetadataImportEventData_builder) Build 

func (b0 MetadataImportEventData_builder) Build() *MetadataImportEventData

type MetadataImportUpdatedEvent 

type MetadataImportUpdatedEvent struct {

	// The data associated with the event.
	Data *MetadataImportEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a MetadataImport is updated.

func (*MetadataImportUpdatedEvent) ClearData 

func (x *MetadataImportUpdatedEvent) ClearData()

func (*MetadataImportUpdatedEvent) GetData 

func (x *MetadataImportUpdatedEvent) GetData() *MetadataImportEventData

func (*MetadataImportUpdatedEvent) HasData 

func (x *MetadataImportUpdatedEvent) HasData() bool

func (*MetadataImportUpdatedEvent) ProtoMessage 

func (*MetadataImportUpdatedEvent) ProtoMessage()

func (*MetadataImportUpdatedEvent) ProtoReflect 

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

func (*MetadataImportUpdatedEvent) Reset 

func (x *MetadataImportUpdatedEvent) Reset()

func (*MetadataImportUpdatedEvent) SetData 

func (x *MetadataImportUpdatedEvent) SetData(v *MetadataImportEventData)

func (*MetadataImportUpdatedEvent) String 

func (x *MetadataImportUpdatedEvent) String() string

type MetadataImportUpdatedEvent_builder 

type MetadataImportUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *MetadataImportEventData
	// contains filtered or unexported fields
}

func (MetadataImportUpdatedEvent_builder) Build 

func (b0 MetadataImportUpdatedEvent_builder) Build() *MetadataImportUpdatedEvent

type MetadataImport_DatabaseDump 

type MetadataImport_DatabaseDump struct {

	// The type of the database.
	DatabaseType MetadataImport_DatabaseDump_DatabaseType `` /* 177-byte string literal not displayed */
	// A Cloud Storage object or folder URI that specifies the source from which
	// to import metadata. It must begin with `gs://`.
	GcsUri string `protobuf:"bytes,2,opt,name=gcs_uri,json=gcsUri,proto3" json:"gcs_uri,omitempty"`
	// The name of the source database.
	SourceDatabase string `protobuf:"bytes,3,opt,name=source_database,json=sourceDatabase,proto3" json:"source_database,omitempty"`
	// Optional. The type of the database dump. If unspecified, defaults to
	// `MYSQL`.
	Type DatabaseDumpSpec_Type `protobuf:"varint,4,opt,name=type,proto3,enum=google.events.cloud.metastore.v1.DatabaseDumpSpec_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

A specification of the location of and metadata about a database dump from a relational database management system.

func (*MetadataImport_DatabaseDump) GetDatabaseType 

func (x *MetadataImport_DatabaseDump) GetDatabaseType() MetadataImport_DatabaseDump_DatabaseType

func (*MetadataImport_DatabaseDump) GetGcsUri 

func (x *MetadataImport_DatabaseDump) GetGcsUri() string

func (*MetadataImport_DatabaseDump) GetSourceDatabase 

func (x *MetadataImport_DatabaseDump) GetSourceDatabase() string

func (*MetadataImport_DatabaseDump) GetType 

func (x *MetadataImport_DatabaseDump) GetType() DatabaseDumpSpec_Type

func (*MetadataImport_DatabaseDump) ProtoMessage 

func (*MetadataImport_DatabaseDump) ProtoMessage()

func (*MetadataImport_DatabaseDump) ProtoReflect 

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

func (*MetadataImport_DatabaseDump) Reset 

func (x *MetadataImport_DatabaseDump) Reset()

func (*MetadataImport_DatabaseDump) SetDatabaseType 

func (x *MetadataImport_DatabaseDump) SetDatabaseType(v MetadataImport_DatabaseDump_DatabaseType)

func (*MetadataImport_DatabaseDump) SetGcsUri 

func (x *MetadataImport_DatabaseDump) SetGcsUri(v string)

func (*MetadataImport_DatabaseDump) SetSourceDatabase 

func (x *MetadataImport_DatabaseDump) SetSourceDatabase(v string)

func (*MetadataImport_DatabaseDump) SetType 

func (x *MetadataImport_DatabaseDump) SetType(v DatabaseDumpSpec_Type)

func (*MetadataImport_DatabaseDump) String 

func (x *MetadataImport_DatabaseDump) String() string

type MetadataImport_DatabaseDump_ 

type MetadataImport_DatabaseDump_ struct {
	// Immutable. A database dump from a pre-existing metastore's database.
	DatabaseDump *MetadataImport_DatabaseDump `protobuf:"bytes,6,opt,name=database_dump,json=databaseDump,proto3,oneof"`
}

type MetadataImport_DatabaseDump_DatabaseType 

type MetadataImport_DatabaseDump_DatabaseType int32

The type of the database. 

const (
	// The type of the source database is unknown.
	MetadataImport_DatabaseDump_DATABASE_TYPE_UNSPECIFIED MetadataImport_DatabaseDump_DatabaseType = 0
	// The type of the source database is MySQL.
	MetadataImport_DatabaseDump_MYSQL MetadataImport_DatabaseDump_DatabaseType = 1
)

func (MetadataImport_DatabaseDump_DatabaseType) Descriptor 

func (MetadataImport_DatabaseDump_DatabaseType) Descriptor() protoreflect.EnumDescriptor

func (MetadataImport_DatabaseDump_DatabaseType) Enum 

func (x MetadataImport_DatabaseDump_DatabaseType) Enum() *MetadataImport_DatabaseDump_DatabaseType

func (MetadataImport_DatabaseDump_DatabaseType) Number 

func (x MetadataImport_DatabaseDump_DatabaseType) Number() protoreflect.EnumNumber

func (MetadataImport_DatabaseDump_DatabaseType) String 

func (x MetadataImport_DatabaseDump_DatabaseType) String() string

func (MetadataImport_DatabaseDump_DatabaseType) Type 

func (MetadataImport_DatabaseDump_DatabaseType) Type() protoreflect.EnumType

type MetadataImport_DatabaseDump_builder 

type MetadataImport_DatabaseDump_builder struct {

	// The type of the database.
	DatabaseType MetadataImport_DatabaseDump_DatabaseType
	// A Cloud Storage object or folder URI that specifies the source from which
	// to import metadata. It must begin with `gs://`.
	GcsUri string
	// The name of the source database.
	SourceDatabase string
	// Optional. The type of the database dump. If unspecified, defaults to
	// `MYSQL`.
	Type DatabaseDumpSpec_Type
	// contains filtered or unexported fields
}

func (MetadataImport_DatabaseDump_builder) Build 

func (b0 MetadataImport_DatabaseDump_builder) Build() *MetadataImport_DatabaseDump

type MetadataImport_State 

type MetadataImport_State int32

The current state of the metadata import. 

const (
	// The state of the metadata import is unknown.
	MetadataImport_STATE_UNSPECIFIED MetadataImport_State = 0
	// The metadata import is running.
	MetadataImport_RUNNING MetadataImport_State = 1
	// The metadata import completed successfully.
	MetadataImport_SUCCEEDED MetadataImport_State = 2
	// The metadata import is being updated.
	MetadataImport_UPDATING MetadataImport_State = 3
	// The metadata import failed, and attempted metadata changes were rolled
	// back.
	MetadataImport_FAILED MetadataImport_State = 4
)

func (MetadataImport_State) Descriptor 

func (MetadataImport_State) Descriptor() protoreflect.EnumDescriptor

func (MetadataImport_State) Enum 

func (x MetadataImport_State) Enum() *MetadataImport_State

func (MetadataImport_State) Number 

func (x MetadataImport_State) Number() protoreflect.EnumNumber

func (MetadataImport_State) String 

func (x MetadataImport_State) String() string

func (MetadataImport_State) Type 

func (MetadataImport_State) Type() protoreflect.EnumType

type MetadataImport_builder 

type MetadataImport_builder struct {

	// Fields of oneof Metadata:
	// Immutable. A database dump from a pre-existing metastore's database.
	DatabaseDump *MetadataImport_DatabaseDump
	// -- end of Metadata
	// Immutable. The relative resource name of the metadata import, of the form:
	//
	// `projects/{project_number}/locations/{location_id}/services/{service_id}/metadataImports/{metadata_import_id}`.
	Name string
	// The description of the metadata import.
	Description string
	// Output only. The time when the metadata import was started.
	CreateTime *timestamppb.Timestamp
	// Output only. The time when the metadata import was last updated.
	UpdateTime *timestamppb.Timestamp
	// Output only. The time when the metadata import finished.
	EndTime *timestamppb.Timestamp
	// Output only. The current state of the metadata import.
	State MetadataImport_State
	// contains filtered or unexported fields
}

func (MetadataImport_builder) Build 

func (b0 MetadataImport_builder) Build() *MetadataImport

type MetadataManagementActivity 

type MetadataManagementActivity struct {

	// Output only. The latest metadata exports of the metastore service.
	MetadataExports []*MetadataExport `protobuf:"bytes,1,rep,name=metadata_exports,json=metadataExports,proto3" json:"metadata_exports,omitempty"`
	// Output only. The latest restores of the metastore service.
	Restores []*Restore `protobuf:"bytes,2,rep,name=restores,proto3" json:"restores,omitempty"`
	// contains filtered or unexported fields
}

The metadata management activities of the metastore service.

func (*MetadataManagementActivity) GetMetadataExports 

func (x *MetadataManagementActivity) GetMetadataExports() []*MetadataExport

func (*MetadataManagementActivity) GetRestores 

func (x *MetadataManagementActivity) GetRestores() []*Restore

func (*MetadataManagementActivity) ProtoMessage 

func (*MetadataManagementActivity) ProtoMessage()

func (*MetadataManagementActivity) ProtoReflect 

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

func (*MetadataManagementActivity) Reset 

func (x *MetadataManagementActivity) Reset()

func (*MetadataManagementActivity) SetMetadataExports 

func (x *MetadataManagementActivity) SetMetadataExports(v []*MetadataExport)

func (*MetadataManagementActivity) SetRestores 

func (x *MetadataManagementActivity) SetRestores(v []*Restore)

func (*MetadataManagementActivity) String 

func (x *MetadataManagementActivity) String() string

type MetadataManagementActivity_builder 

type MetadataManagementActivity_builder struct {

	// Output only. The latest metadata exports of the metastore service.
	MetadataExports []*MetadataExport
	// Output only. The latest restores of the metastore service.
	Restores []*Restore
	// contains filtered or unexported fields
}

func (MetadataManagementActivity_builder) Build 

func (b0 MetadataManagementActivity_builder) Build() *MetadataManagementActivity

type NetworkConfig 

type NetworkConfig struct {

	// Immutable. The consumer-side network configuration for the Dataproc
	// Metastore instance.
	Consumers []*NetworkConfig_Consumer `protobuf:"bytes,1,rep,name=consumers,proto3" json:"consumers,omitempty"`
	// contains filtered or unexported fields
}

Network configuration for the Dataproc Metastore service.

func (*NetworkConfig) GetConsumers 

func (x *NetworkConfig) GetConsumers() []*NetworkConfig_Consumer

func (*NetworkConfig) ProtoMessage 

func (*NetworkConfig) ProtoMessage()

func (*NetworkConfig) ProtoReflect 

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

func (*NetworkConfig) Reset 

func (x *NetworkConfig) Reset()

func (*NetworkConfig) SetConsumers 

func (x *NetworkConfig) SetConsumers(v []*NetworkConfig_Consumer)

func (*NetworkConfig) String 

func (x *NetworkConfig) String() string

type NetworkConfig_Consumer 

type NetworkConfig_Consumer struct {

	// Types that are valid to be assigned to VpcResource:
	//
	//	*NetworkConfig_Consumer_Subnetwork
	VpcResource isNetworkConfig_Consumer_VpcResource `protobuf_oneof:"vpc_resource"`
	// Output only. The URI of the endpoint used to access the metastore
	// service.
	EndpointUri string `protobuf:"bytes,3,opt,name=endpoint_uri,json=endpointUri,proto3" json:"endpoint_uri,omitempty"`
	// contains filtered or unexported fields
}

Contains information of the customer's network configurations.

func (*NetworkConfig_Consumer) ClearSubnetwork 

func (x *NetworkConfig_Consumer) ClearSubnetwork()

func (*NetworkConfig_Consumer) ClearVpcResource 

func (x *NetworkConfig_Consumer) ClearVpcResource()

func (*NetworkConfig_Consumer) GetEndpointUri 

func (x *NetworkConfig_Consumer) GetEndpointUri() string

func (*NetworkConfig_Consumer) GetSubnetwork 

func (x *NetworkConfig_Consumer) GetSubnetwork() string

func (*NetworkConfig_Consumer) GetVpcResource 

func (x *NetworkConfig_Consumer) GetVpcResource() isNetworkConfig_Consumer_VpcResource

func (*NetworkConfig_Consumer) HasSubnetwork 

func (x *NetworkConfig_Consumer) HasSubnetwork() bool

func (*NetworkConfig_Consumer) HasVpcResource 

func (x *NetworkConfig_Consumer) HasVpcResource() bool

func (*NetworkConfig_Consumer) ProtoMessage 

func (*NetworkConfig_Consumer) ProtoMessage()

func (*NetworkConfig_Consumer) ProtoReflect 

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

func (*NetworkConfig_Consumer) Reset 

func (x *NetworkConfig_Consumer) Reset()

func (*NetworkConfig_Consumer) SetEndpointUri 

func (x *NetworkConfig_Consumer) SetEndpointUri(v string)

func (*NetworkConfig_Consumer) SetSubnetwork 

func (x *NetworkConfig_Consumer) SetSubnetwork(v string)

func (*NetworkConfig_Consumer) String 

func (x *NetworkConfig_Consumer) String() string

func (*NetworkConfig_Consumer) WhichVpcResource 

func (x *NetworkConfig_Consumer) WhichVpcResource() case_NetworkConfig_Consumer_VpcResource

type NetworkConfig_Consumer_Subnetwork 

type NetworkConfig_Consumer_Subnetwork struct {
	// Immutable. The subnetwork of the customer project from which an IP
	// address is reserved and used as the Dataproc Metastore service's
	// endpoint. It is accessible to hosts in the subnet and to all
	// hosts in a subnet in the same region and same network. There must
	// be at least one IP address available in the subnet's primary range. The
	// subnet is specified in the following form:
	//
	// `projects/{project_number}/regions/{region_id}/subnetworks/{subnetwork_id}`
	Subnetwork string `protobuf:"bytes,1,opt,name=subnetwork,proto3,oneof"`
}

type NetworkConfig_Consumer_builder 

type NetworkConfig_Consumer_builder struct {

	// Fields of oneof VpcResource:
	// Immutable. The subnetwork of the customer project from which an IP
	// address is reserved and used as the Dataproc Metastore service's
	// endpoint. It is accessible to hosts in the subnet and to all
	// hosts in a subnet in the same region and same network. There must
	// be at least one IP address available in the subnet's primary range. The
	// subnet is specified in the following form:
	//
	// `projects/{project_number}/regions/{region_id}/subnetworks/{subnetwork_id}`
	Subnetwork *string
	// -- end of VpcResource
	// Output only. The URI of the endpoint used to access the metastore
	// service.
	EndpointUri string
	// contains filtered or unexported fields
}

func (NetworkConfig_Consumer_builder) Build 

func (b0 NetworkConfig_Consumer_builder) Build() *NetworkConfig_Consumer

type NetworkConfig_builder 

type NetworkConfig_builder struct {

	// Immutable. The consumer-side network configuration for the Dataproc
	// Metastore instance.
	Consumers []*NetworkConfig_Consumer
	// contains filtered or unexported fields
}

func (NetworkConfig_builder) Build 

func (b0 NetworkConfig_builder) Build() *NetworkConfig

type Restore 

type Restore struct {

	// Output only. The time when the restore started.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Output only. The time when the restore ended.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Output only. The current state of the restore.
	State Restore_State `protobuf:"varint,3,opt,name=state,proto3,enum=google.events.cloud.metastore.v1.Restore_State" json:"state,omitempty"`
	// Output only. The relative resource name of the metastore service backup to
	// restore from, in the following form:
	//
	// `projects/{project_id}/locations/{location_id}/services/{service_id}/backups/{backup_id}`.
	Backup string `protobuf:"bytes,4,opt,name=backup,proto3" json:"backup,omitempty"`
	// Output only. The type of restore.
	Type Restore_RestoreType `protobuf:"varint,5,opt,name=type,proto3,enum=google.events.cloud.metastore.v1.Restore_RestoreType" json:"type,omitempty"`
	// Output only. The restore details containing the revision of the service to
	// be restored to, in format of JSON.
	Details string `protobuf:"bytes,6,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

The details of a metadata restore operation.

func (*Restore) ClearEndTime 

func (x *Restore) ClearEndTime()

func (*Restore) ClearStartTime 

func (x *Restore) ClearStartTime()

func (*Restore) GetBackup 

func (x *Restore) GetBackup() string

func (*Restore) GetDetails 

func (x *Restore) GetDetails() string

func (*Restore) GetEndTime 

func (x *Restore) GetEndTime() *timestamppb.Timestamp

func (*Restore) GetStartTime 

func (x *Restore) GetStartTime() *timestamppb.Timestamp

func (*Restore) GetState 

func (x *Restore) GetState() Restore_State

func (*Restore) GetType 

func (x *Restore) GetType() Restore_RestoreType

func (*Restore) HasEndTime 

func (x *Restore) HasEndTime() bool

func (*Restore) HasStartTime 

func (x *Restore) HasStartTime() bool

func (*Restore) ProtoMessage 

func (*Restore) ProtoMessage()

func (*Restore) ProtoReflect 

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

func (*Restore) Reset 

func (x *Restore) Reset()

func (*Restore) SetBackup 

func (x *Restore) SetBackup(v string)

func (*Restore) SetDetails 

func (x *Restore) SetDetails(v string)

func (*Restore) SetEndTime 

func (x *Restore) SetEndTime(v *timestamppb.Timestamp)

func (*Restore) SetStartTime 

func (x *Restore) SetStartTime(v *timestamppb.Timestamp)

func (*Restore) SetState 

func (x *Restore) SetState(v Restore_State)

func (*Restore) SetType 

func (x *Restore) SetType(v Restore_RestoreType)

func (*Restore) String 

func (x *Restore) String() string

type Restore_RestoreType 

type Restore_RestoreType int32

The type of restore. If unspecified, defaults to `METADATA_ONLY`. 

const (
	// The restore type is unknown.
	Restore_RESTORE_TYPE_UNSPECIFIED Restore_RestoreType = 0
	// The service's metadata and configuration are restored.
	Restore_FULL Restore_RestoreType = 1
	// Only the service's metadata is restored.
	Restore_METADATA_ONLY Restore_RestoreType = 2
)

func (Restore_RestoreType) Descriptor 

func (Restore_RestoreType) Descriptor() protoreflect.EnumDescriptor

func (Restore_RestoreType) Enum 

func (x Restore_RestoreType) Enum() *Restore_RestoreType

func (Restore_RestoreType) Number 

func (x Restore_RestoreType) Number() protoreflect.EnumNumber

func (Restore_RestoreType) String 

func (x Restore_RestoreType) String() string

func (Restore_RestoreType) Type 

func (Restore_RestoreType) Type() protoreflect.EnumType

type Restore_State 

type Restore_State int32

The current state of the restore. 

const (
	// The state of the metadata restore is unknown.
	Restore_STATE_UNSPECIFIED Restore_State = 0
	// The metadata restore is running.
	Restore_RUNNING Restore_State = 1
	// The metadata restore completed successfully.
	Restore_SUCCEEDED Restore_State = 2
	// The metadata restore failed.
	Restore_FAILED Restore_State = 3
	// The metadata restore is cancelled.
	Restore_CANCELLED Restore_State = 4
)

func (Restore_State) Descriptor 

func (Restore_State) Descriptor() protoreflect.EnumDescriptor

func (Restore_State) Enum 

func (x Restore_State) Enum() *Restore_State

func (Restore_State) Number 

func (x Restore_State) Number() protoreflect.EnumNumber

func (Restore_State) String 

func (x Restore_State) String() string

func (Restore_State) Type 

func (Restore_State) Type() protoreflect.EnumType

type Restore_builder 

type Restore_builder struct {

	// Output only. The time when the restore started.
	StartTime *timestamppb.Timestamp
	// Output only. The time when the restore ended.
	EndTime *timestamppb.Timestamp
	// Output only. The current state of the restore.
	State Restore_State
	// Output only. The relative resource name of the metastore service backup to
	// restore from, in the following form:
	//
	// `projects/{project_id}/locations/{location_id}/services/{service_id}/backups/{backup_id}`.
	Backup string
	// Output only. The type of restore.
	Type Restore_RestoreType
	// Output only. The restore details containing the revision of the service to
	// be restored to, in format of JSON.
	Details string
	// contains filtered or unexported fields
}

func (Restore_builder) Build 

func (b0 Restore_builder) Build() *Restore

type ScalingConfig 

type ScalingConfig struct {

	// Represents either a predetermined instance size or a numeric
	// scaling factor.
	//
	// Types that are valid to be assigned to ScalingModel:
	//
	//	*ScalingConfig_InstanceSize_
	//	*ScalingConfig_ScalingFactor
	ScalingModel isScalingConfig_ScalingModel `protobuf_oneof:"scaling_model"`
	// contains filtered or unexported fields
}

Represents the scaling configuration of a metastore service.

func (*ScalingConfig) ClearInstanceSize 

func (x *ScalingConfig) ClearInstanceSize()

func (*ScalingConfig) ClearScalingFactor 

func (x *ScalingConfig) ClearScalingFactor()

func (*ScalingConfig) ClearScalingModel 

func (x *ScalingConfig) ClearScalingModel()

func (*ScalingConfig) GetInstanceSize 

func (x *ScalingConfig) GetInstanceSize() ScalingConfig_InstanceSize

func (*ScalingConfig) GetScalingFactor 

func (x *ScalingConfig) GetScalingFactor() float32

func (*ScalingConfig) GetScalingModel 

func (x *ScalingConfig) GetScalingModel() isScalingConfig_ScalingModel

func (*ScalingConfig) HasInstanceSize 

func (x *ScalingConfig) HasInstanceSize() bool

func (*ScalingConfig) HasScalingFactor 

func (x *ScalingConfig) HasScalingFactor() bool

func (*ScalingConfig) HasScalingModel 

func (x *ScalingConfig) HasScalingModel() bool

func (*ScalingConfig) ProtoMessage 

func (*ScalingConfig) ProtoMessage()

func (*ScalingConfig) ProtoReflect 

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

func (*ScalingConfig) Reset 

func (x *ScalingConfig) Reset()

func (*ScalingConfig) SetInstanceSize 

func (x *ScalingConfig) SetInstanceSize(v ScalingConfig_InstanceSize)

func (*ScalingConfig) SetScalingFactor 

func (x *ScalingConfig) SetScalingFactor(v float32)

func (*ScalingConfig) String 

func (x *ScalingConfig) String() string

func (*ScalingConfig) WhichScalingModel 

func (x *ScalingConfig) WhichScalingModel() case_ScalingConfig_ScalingModel

type ScalingConfig_InstanceSize 

type ScalingConfig_InstanceSize int32

Metastore instance sizes. 

const (
	// Unspecified instance size
	ScalingConfig_INSTANCE_SIZE_UNSPECIFIED ScalingConfig_InstanceSize = 0
	// Extra small instance size, maps to a scaling factor of 0.1.
	ScalingConfig_EXTRA_SMALL ScalingConfig_InstanceSize = 1
	// Small instance size, maps to a scaling factor of 0.5.
	ScalingConfig_SMALL ScalingConfig_InstanceSize = 2
	// Medium instance size, maps to a scaling factor of 1.0.
	ScalingConfig_MEDIUM ScalingConfig_InstanceSize = 3
	// Large instance size, maps to a scaling factor of 3.0.
	ScalingConfig_LARGE ScalingConfig_InstanceSize = 4
	// Extra large instance size, maps to a scaling factor of 6.0.
	ScalingConfig_EXTRA_LARGE ScalingConfig_InstanceSize = 5
)

func (ScalingConfig_InstanceSize) Descriptor 

func (ScalingConfig_InstanceSize) Descriptor() protoreflect.EnumDescriptor

func (ScalingConfig_InstanceSize) Enum 

func (x ScalingConfig_InstanceSize) Enum() *ScalingConfig_InstanceSize

func (ScalingConfig_InstanceSize) Number 

func (x ScalingConfig_InstanceSize) Number() protoreflect.EnumNumber

func (ScalingConfig_InstanceSize) String 

func (x ScalingConfig_InstanceSize) String() string

func (ScalingConfig_InstanceSize) Type 

func (ScalingConfig_InstanceSize) Type() protoreflect.EnumType

type ScalingConfig_InstanceSize_ 

type ScalingConfig_InstanceSize_ struct {
	// An enum of readable instance sizes, with each instance size mapping to a
	// float value (e.g. InstanceSize.EXTRA_SMALL = scaling_factor(0.1))
	InstanceSize ScalingConfig_InstanceSize `` /* 138-byte string literal not displayed */
}

type ScalingConfig_ScalingFactor 

type ScalingConfig_ScalingFactor struct {
	// Scaling factor, increments of 0.1 for values less than 1.0, and
	// increments of 1.0 for values greater than 1.0.
	ScalingFactor float32 `protobuf:"fixed32,2,opt,name=scaling_factor,json=scalingFactor,proto3,oneof"`
}

type ScalingConfig_builder 

type ScalingConfig_builder struct {

	// Fields of oneof ScalingModel:
	// An enum of readable instance sizes, with each instance size mapping to a
	// float value (e.g. InstanceSize.EXTRA_SMALL = scaling_factor(0.1))
	InstanceSize *ScalingConfig_InstanceSize
	// Scaling factor, increments of 0.1 for values less than 1.0, and
	// increments of 1.0 for values greater than 1.0.
	ScalingFactor *float32
	// contains filtered or unexported fields
}

func (ScalingConfig_builder) Build 

func (b0 ScalingConfig_builder) Build() *ScalingConfig

type Secret 

type Secret struct {

	// Types that are valid to be assigned to Value:
	//
	//	*Secret_CloudSecret
	Value isSecret_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

A securely stored value.

func (*Secret) ClearCloudSecret 

func (x *Secret) ClearCloudSecret()

func (*Secret) ClearValue 

func (x *Secret) ClearValue()

func (*Secret) GetCloudSecret 

func (x *Secret) GetCloudSecret() string

func (*Secret) GetValue 

func (x *Secret) GetValue() isSecret_Value

func (*Secret) HasCloudSecret 

func (x *Secret) HasCloudSecret() bool

func (*Secret) HasValue 

func (x *Secret) HasValue() bool

func (*Secret) ProtoMessage 

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect 

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

func (*Secret) Reset 

func (x *Secret) Reset()

func (*Secret) SetCloudSecret 

func (x *Secret) SetCloudSecret(v string)

func (*Secret) String 

func (x *Secret) String() string

func (*Secret) WhichValue 

func (x *Secret) WhichValue() case_Secret_Value

type Secret_CloudSecret 

type Secret_CloudSecret struct {
	// The relative resource name of a Secret Manager secret version, in the
	// following form:
	//
	// `projects/{project_number}/secrets/{secret_id}/versions/{version_id}`.
	CloudSecret string `protobuf:"bytes,2,opt,name=cloud_secret,json=cloudSecret,proto3,oneof"`
}

type Secret_builder 

type Secret_builder struct {

	// Fields of oneof Value:
	// The relative resource name of a Secret Manager secret version, in the
	// following form:
	//
	// `projects/{project_number}/secrets/{secret_id}/versions/{version_id}`.
	CloudSecret *string
	// contains filtered or unexported fields
}

func (Secret_builder) Build 

func (b0 Secret_builder) Build() *Secret

type Service 

type Service struct {

	// Configuration properties specific to the underlying metastore service
	// technology (the software that serves metastore queries).
	//
	// Types that are valid to be assigned to MetastoreConfig:
	//
	//	*Service_HiveMetastoreConfig
	MetastoreConfig isService_MetastoreConfig `protobuf_oneof:"metastore_config"`
	// Immutable. The relative resource name of the metastore service, in the
	// following format:
	//
	// `projects/{project_number}/locations/{location_id}/services/{service_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The time when the metastore service was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time when the metastore service was last updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// User-defined labels for the metastore service.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Immutable. The relative resource name of the VPC network on which the
	// instance can be accessed. It is specified in the following form:
	//
	// `projects/{project_number}/global/networks/{network_id}`.
	Network string `protobuf:"bytes,7,opt,name=network,proto3" json:"network,omitempty"`
	// Output only. The URI of the endpoint used to access the metastore service.
	EndpointUri string `protobuf:"bytes,8,opt,name=endpoint_uri,json=endpointUri,proto3" json:"endpoint_uri,omitempty"`
	// The TCP port at which the metastore service is reached. Default: 9083.
	Port int32 `protobuf:"varint,9,opt,name=port,proto3" json:"port,omitempty"`
	// Output only. The current state of the metastore service.
	State Service_State `protobuf:"varint,10,opt,name=state,proto3,enum=google.events.cloud.metastore.v1.Service_State" json:"state,omitempty"`
	// Output only. Additional information about the current state of the
	// metastore service, if available.
	StateMessage string `protobuf:"bytes,11,opt,name=state_message,json=stateMessage,proto3" json:"state_message,omitempty"`
	// Output only. A Cloud Storage URI (starting with `gs://`) that specifies
	// where artifacts related to the metastore service are stored.
	ArtifactGcsUri string `protobuf:"bytes,12,opt,name=artifact_gcs_uri,json=artifactGcsUri,proto3" json:"artifact_gcs_uri,omitempty"`
	// The tier of the service.
	Tier Service_Tier `protobuf:"varint,13,opt,name=tier,proto3,enum=google.events.cloud.metastore.v1.Service_Tier" json:"tier,omitempty"`
	// The one hour maintenance window of the metastore service. This specifies
	// when the service can be restarted for maintenance purposes in UTC time.
	// Maintenance window is not needed for services with the SPANNER
	// database type.
	MaintenanceWindow *MaintenanceWindow `protobuf:"bytes,15,opt,name=maintenance_window,json=maintenanceWindow,proto3" json:"maintenance_window,omitempty"`
	// Output only. The globally unique resource identifier of the metastore
	// service.
	Uid string `protobuf:"bytes,16,opt,name=uid,proto3" json:"uid,omitempty"`
	// Output only. The metadata management activities of the metastore service.
	MetadataManagementActivity *MetadataManagementActivity `` /* 142-byte string literal not displayed */
	// Immutable. The release channel of the service.
	// If unspecified, defaults to `STABLE`.
	ReleaseChannel Service_ReleaseChannel `` /* 166-byte string literal not displayed */
	// Immutable. Information used to configure the Dataproc Metastore service to
	// encrypt customer data at rest. Cannot be updated.
	EncryptionConfig *EncryptionConfig `protobuf:"bytes,20,opt,name=encryption_config,json=encryptionConfig,proto3" json:"encryption_config,omitempty"`
	// The configuration specifying the network settings for the
	// Dataproc Metastore service.
	NetworkConfig *NetworkConfig `protobuf:"bytes,21,opt,name=network_config,json=networkConfig,proto3" json:"network_config,omitempty"`
	// Immutable. The database type that the Metastore service stores its data.
	DatabaseType Service_DatabaseType `` /* 158-byte string literal not displayed */
	// The configuration specifying telemetry settings for the Dataproc Metastore
	// service. If unspecified defaults to `JSON`.
	TelemetryConfig *TelemetryConfig `protobuf:"bytes,23,opt,name=telemetry_config,json=telemetryConfig,proto3" json:"telemetry_config,omitempty"`
	// Scaling configuration of the metastore service.
	ScalingConfig *ScalingConfig `protobuf:"bytes,24,opt,name=scaling_config,json=scalingConfig,proto3" json:"scaling_config,omitempty"`
	// contains filtered or unexported fields
}

A managed metastore service that serves metadata queries.

func (*Service) ClearCreateTime 

func (x *Service) ClearCreateTime()

func (*Service) ClearEncryptionConfig 

func (x *Service) ClearEncryptionConfig()

func (*Service) ClearHiveMetastoreConfig 

func (x *Service) ClearHiveMetastoreConfig()

func (*Service) ClearMaintenanceWindow 

func (x *Service) ClearMaintenanceWindow()

func (*Service) ClearMetadataManagementActivity 

func (x *Service) ClearMetadataManagementActivity()

func (*Service) ClearMetastoreConfig 

func (x *Service) ClearMetastoreConfig()

func (*Service) ClearNetworkConfig 

func (x *Service) ClearNetworkConfig()

func (*Service) ClearScalingConfig 

func (x *Service) ClearScalingConfig()

func (*Service) ClearTelemetryConfig 

func (x *Service) ClearTelemetryConfig()

func (*Service) ClearUpdateTime 

func (x *Service) ClearUpdateTime()

func (*Service) GetArtifactGcsUri 

func (x *Service) GetArtifactGcsUri() string

func (*Service) GetCreateTime 

func (x *Service) GetCreateTime() *timestamppb.Timestamp

func (*Service) GetDatabaseType 

func (x *Service) GetDatabaseType() Service_DatabaseType

func (*Service) GetEncryptionConfig 

func (x *Service) GetEncryptionConfig() *EncryptionConfig

func (*Service) GetEndpointUri 

func (x *Service) GetEndpointUri() string

func (*Service) GetHiveMetastoreConfig 

func (x *Service) GetHiveMetastoreConfig() *HiveMetastoreConfig

func (*Service) GetLabels 

func (x *Service) GetLabels() map[string]string

func (*Service) GetMaintenanceWindow 

func (x *Service) GetMaintenanceWindow() *MaintenanceWindow

func (*Service) GetMetadataManagementActivity 

func (x *Service) GetMetadataManagementActivity() *MetadataManagementActivity

func (*Service) GetMetastoreConfig 

func (x *Service) GetMetastoreConfig() isService_MetastoreConfig

func (*Service) GetName 

func (x *Service) GetName() string

func (*Service) GetNetwork 

func (x *Service) GetNetwork() string

func (*Service) GetNetworkConfig 

func (x *Service) GetNetworkConfig() *NetworkConfig

func (*Service) GetPort 

func (x *Service) GetPort() int32

func (*Service) GetReleaseChannel 

func (x *Service) GetReleaseChannel() Service_ReleaseChannel

func (*Service) GetScalingConfig 

func (x *Service) GetScalingConfig() *ScalingConfig

func (*Service) GetState 

func (x *Service) GetState() Service_State

func (*Service) GetStateMessage 

func (x *Service) GetStateMessage() string

func (*Service) GetTelemetryConfig 

func (x *Service) GetTelemetryConfig() *TelemetryConfig

func (*Service) GetTier 

func (x *Service) GetTier() Service_Tier

func (*Service) GetUid 

func (x *Service) GetUid() string

func (*Service) GetUpdateTime 

func (x *Service) GetUpdateTime() *timestamppb.Timestamp

func (*Service) HasCreateTime 

func (x *Service) HasCreateTime() bool

func (*Service) HasEncryptionConfig 

func (x *Service) HasEncryptionConfig() bool

func (*Service) HasHiveMetastoreConfig 

func (x *Service) HasHiveMetastoreConfig() bool

func (*Service) HasMaintenanceWindow 

func (x *Service) HasMaintenanceWindow() bool

func (*Service) HasMetadataManagementActivity 

func (x *Service) HasMetadataManagementActivity() bool

func (*Service) HasMetastoreConfig 

func (x *Service) HasMetastoreConfig() bool

func (*Service) HasNetworkConfig 

func (x *Service) HasNetworkConfig() bool

func (*Service) HasScalingConfig 

func (x *Service) HasScalingConfig() bool

func (*Service) HasTelemetryConfig 

func (x *Service) HasTelemetryConfig() bool

func (*Service) HasUpdateTime 

func (x *Service) HasUpdateTime() bool

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

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

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) SetArtifactGcsUri 

func (x *Service) SetArtifactGcsUri(v string)

func (*Service) SetCreateTime 

func (x *Service) SetCreateTime(v *timestamppb.Timestamp)

func (*Service) SetDatabaseType 

func (x *Service) SetDatabaseType(v Service_DatabaseType)

func (*Service) SetEncryptionConfig 

func (x *Service) SetEncryptionConfig(v *EncryptionConfig)

func (*Service) SetEndpointUri 

func (x *Service) SetEndpointUri(v string)

func (*Service) SetHiveMetastoreConfig 

func (x *Service) SetHiveMetastoreConfig(v *HiveMetastoreConfig)

func (*Service) SetLabels 

func (x *Service) SetLabels(v map[string]string)

func (*Service) SetMaintenanceWindow 

func (x *Service) SetMaintenanceWindow(v *MaintenanceWindow)

func (*Service) SetMetadataManagementActivity 

func (x *Service) SetMetadataManagementActivity(v *MetadataManagementActivity)

func (*Service) SetName 

func (x *Service) SetName(v string)

func (*Service) SetNetwork 

func (x *Service) SetNetwork(v string)

func (*Service) SetNetworkConfig 

func (x *Service) SetNetworkConfig(v *NetworkConfig)

func (*Service) SetPort 

func (x *Service) SetPort(v int32)

func (*Service) SetReleaseChannel 

func (x *Service) SetReleaseChannel(v Service_ReleaseChannel)

func (*Service) SetScalingConfig 

func (x *Service) SetScalingConfig(v *ScalingConfig)

func (*Service) SetState 

func (x *Service) SetState(v Service_State)

func (*Service) SetStateMessage 

func (x *Service) SetStateMessage(v string)

func (*Service) SetTelemetryConfig 

func (x *Service) SetTelemetryConfig(v *TelemetryConfig)

func (*Service) SetTier 

func (x *Service) SetTier(v Service_Tier)

func (*Service) SetUid 

func (x *Service) SetUid(v string)

func (*Service) SetUpdateTime 

func (x *Service) SetUpdateTime(v *timestamppb.Timestamp)

func (*Service) String 

func (x *Service) String() string

func (*Service) WhichMetastoreConfig 

func (x *Service) WhichMetastoreConfig() case_Service_MetastoreConfig

type ServiceCreatedEvent 

type ServiceCreatedEvent struct {

	// The data associated with the event.
	Data *ServiceEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Service is created.

func (*ServiceCreatedEvent) ClearData 

func (x *ServiceCreatedEvent) ClearData()

func (*ServiceCreatedEvent) GetData 

func (x *ServiceCreatedEvent) GetData() *ServiceEventData

func (*ServiceCreatedEvent) HasData 

func (x *ServiceCreatedEvent) HasData() bool

func (*ServiceCreatedEvent) ProtoMessage 

func (*ServiceCreatedEvent) ProtoMessage()

func (*ServiceCreatedEvent) ProtoReflect 

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

func (*ServiceCreatedEvent) Reset 

func (x *ServiceCreatedEvent) Reset()

func (*ServiceCreatedEvent) SetData 

func (x *ServiceCreatedEvent) SetData(v *ServiceEventData)

func (*ServiceCreatedEvent) String 

func (x *ServiceCreatedEvent) String() string

type ServiceCreatedEvent_builder 

type ServiceCreatedEvent_builder struct {

	// The data associated with the event.
	Data *ServiceEventData
	// contains filtered or unexported fields
}

func (ServiceCreatedEvent_builder) Build 

func (b0 ServiceCreatedEvent_builder) Build() *ServiceCreatedEvent

type ServiceDeletedEvent 

type ServiceDeletedEvent struct {

	// The data associated with the event.
	Data *ServiceEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Service is deleted.

func (*ServiceDeletedEvent) ClearData 

func (x *ServiceDeletedEvent) ClearData()

func (*ServiceDeletedEvent) GetData 

func (x *ServiceDeletedEvent) GetData() *ServiceEventData

func (*ServiceDeletedEvent) HasData 

func (x *ServiceDeletedEvent) HasData() bool

func (*ServiceDeletedEvent) ProtoMessage 

func (*ServiceDeletedEvent) ProtoMessage()

func (*ServiceDeletedEvent) ProtoReflect 

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

func (*ServiceDeletedEvent) Reset 

func (x *ServiceDeletedEvent) Reset()

func (*ServiceDeletedEvent) SetData 

func (x *ServiceDeletedEvent) SetData(v *ServiceEventData)

func (*ServiceDeletedEvent) String 

func (x *ServiceDeletedEvent) String() string

type ServiceDeletedEvent_builder 

type ServiceDeletedEvent_builder struct {

	// The data associated with the event.
	Data *ServiceEventData
	// contains filtered or unexported fields
}

func (ServiceDeletedEvent_builder) Build 

func (b0 ServiceDeletedEvent_builder) Build() *ServiceDeletedEvent

type ServiceEventData 

type ServiceEventData struct {

	// Optional. The Service event payload. Unset for deletion events.
	Payload *Service `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Service events.

func (*ServiceEventData) ClearPayload 

func (x *ServiceEventData) ClearPayload()

func (*ServiceEventData) GetPayload 

func (x *ServiceEventData) GetPayload() *Service

func (*ServiceEventData) HasPayload 

func (x *ServiceEventData) HasPayload() bool

func (*ServiceEventData) ProtoMessage 

func (*ServiceEventData) ProtoMessage()

func (*ServiceEventData) ProtoReflect 

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

func (*ServiceEventData) Reset 

func (x *ServiceEventData) Reset()

func (*ServiceEventData) SetPayload 

func (x *ServiceEventData) SetPayload(v *Service)

func (*ServiceEventData) String 

func (x *ServiceEventData) String() string

type ServiceEventData_builder 

type ServiceEventData_builder struct {

	// Optional. The Service event payload. Unset for deletion events.
	Payload *Service
	// contains filtered or unexported fields
}

func (ServiceEventData_builder) Build 

func (b0 ServiceEventData_builder) Build() *ServiceEventData

type ServiceUpdatedEvent 

type ServiceUpdatedEvent struct {

	// The data associated with the event.
	Data *ServiceEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Service is updated.

func (*ServiceUpdatedEvent) ClearData 

func (x *ServiceUpdatedEvent) ClearData()

func (*ServiceUpdatedEvent) GetData 

func (x *ServiceUpdatedEvent) GetData() *ServiceEventData

func (*ServiceUpdatedEvent) HasData 

func (x *ServiceUpdatedEvent) HasData() bool

func (*ServiceUpdatedEvent) ProtoMessage 

func (*ServiceUpdatedEvent) ProtoMessage()

func (*ServiceUpdatedEvent) ProtoReflect 

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

func (*ServiceUpdatedEvent) Reset 

func (x *ServiceUpdatedEvent) Reset()

func (*ServiceUpdatedEvent) SetData 

func (x *ServiceUpdatedEvent) SetData(v *ServiceEventData)

func (*ServiceUpdatedEvent) String 

func (x *ServiceUpdatedEvent) String() string

type ServiceUpdatedEvent_builder 

type ServiceUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *ServiceEventData
	// contains filtered or unexported fields
}

func (ServiceUpdatedEvent_builder) Build 

func (b0 ServiceUpdatedEvent_builder) Build() *ServiceUpdatedEvent

type Service_DatabaseType 

type Service_DatabaseType int32

The backend database type for the metastore service. 

const (
	// The DATABASE_TYPE is not set.
	Service_DATABASE_TYPE_UNSPECIFIED Service_DatabaseType = 0
	// MySQL is used to persist the metastore data.
	Service_MYSQL Service_DatabaseType = 1
	// Spanner is used to persist the metastore data.
	Service_SPANNER Service_DatabaseType = 2
)

func (Service_DatabaseType) Descriptor 

func (Service_DatabaseType) Descriptor() protoreflect.EnumDescriptor

func (Service_DatabaseType) Enum 

func (x Service_DatabaseType) Enum() *Service_DatabaseType

func (Service_DatabaseType) Number 

func (x Service_DatabaseType) Number() protoreflect.EnumNumber

func (Service_DatabaseType) String 

func (x Service_DatabaseType) String() string

func (Service_DatabaseType) Type 

func (Service_DatabaseType) Type() protoreflect.EnumType

type Service_HiveMetastoreConfig 

type Service_HiveMetastoreConfig struct {
	// Configuration information specific to running Hive metastore
	// software as the metastore service.
	HiveMetastoreConfig *HiveMetastoreConfig `protobuf:"bytes,5,opt,name=hive_metastore_config,json=hiveMetastoreConfig,proto3,oneof"`
}

type Service_ReleaseChannel 

type Service_ReleaseChannel int32

Release channels bundle features of varying levels of stability. Newer features may be introduced initially into less stable release channels and can be automatically promoted into more stable release channels. 

const (
	// Release channel is not specified.
	Service_RELEASE_CHANNEL_UNSPECIFIED Service_ReleaseChannel = 0
	// The `CANARY` release channel contains the newest features, which may be
	// unstable and subject to unresolved issues with no known workarounds.
	// Services using the `CANARY` release channel are not subject to any SLAs.
	Service_CANARY Service_ReleaseChannel = 1
	// The `STABLE` release channel contains features that are considered stable
	// and have been validated for production use.
	Service_STABLE Service_ReleaseChannel = 2
)

func (Service_ReleaseChannel) Descriptor 

func (Service_ReleaseChannel) Descriptor() protoreflect.EnumDescriptor

func (Service_ReleaseChannel) Enum 

func (x Service_ReleaseChannel) Enum() *Service_ReleaseChannel

func (Service_ReleaseChannel) Number 

func (x Service_ReleaseChannel) Number() protoreflect.EnumNumber

func (Service_ReleaseChannel) String 

func (x Service_ReleaseChannel) String() string

func (Service_ReleaseChannel) Type 

func (Service_ReleaseChannel) Type() protoreflect.EnumType

type Service_State 

type Service_State int32

The current state of the metastore service. 

const (
	// The state of the metastore service is unknown.
	Service_STATE_UNSPECIFIED Service_State = 0
	// The metastore service is in the process of being created.
	Service_CREATING Service_State = 1
	// The metastore service is running and ready to serve queries.
	Service_ACTIVE Service_State = 2
	// The metastore service is entering suspension. Its query-serving
	// availability may cease unexpectedly.
	Service_SUSPENDING Service_State = 3
	// The metastore service is suspended and unable to serve queries.
	Service_SUSPENDED Service_State = 4
	// The metastore service is being updated. It remains usable but cannot
	// accept additional update requests or be deleted at this time.
	Service_UPDATING Service_State = 5
	// The metastore service is undergoing deletion. It cannot be used.
	Service_DELETING Service_State = 6
	// The metastore service has encountered an error and cannot be used. The
	// metastore service should be deleted.
	Service_ERROR Service_State = 7
)

func (Service_State) Descriptor 

func (Service_State) Descriptor() protoreflect.EnumDescriptor

func (Service_State) Enum 

func (x Service_State) Enum() *Service_State

func (Service_State) Number 

func (x Service_State) Number() protoreflect.EnumNumber

func (Service_State) String 

func (x Service_State) String() string

func (Service_State) Type 

func (Service_State) Type() protoreflect.EnumType

type Service_Tier 

type Service_Tier int32

Available service tiers. 

const (
	// The tier is not set.
	Service_TIER_UNSPECIFIED Service_Tier = 0
	// The developer tier provides limited scalability and no fault tolerance.
	// Good for low-cost proof-of-concept.
	Service_DEVELOPER Service_Tier = 1
	// The enterprise tier provides multi-zone high availability, and sufficient
	// scalability for enterprise-level Dataproc Metastore workloads.
	Service_ENTERPRISE Service_Tier = 3
)

func (Service_Tier) Descriptor 

func (Service_Tier) Descriptor() protoreflect.EnumDescriptor

func (Service_Tier) Enum 

func (x Service_Tier) Enum() *Service_Tier

func (Service_Tier) Number 

func (x Service_Tier) Number() protoreflect.EnumNumber

func (Service_Tier) String 

func (x Service_Tier) String() string

func (Service_Tier) Type 

func (Service_Tier) Type() protoreflect.EnumType

type Service_builder 

type Service_builder struct {

	// Fields of oneof MetastoreConfig:
	// Configuration information specific to running Hive metastore
	// software as the metastore service.
	HiveMetastoreConfig *HiveMetastoreConfig
	// -- end of MetastoreConfig
	// Immutable. The relative resource name of the metastore service, in the
	// following format:
	//
	// `projects/{project_number}/locations/{location_id}/services/{service_id}`.
	Name string
	// Output only. The time when the metastore service was created.
	CreateTime *timestamppb.Timestamp
	// Output only. The time when the metastore service was last updated.
	UpdateTime *timestamppb.Timestamp
	// User-defined labels for the metastore service.
	Labels map[string]string
	// Immutable. The relative resource name of the VPC network on which the
	// instance can be accessed. It is specified in the following form:
	//
	// `projects/{project_number}/global/networks/{network_id}`.
	Network string
	// Output only. The URI of the endpoint used to access the metastore service.
	EndpointUri string
	// The TCP port at which the metastore service is reached. Default: 9083.
	Port int32
	// Output only. The current state of the metastore service.
	State Service_State
	// Output only. Additional information about the current state of the
	// metastore service, if available.
	StateMessage string
	// Output only. A Cloud Storage URI (starting with `gs://`) that specifies
	// where artifacts related to the metastore service are stored.
	ArtifactGcsUri string
	// The tier of the service.
	Tier Service_Tier
	// The one hour maintenance window of the metastore service. This specifies
	// when the service can be restarted for maintenance purposes in UTC time.
	// Maintenance window is not needed for services with the SPANNER
	// database type.
	MaintenanceWindow *MaintenanceWindow
	// Output only. The globally unique resource identifier of the metastore
	// service.
	Uid string
	// Output only. The metadata management activities of the metastore service.
	MetadataManagementActivity *MetadataManagementActivity
	// Immutable. The release channel of the service.
	// If unspecified, defaults to `STABLE`.
	ReleaseChannel Service_ReleaseChannel
	// Immutable. Information used to configure the Dataproc Metastore service to
	// encrypt customer data at rest. Cannot be updated.
	EncryptionConfig *EncryptionConfig
	// The configuration specifying the network settings for the
	// Dataproc Metastore service.
	NetworkConfig *NetworkConfig
	// Immutable. The database type that the Metastore service stores its data.
	DatabaseType Service_DatabaseType
	// The configuration specifying telemetry settings for the Dataproc Metastore
	// service. If unspecified defaults to `JSON`.
	TelemetryConfig *TelemetryConfig
	// Scaling configuration of the metastore service.
	ScalingConfig *ScalingConfig
	// contains filtered or unexported fields
}

func (Service_builder) Build 

func (b0 Service_builder) Build() *Service

type TelemetryConfig 

type TelemetryConfig struct {

	// The output format of the Dataproc Metastore service's logs.
	LogFormat TelemetryConfig_LogFormat `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Telemetry Configuration for the Dataproc Metastore service.

func (*TelemetryConfig) GetLogFormat 

func (x *TelemetryConfig) GetLogFormat() TelemetryConfig_LogFormat

func (*TelemetryConfig) ProtoMessage 

func (*TelemetryConfig) ProtoMessage()

func (*TelemetryConfig) ProtoReflect 

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

func (*TelemetryConfig) Reset 

func (x *TelemetryConfig) Reset()

func (*TelemetryConfig) SetLogFormat 

func (x *TelemetryConfig) SetLogFormat(v TelemetryConfig_LogFormat)

func (*TelemetryConfig) String 

func (x *TelemetryConfig) String() string

type TelemetryConfig_LogFormat 

type TelemetryConfig_LogFormat int32
const (
	// The LOG_FORMAT is not set.
	TelemetryConfig_LOG_FORMAT_UNSPECIFIED TelemetryConfig_LogFormat = 0
	// Logging output uses the legacy `textPayload` format.
	TelemetryConfig_LEGACY TelemetryConfig_LogFormat = 1
	// Logging output uses the `jsonPayload` format.
	TelemetryConfig_JSON TelemetryConfig_LogFormat = 2
)

func (TelemetryConfig_LogFormat) Descriptor 

func (TelemetryConfig_LogFormat) Descriptor() protoreflect.EnumDescriptor

func (TelemetryConfig_LogFormat) Enum 

func (x TelemetryConfig_LogFormat) Enum() *TelemetryConfig_LogFormat

func (TelemetryConfig_LogFormat) Number 

func (x TelemetryConfig_LogFormat) Number() protoreflect.EnumNumber

func (TelemetryConfig_LogFormat) String 

func (x TelemetryConfig_LogFormat) String() string

func (TelemetryConfig_LogFormat) Type 

func (TelemetryConfig_LogFormat) Type() protoreflect.EnumType

type TelemetryConfig_builder 

type TelemetryConfig_builder struct {

	// The output format of the Dataproc Metastore service's logs.
	LogFormat TelemetryConfig_LogFormat
	// contains filtered or unexported fields
}

func (TelemetryConfig_builder) Build 

func (b0 TelemetryConfig_builder) Build() *TelemetryConfig

Source Files

  • data.pb.go
  • events.pb.go

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.