logging

package
v0.0.0-...-8f55acc Latest Latest
Warning

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

 Go to latest Published: Aug 3, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DatabaseEngine_name = map[int32]string{
		0: "DATABASE_ENGINE_UNSPECIFIED",
		1: "MYSQL",
		2: "POSTGRESQL",
		3: "SQLSERVER",
	}
	DatabaseEngine_value = map[string]int32{
		"DATABASE_ENGINE_UNSPECIFIED": 0,
		"MYSQL":                       1,
		"POSTGRESQL":                  2,
		"SQLSERVER":                   3,
	}
)

Enum value maps for DatabaseEngine.

View Source 
var (
	DatabaseProvider_name = map[int32]string{
		0: "DATABASE_PROVIDER_UNSPECIFIED",
		1: "CLOUDSQL",
		2: "RDS",
	}
	DatabaseProvider_value = map[string]int32{
		"DATABASE_PROVIDER_UNSPECIFIED": 0,
		"CLOUDSQL":                      1,
		"RDS":                           2,
	}
)

Enum value maps for DatabaseProvider.

View Source 
var (
	LoggedMigrationJob_State_name = map[int32]string{
		0:  "STATE_UNSPECIFIED",
		1:  "MAINTENANCE",
		2:  "DRAFT",
		3:  "CREATING",
		4:  "NOT_STARTED",
		5:  "RUNNING",
		6:  "FAILED",
		7:  "COMPLETED",
		8:  "DELETING",
		9:  "STOPPING",
		10: "STOPPED",
		11: "DELETED",
		12: "UPDATING",
		13: "STARTING",
		14: "RESTARTING",
		15: "RESUMING",
	}
	LoggedMigrationJob_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"MAINTENANCE":       1,
		"DRAFT":             2,
		"CREATING":          3,
		"NOT_STARTED":       4,
		"RUNNING":           5,
		"FAILED":            6,
		"COMPLETED":         7,
		"DELETING":          8,
		"STOPPING":          9,
		"STOPPED":           10,
		"DELETED":           11,
		"UPDATING":          12,
		"STARTING":          13,
		"RESTARTING":        14,
		"RESUMING":          15,
	}
)

Enum value maps for LoggedMigrationJob_State.

View Source 
var (
	LoggedMigrationJob_Phase_name = map[int32]string{
		0: "PHASE_UNSPECIFIED",
		1: "FULL_DUMP",
		2: "CDC",
		3: "PROMOTE_IN_PROGRESS",
		4: "WAITING_FOR_SOURCE_WRITES_TO_STOP",
		5: "PREPARING_THE_DUMP",
	}
	LoggedMigrationJob_Phase_value = map[string]int32{
		"PHASE_UNSPECIFIED":                 0,
		"FULL_DUMP":                         1,
		"CDC":                               2,
		"PROMOTE_IN_PROGRESS":               3,
		"WAITING_FOR_SOURCE_WRITES_TO_STOP": 4,
		"PREPARING_THE_DUMP":                5,
	}
)

Enum value maps for LoggedMigrationJob_Phase.

View Source 
var (
	LoggedMigrationJob_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "ONE_TIME",
		2: "CONTINUOUS",
	}
	LoggedMigrationJob_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"ONE_TIME":         1,
		"CONTINUOUS":       2,
	}
)

Enum value maps for LoggedMigrationJob_Type.

View Source 
var (
	LoggedMigrationJob_ConnectivityType_name = map[int32]string{
		0: "CONNECTIVITY_TYPE_UNSPECIFIED",
		1: "STATIC_IP",
		2: "REVERSE_SSH",
		3: "VPC_PEERING",
	}
	LoggedMigrationJob_ConnectivityType_value = map[string]int32{
		"CONNECTIVITY_TYPE_UNSPECIFIED": 0,
		"STATIC_IP":                     1,
		"REVERSE_SSH":                   2,
		"VPC_PEERING":                   3,
	}
)

Enum value maps for LoggedMigrationJob_ConnectivityType.

View Source 
var (
	MySqlConnectionProfile_Version_name = map[int32]string{
		0: "VERSION_UNSPECIFIED",
		1: "V5_5",
		2: "V5_6",
		3: "V5_7",
		4: "V8_0",
	}
	MySqlConnectionProfile_Version_value = map[string]int32{
		"VERSION_UNSPECIFIED": 0,
		"V5_5":                1,
		"V5_6":                2,
		"V5_7":                3,
		"V8_0":                4,
	}
)

Enum value maps for MySqlConnectionProfile_Version.

View Source 
var (
	PostgreSqlConnectionProfile_Version_name = map[int32]string{
		0: "VERSION_UNSPECIFIED",
		1: "V9_6",
		2: "V11",
		3: "V10",
		4: "V12",
		5: "V13",
	}
	PostgreSqlConnectionProfile_Version_value = map[string]int32{
		"VERSION_UNSPECIFIED": 0,
		"V9_6":                1,
		"V11":                 2,
		"V10":                 3,
		"V12":                 4,
		"V13":                 5,
	}
)

Enum value maps for PostgreSqlConnectionProfile_Version.

View Source 
var (
	LoggedConnectionProfile_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "DRAFT",
		2: "CREATING",
		3: "READY",
		4: "UPDATING",
		5: "DELETING",
		6: "DELETED",
		7: "FAILED",
	}
	LoggedConnectionProfile_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"DRAFT":             1,
		"CREATING":          2,
		"READY":             3,
		"UPDATING":          4,
		"DELETING":          5,
		"DELETED":           6,
		"FAILED":            7,
	}
)

Enum value maps for LoggedConnectionProfile_State.

View Source 
var File_google_cloud_clouddms_logging_v1_clouddms_platform_logs_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CloudSqlConnectionProfile 

type CloudSqlConnectionProfile struct {

	// The Cloud SQL id.
	CloudSqlId string `protobuf:"bytes,1,opt,name=cloud_sql_id,json=cloudSqlId,proto3" json:"cloud_sql_id,omitempty"`
	// contains filtered or unexported fields
}

A CloudSQL connection profile.

func (*CloudSqlConnectionProfile) Descriptor deprecated 

func (*CloudSqlConnectionProfile) Descriptor() ([]byte, []int)

Deprecated: Use CloudSqlConnectionProfile.ProtoReflect.Descriptor instead.

func (*CloudSqlConnectionProfile) GetCloudSqlId 

func (x *CloudSqlConnectionProfile) GetCloudSqlId() string

func (*CloudSqlConnectionProfile) ProtoMessage 

func (*CloudSqlConnectionProfile) ProtoMessage()

func (*CloudSqlConnectionProfile) ProtoReflect 

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

func (*CloudSqlConnectionProfile) Reset 

func (x *CloudSqlConnectionProfile) Reset()

func (*CloudSqlConnectionProfile) String 

func (x *CloudSqlConnectionProfile) String() string

type ConnectionProfileEventLog 

type ConnectionProfileEventLog struct {

	// The connection profilr resource
	ConnectionProfile *LoggedConnectionProfile `protobuf:"bytes,1,opt,name=connection_profile,json=connectionProfile,proto3" json:"connection_profile,omitempty"`
	// Timestamp of the event
	OccurrenceTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=occurrence_timestamp,json=occurrenceTimestamp,proto3" json:"occurrence_timestamp,omitempty"`
	// Event code
	Code int32 `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`
	// Event message
	TextMessage string `protobuf:"bytes,4,opt,name=text_message,json=textMessage,proto3" json:"text_message,omitempty"`
	// Original event data
	//
	// Types that are assignable to OriginalCause:
	//	*ConnectionProfileEventLog_OriginalCode
	//	*ConnectionProfileEventLog_OriginalMessage
	OriginalCause isConnectionProfileEventLog_OriginalCause `protobuf_oneof:"original_cause"`
	// contains filtered or unexported fields
}

Log definition for Connection Profile event

func (*ConnectionProfileEventLog) Descriptor deprecated 

func (*ConnectionProfileEventLog) Descriptor() ([]byte, []int)

Deprecated: Use ConnectionProfileEventLog.ProtoReflect.Descriptor instead.

func (*ConnectionProfileEventLog) GetCode 

func (x *ConnectionProfileEventLog) GetCode() int32

func (*ConnectionProfileEventLog) GetConnectionProfile 

func (x *ConnectionProfileEventLog) GetConnectionProfile() *LoggedConnectionProfile

func (*ConnectionProfileEventLog) GetOccurrenceTimestamp 

func (x *ConnectionProfileEventLog) GetOccurrenceTimestamp() *timestamppb.Timestamp

func (*ConnectionProfileEventLog) GetOriginalCause 

func (m *ConnectionProfileEventLog) GetOriginalCause() isConnectionProfileEventLog_OriginalCause

func (*ConnectionProfileEventLog) GetOriginalCode 

func (x *ConnectionProfileEventLog) GetOriginalCode() int32

func (*ConnectionProfileEventLog) GetOriginalMessage 

func (x *ConnectionProfileEventLog) GetOriginalMessage() string

func (*ConnectionProfileEventLog) GetTextMessage 

func (x *ConnectionProfileEventLog) GetTextMessage() string

func (*ConnectionProfileEventLog) ProtoMessage 

func (*ConnectionProfileEventLog) ProtoMessage()

func (*ConnectionProfileEventLog) ProtoReflect 

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

func (*ConnectionProfileEventLog) Reset 

func (x *ConnectionProfileEventLog) Reset()

func (*ConnectionProfileEventLog) String 

func (x *ConnectionProfileEventLog) String() string

type ConnectionProfileEventLog_OriginalCode 

type ConnectionProfileEventLog_OriginalCode struct {
	// Original event code
	OriginalCode int32 `protobuf:"varint,200,opt,name=original_code,json=originalCode,proto3,oneof"`
}

type ConnectionProfileEventLog_OriginalMessage 

type ConnectionProfileEventLog_OriginalMessage struct {
	// Original event message
	OriginalMessage string `protobuf:"bytes,201,opt,name=original_message,json=originalMessage,proto3,oneof"`
}

type DatabaseEngine 

type DatabaseEngine int32

The database engines. 

const (
	// The source database engine of the migration job is unknown.
	DatabaseEngine_DATABASE_ENGINE_UNSPECIFIED DatabaseEngine = 0
	// The source engine is MySQL.
	DatabaseEngine_MYSQL DatabaseEngine = 1
	// The source engine is PostgreSQL.
	DatabaseEngine_POSTGRESQL DatabaseEngine = 2
	// The source engine is SQL Server.
	DatabaseEngine_SQLSERVER DatabaseEngine = 3
)

func (DatabaseEngine) Descriptor 

func (DatabaseEngine) Descriptor() protoreflect.EnumDescriptor

func (DatabaseEngine) Enum 

func (x DatabaseEngine) Enum() *DatabaseEngine

func (DatabaseEngine) EnumDescriptor deprecated 

func (DatabaseEngine) EnumDescriptor() ([]byte, []int)

Deprecated: Use DatabaseEngine.Descriptor instead.

func (DatabaseEngine) Number 

func (x DatabaseEngine) Number() protoreflect.EnumNumber

func (DatabaseEngine) String 

func (x DatabaseEngine) String() string

func (DatabaseEngine) Type 

func (DatabaseEngine) Type() protoreflect.EnumType

type DatabaseProvider 

type DatabaseProvider int32

The database providers. 

const (
	// The database provider is unknown.
	DatabaseProvider_DATABASE_PROVIDER_UNSPECIFIED DatabaseProvider = 0
	// CloudSQL runs the database.
	DatabaseProvider_CLOUDSQL DatabaseProvider = 1
	// RDS runs the database.
	DatabaseProvider_RDS DatabaseProvider = 2
)

func (DatabaseProvider) Descriptor 

func (DatabaseProvider) Descriptor() protoreflect.EnumDescriptor

func (DatabaseProvider) Enum 

func (x DatabaseProvider) Enum() *DatabaseProvider

func (DatabaseProvider) EnumDescriptor deprecated 

func (DatabaseProvider) EnumDescriptor() ([]byte, []int)

Deprecated: Use DatabaseProvider.Descriptor instead.

func (DatabaseProvider) Number 

func (x DatabaseProvider) Number() protoreflect.EnumNumber

func (DatabaseProvider) String 

func (x DatabaseProvider) String() string

func (DatabaseProvider) Type 

func (DatabaseProvider) Type() protoreflect.EnumType

type DatabaseType 

type DatabaseType struct {

	// The database provider.
	Provider DatabaseProvider `protobuf:"varint,1,opt,name=provider,proto3,enum=google.cloud.clouddms.logging.v1.DatabaseProvider" json:"provider,omitempty"`
	// The database engine.
	Engine DatabaseEngine `protobuf:"varint,2,opt,name=engine,proto3,enum=google.cloud.clouddms.logging.v1.DatabaseEngine" json:"engine,omitempty"`
	// contains filtered or unexported fields
}

A message defining the database engine and provider.

func (*DatabaseType) Descriptor deprecated 

func (*DatabaseType) Descriptor() ([]byte, []int)

Deprecated: Use DatabaseType.ProtoReflect.Descriptor instead.

func (*DatabaseType) GetEngine 

func (x *DatabaseType) GetEngine() DatabaseEngine

func (*DatabaseType) GetProvider 

func (x *DatabaseType) GetProvider() DatabaseProvider

func (*DatabaseType) ProtoMessage 

func (*DatabaseType) ProtoMessage()

func (*DatabaseType) ProtoReflect 

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

func (*DatabaseType) Reset 

func (x *DatabaseType) Reset()

func (*DatabaseType) String 

func (x *DatabaseType) String() string

type LoggedConnectionProfile 

type LoggedConnectionProfile struct {

	// The unique identifier for a connection profile.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// The current connection profile state.
	State LoggedConnectionProfile_State `` /* 132-byte string literal not displayed */
	// The display name.
	DisplayName string `protobuf:"bytes,4,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// The connection profile definition
	//
	// Types that are assignable to ConnectionProfile:
	//	*LoggedConnectionProfile_Mysql
	//	*LoggedConnectionProfile_Postgresql
	//	*LoggedConnectionProfile_Cloudsql
	ConnectionProfile isLoggedConnectionProfile_ConnectionProfile `protobuf_oneof:"connection_profile"`
	// The error details in case of state FAILED.
	Error *status.Status `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// The database provider.
	Provider DatabaseProvider `protobuf:"varint,6,opt,name=provider,proto3,enum=google.cloud.clouddms.logging.v1.DatabaseProvider" json:"provider,omitempty"`
	// contains filtered or unexported fields
}

An producer connection profile definition. NEXT_TAG = 18.

func (*LoggedConnectionProfile) Descriptor deprecated 

func (*LoggedConnectionProfile) Descriptor() ([]byte, []int)

Deprecated: Use LoggedConnectionProfile.ProtoReflect.Descriptor instead.

func (*LoggedConnectionProfile) GetCloudsql 

func (x *LoggedConnectionProfile) GetCloudsql() *CloudSqlConnectionProfile

func (*LoggedConnectionProfile) GetConnectionProfile 

func (m *LoggedConnectionProfile) GetConnectionProfile() isLoggedConnectionProfile_ConnectionProfile

func (*LoggedConnectionProfile) GetDisplayName 

func (x *LoggedConnectionProfile) GetDisplayName() string

func (*LoggedConnectionProfile) GetError 

func (x *LoggedConnectionProfile) GetError() *status.Status

func (*LoggedConnectionProfile) GetLabels 

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

func (*LoggedConnectionProfile) GetMysql 

func (x *LoggedConnectionProfile) GetMysql() *MySqlConnectionProfile

func (*LoggedConnectionProfile) GetName 

func (x *LoggedConnectionProfile) GetName() string

func (*LoggedConnectionProfile) GetPostgresql 

func (x *LoggedConnectionProfile) GetPostgresql() *PostgreSqlConnectionProfile

func (*LoggedConnectionProfile) GetProvider 

func (x *LoggedConnectionProfile) GetProvider() DatabaseProvider

func (*LoggedConnectionProfile) GetState 

func (x *LoggedConnectionProfile) GetState() LoggedConnectionProfile_State

func (*LoggedConnectionProfile) ProtoMessage 

func (*LoggedConnectionProfile) ProtoMessage()

func (*LoggedConnectionProfile) ProtoReflect 

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

func (*LoggedConnectionProfile) Reset 

func (x *LoggedConnectionProfile) Reset()

func (*LoggedConnectionProfile) String 

func (x *LoggedConnectionProfile) String() string

type LoggedConnectionProfile_Cloudsql 

type LoggedConnectionProfile_Cloudsql struct {
	// A CloudSQL database connection profile.
	Cloudsql *CloudSqlConnectionProfile `protobuf:"bytes,102,opt,name=cloudsql,proto3,oneof"`
}

type LoggedConnectionProfile_Mysql 

type LoggedConnectionProfile_Mysql struct {
	// A MySQL database connection profile.
	Mysql *MySqlConnectionProfile `protobuf:"bytes,100,opt,name=mysql,proto3,oneof"`
}

type LoggedConnectionProfile_Postgresql 

type LoggedConnectionProfile_Postgresql struct {
	// A PostgreSQL database connection profile.
	Postgresql *PostgreSqlConnectionProfile `protobuf:"bytes,101,opt,name=postgresql,proto3,oneof"`
}

type LoggedConnectionProfile_State 

type LoggedConnectionProfile_State int32

The connection profile states enum. 

const (
	// The state of the connection profile is unknown.
	LoggedConnectionProfile_STATE_UNSPECIFIED LoggedConnectionProfile_State = 0
	// The connection profile is in draft mode and fully editable.
	LoggedConnectionProfile_DRAFT LoggedConnectionProfile_State = 1
	// The connection profile is being created.
	LoggedConnectionProfile_CREATING LoggedConnectionProfile_State = 2
	// The connection profile is ready.
	LoggedConnectionProfile_READY LoggedConnectionProfile_State = 3
	// The connection profile is being updated.
	LoggedConnectionProfile_UPDATING LoggedConnectionProfile_State = 4
	// The connection profile is being deleted.
	LoggedConnectionProfile_DELETING LoggedConnectionProfile_State = 5
	// The connection profile has been deleted.
	LoggedConnectionProfile_DELETED LoggedConnectionProfile_State = 6
	// The last action on the connection profile failed.
	LoggedConnectionProfile_FAILED LoggedConnectionProfile_State = 7
)

func (LoggedConnectionProfile_State) Descriptor 

func (LoggedConnectionProfile_State) Descriptor() protoreflect.EnumDescriptor

func (LoggedConnectionProfile_State) Enum 

func (x LoggedConnectionProfile_State) Enum() *LoggedConnectionProfile_State

func (LoggedConnectionProfile_State) EnumDescriptor deprecated 

func (LoggedConnectionProfile_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use LoggedConnectionProfile_State.Descriptor instead.

func (LoggedConnectionProfile_State) Number 

func (x LoggedConnectionProfile_State) Number() protoreflect.EnumNumber

func (LoggedConnectionProfile_State) String 

func (x LoggedConnectionProfile_State) String() string

func (LoggedConnectionProfile_State) Type 

func (LoggedConnectionProfile_State) Type() protoreflect.EnumType

type LoggedMigrationJob 

type LoggedMigrationJob struct {

	// Required. The unique identifier for a migration job.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. Labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Required. The display name.
	DisplayName string `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Required. The current migration job state.
	State LoggedMigrationJob_State `` /* 127-byte string literal not displayed */
	// Required. The current migration job phase.
	Phase LoggedMigrationJob_Phase `` /* 127-byte string literal not displayed */
	// Required. The migration job type.
	Type LoggedMigrationJob_Type `protobuf:"varint,6,opt,name=type,proto3,enum=google.cloud.clouddms.logging.v1.LoggedMigrationJob_Type" json:"type,omitempty"`
	// Optional. An optional dump path (gs://[BUCKET_NAME]/[OBJECT_NAME]).
	DumpPath string `protobuf:"bytes,7,opt,name=dump_path,json=dumpPath,proto3" json:"dump_path,omitempty"`
	// Required. The migration job source connection profile name.
	Source string `protobuf:"bytes,8,opt,name=source,proto3" json:"source,omitempty"`
	// Required. The migration job destination connection profile name.
	Destination string `protobuf:"bytes,9,opt,name=destination,proto3" json:"destination,omitempty"`
	// Required. the migration job duration in seconds.
	Duration *durationpb.Duration `protobuf:"bytes,10,opt,name=duration,proto3" json:"duration,omitempty"`
	// Required. Type of connectivity to source database.
	ConnectivityType LoggedMigrationJob_ConnectivityType `` /* 185-byte string literal not displayed */
	// Required. The error details in case of state FAILED.
	Error *status.Status `protobuf:"bytes,12,opt,name=error,proto3" json:"error,omitempty"`
	// Required. The time when this migration job was completed. Should only be set when the
	// phase of the migration job is COMPLETED.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Required. The indicative source database.
	SourceDatabase *DatabaseType `protobuf:"bytes,14,opt,name=source_database,json=sourceDatabase,proto3" json:"source_database,omitempty"`
	// Required. The indicative destination database.
	DestinationDatabase *DatabaseType `protobuf:"bytes,15,opt,name=destination_database,json=destinationDatabase,proto3" json:"destination_database,omitempty"`
	// contains filtered or unexported fields
}

Migration job as stored in Cloud Logging logs. NEXT_TAG = 36.

func (*LoggedMigrationJob) Descriptor deprecated 

func (*LoggedMigrationJob) Descriptor() ([]byte, []int)

Deprecated: Use LoggedMigrationJob.ProtoReflect.Descriptor instead.

func (*LoggedMigrationJob) GetConnectivityType 

func (x *LoggedMigrationJob) GetConnectivityType() LoggedMigrationJob_ConnectivityType

func (*LoggedMigrationJob) GetDestination 

func (x *LoggedMigrationJob) GetDestination() string

func (*LoggedMigrationJob) GetDestinationDatabase 

func (x *LoggedMigrationJob) GetDestinationDatabase() *DatabaseType

func (*LoggedMigrationJob) GetDisplayName 

func (x *LoggedMigrationJob) GetDisplayName() string

func (*LoggedMigrationJob) GetDumpPath 

func (x *LoggedMigrationJob) GetDumpPath() string

func (*LoggedMigrationJob) GetDuration 

func (x *LoggedMigrationJob) GetDuration() *durationpb.Duration

func (*LoggedMigrationJob) GetEndTime 

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

func (*LoggedMigrationJob) GetError 

func (x *LoggedMigrationJob) GetError() *status.Status

func (*LoggedMigrationJob) GetLabels 

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

func (*LoggedMigrationJob) GetName 

func (x *LoggedMigrationJob) GetName() string

func (*LoggedMigrationJob) GetPhase 

func (x *LoggedMigrationJob) GetPhase() LoggedMigrationJob_Phase

func (*LoggedMigrationJob) GetSource 

func (x *LoggedMigrationJob) GetSource() string

func (*LoggedMigrationJob) GetSourceDatabase 

func (x *LoggedMigrationJob) GetSourceDatabase() *DatabaseType

func (*LoggedMigrationJob) GetState 

func (x *LoggedMigrationJob) GetState() LoggedMigrationJob_State

func (*LoggedMigrationJob) GetType 

func (x *LoggedMigrationJob) GetType() LoggedMigrationJob_Type

func (*LoggedMigrationJob) ProtoMessage 

func (*LoggedMigrationJob) ProtoMessage()

func (*LoggedMigrationJob) ProtoReflect 

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

func (*LoggedMigrationJob) Reset 

func (x *LoggedMigrationJob) Reset()

func (*LoggedMigrationJob) String 

func (x *LoggedMigrationJob) String() string

type LoggedMigrationJob_ConnectivityType 

type LoggedMigrationJob_ConnectivityType int32

Type of connectivity to source database. 

const (
	// No data defined.
	LoggedMigrationJob_CONNECTIVITY_TYPE_UNSPECIFIED LoggedMigrationJob_ConnectivityType = 0
	// Connect using static IO
	LoggedMigrationJob_STATIC_IP LoggedMigrationJob_ConnectivityType = 1
	// Use reverse SSH connectivity.
	LoggedMigrationJob_REVERSE_SSH LoggedMigrationJob_ConnectivityType = 2
	// Use VPC Peering connectivity.
	LoggedMigrationJob_VPC_PEERING LoggedMigrationJob_ConnectivityType = 3
)

func (LoggedMigrationJob_ConnectivityType) Descriptor 

func (LoggedMigrationJob_ConnectivityType) Descriptor() protoreflect.EnumDescriptor

func (LoggedMigrationJob_ConnectivityType) Enum 

func (x LoggedMigrationJob_ConnectivityType) Enum() *LoggedMigrationJob_ConnectivityType

func (LoggedMigrationJob_ConnectivityType) EnumDescriptor deprecated 

func (LoggedMigrationJob_ConnectivityType) EnumDescriptor() ([]byte, []int)

Deprecated: Use LoggedMigrationJob_ConnectivityType.Descriptor instead.

func (LoggedMigrationJob_ConnectivityType) Number 

func (x LoggedMigrationJob_ConnectivityType) Number() protoreflect.EnumNumber

func (LoggedMigrationJob_ConnectivityType) String 

func (x LoggedMigrationJob_ConnectivityType) String() string

func (LoggedMigrationJob_ConnectivityType) Type 

func (LoggedMigrationJob_ConnectivityType) Type() protoreflect.EnumType

type LoggedMigrationJob_Phase 

type LoggedMigrationJob_Phase int32

The migration job phases enum. 

const (
	// The phase of the migration job is unknown.
	LoggedMigrationJob_PHASE_UNSPECIFIED LoggedMigrationJob_Phase = 0
	// The migration job is in the full dump phase.
	LoggedMigrationJob_FULL_DUMP LoggedMigrationJob_Phase = 1
	// The migration job is CDC phase.
	LoggedMigrationJob_CDC LoggedMigrationJob_Phase = 2
	// The migration job is running the promote phase.
	LoggedMigrationJob_PROMOTE_IN_PROGRESS LoggedMigrationJob_Phase = 3
	// Only RDS flow - waiting for source writes to stop
	LoggedMigrationJob_WAITING_FOR_SOURCE_WRITES_TO_STOP LoggedMigrationJob_Phase = 4
	// Only RDS flow - the sources writes stopped, waiting for dump to begin
	LoggedMigrationJob_PREPARING_THE_DUMP LoggedMigrationJob_Phase = 5
)

func (LoggedMigrationJob_Phase) Descriptor 

func (LoggedMigrationJob_Phase) Descriptor() protoreflect.EnumDescriptor

func (LoggedMigrationJob_Phase) Enum 

func (x LoggedMigrationJob_Phase) Enum() *LoggedMigrationJob_Phase

func (LoggedMigrationJob_Phase) EnumDescriptor deprecated 

func (LoggedMigrationJob_Phase) EnumDescriptor() ([]byte, []int)

Deprecated: Use LoggedMigrationJob_Phase.Descriptor instead.

func (LoggedMigrationJob_Phase) Number 

func (x LoggedMigrationJob_Phase) Number() protoreflect.EnumNumber

func (LoggedMigrationJob_Phase) String 

func (x LoggedMigrationJob_Phase) String() string

func (LoggedMigrationJob_Phase) Type 

func (LoggedMigrationJob_Phase) Type() protoreflect.EnumType

type LoggedMigrationJob_State 

type LoggedMigrationJob_State int32

The migration job states enum. 

const (
	// The state of the migration job is unknown.
	LoggedMigrationJob_STATE_UNSPECIFIED LoggedMigrationJob_State = 0
	// The migration job is down for maintenance.
	LoggedMigrationJob_MAINTENANCE LoggedMigrationJob_State = 1
	// The migration job is in draft mode and fully editable.
	LoggedMigrationJob_DRAFT LoggedMigrationJob_State = 2
	// The migration job is being created.
	LoggedMigrationJob_CREATING LoggedMigrationJob_State = 3
	// The migration job is created and not started.
	LoggedMigrationJob_NOT_STARTED LoggedMigrationJob_State = 4
	// The migration job is running
	LoggedMigrationJob_RUNNING LoggedMigrationJob_State = 5
	// The migration job failed.
	LoggedMigrationJob_FAILED LoggedMigrationJob_State = 6
	// The migration job has been completed.
	LoggedMigrationJob_COMPLETED LoggedMigrationJob_State = 7
	// The migration job is being deleted.
	LoggedMigrationJob_DELETING LoggedMigrationJob_State = 8
	// The migration job is being stopped.
	LoggedMigrationJob_STOPPING LoggedMigrationJob_State = 9
	// The migration job is currently stopped.
	LoggedMigrationJob_STOPPED LoggedMigrationJob_State = 10
	// The migration job has been deleted.
	LoggedMigrationJob_DELETED LoggedMigrationJob_State = 11
	// The migration job is being updated.
	LoggedMigrationJob_UPDATING LoggedMigrationJob_State = 12
	// The migration job is starting.
	LoggedMigrationJob_STARTING LoggedMigrationJob_State = 13
	// The migration job is restarting.
	LoggedMigrationJob_RESTARTING LoggedMigrationJob_State = 14
	// The migration job is resuming.
	LoggedMigrationJob_RESUMING LoggedMigrationJob_State = 15
)

func (LoggedMigrationJob_State) Descriptor 

func (LoggedMigrationJob_State) Descriptor() protoreflect.EnumDescriptor

func (LoggedMigrationJob_State) Enum 

func (x LoggedMigrationJob_State) Enum() *LoggedMigrationJob_State

func (LoggedMigrationJob_State) EnumDescriptor deprecated 

func (LoggedMigrationJob_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use LoggedMigrationJob_State.Descriptor instead.

func (LoggedMigrationJob_State) Number 

func (x LoggedMigrationJob_State) Number() protoreflect.EnumNumber

func (LoggedMigrationJob_State) String 

func (x LoggedMigrationJob_State) String() string

func (LoggedMigrationJob_State) Type 

func (LoggedMigrationJob_State) Type() protoreflect.EnumType

type LoggedMigrationJob_Type 

type LoggedMigrationJob_Type int32

The migration job types. 

const (
	// The type of the migration job is unknown.
	LoggedMigrationJob_TYPE_UNSPECIFIED LoggedMigrationJob_Type = 0
	// The migration job is a one time migration.
	LoggedMigrationJob_ONE_TIME LoggedMigrationJob_Type = 1
	// The migration job is a continuous migration.
	LoggedMigrationJob_CONTINUOUS LoggedMigrationJob_Type = 2
)

func (LoggedMigrationJob_Type) Descriptor 

func (LoggedMigrationJob_Type) Descriptor() protoreflect.EnumDescriptor

func (LoggedMigrationJob_Type) Enum 

func (x LoggedMigrationJob_Type) Enum() *LoggedMigrationJob_Type

func (LoggedMigrationJob_Type) EnumDescriptor deprecated 

func (LoggedMigrationJob_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use LoggedMigrationJob_Type.Descriptor instead.

func (LoggedMigrationJob_Type) Number 

func (x LoggedMigrationJob_Type) Number() protoreflect.EnumNumber

func (LoggedMigrationJob_Type) String 

func (x LoggedMigrationJob_Type) String() string

func (LoggedMigrationJob_Type) Type 

func (LoggedMigrationJob_Type) Type() protoreflect.EnumType

type MigrationJobEventLog 

type MigrationJobEventLog struct {

	// The migration job resource
	MigrationJob *LoggedMigrationJob `protobuf:"bytes,1,opt,name=migration_job,json=migrationJob,proto3" json:"migration_job,omitempty"`
	// Timestamp of the event
	OccurrenceTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=occurrence_timestamp,json=occurrenceTimestamp,proto3" json:"occurrence_timestamp,omitempty"`
	// Event code
	Code int32 `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`
	// Event message
	TextMessage string `protobuf:"bytes,4,opt,name=text_message,json=textMessage,proto3" json:"text_message,omitempty"`
	// Original event data
	//
	// Types that are assignable to OriginalCause:
	//	*MigrationJobEventLog_OriginalCode
	//	*MigrationJobEventLog_OriginalMessage
	OriginalCause isMigrationJobEventLog_OriginalCause `protobuf_oneof:"original_cause"`
	// contains filtered or unexported fields
}

Log definition for Migration Job event

func (*MigrationJobEventLog) Descriptor deprecated 

func (*MigrationJobEventLog) Descriptor() ([]byte, []int)

Deprecated: Use MigrationJobEventLog.ProtoReflect.Descriptor instead.

func (*MigrationJobEventLog) GetCode 

func (x *MigrationJobEventLog) GetCode() int32

func (*MigrationJobEventLog) GetMigrationJob 

func (x *MigrationJobEventLog) GetMigrationJob() *LoggedMigrationJob

func (*MigrationJobEventLog) GetOccurrenceTimestamp 

func (x *MigrationJobEventLog) GetOccurrenceTimestamp() *timestamppb.Timestamp

func (*MigrationJobEventLog) GetOriginalCause 

func (m *MigrationJobEventLog) GetOriginalCause() isMigrationJobEventLog_OriginalCause

func (*MigrationJobEventLog) GetOriginalCode 

func (x *MigrationJobEventLog) GetOriginalCode() int32

func (*MigrationJobEventLog) GetOriginalMessage 

func (x *MigrationJobEventLog) GetOriginalMessage() string

func (*MigrationJobEventLog) GetTextMessage 

func (x *MigrationJobEventLog) GetTextMessage() string

func (*MigrationJobEventLog) ProtoMessage 

func (*MigrationJobEventLog) ProtoMessage()

func (*MigrationJobEventLog) ProtoReflect 

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

func (*MigrationJobEventLog) Reset 

func (x *MigrationJobEventLog) Reset()

func (*MigrationJobEventLog) String 

func (x *MigrationJobEventLog) String() string

type MigrationJobEventLog_OriginalCode 

type MigrationJobEventLog_OriginalCode struct {
	// Original event code
	OriginalCode int32 `protobuf:"varint,200,opt,name=original_code,json=originalCode,proto3,oneof"`
}

type MigrationJobEventLog_OriginalMessage 

type MigrationJobEventLog_OriginalMessage struct {
	// Original event message
	OriginalMessage string `protobuf:"bytes,201,opt,name=original_message,json=originalMessage,proto3,oneof"`
}

type MySqlConnectionProfile 

type MySqlConnectionProfile struct {

	// The database version.
	Version MySqlConnectionProfile_Version `` /* 137-byte string literal not displayed */
	// The Cloud SQL id for a Cloud SQL instance.
	CloudSqlId string `protobuf:"bytes,2,opt,name=cloud_sql_id,json=cloudSqlId,proto3" json:"cloud_sql_id,omitempty"`
	// contains filtered or unexported fields
}

An MySQL database connection profile.

func (*MySqlConnectionProfile) Descriptor deprecated 

func (*MySqlConnectionProfile) Descriptor() ([]byte, []int)

Deprecated: Use MySqlConnectionProfile.ProtoReflect.Descriptor instead.

func (*MySqlConnectionProfile) GetCloudSqlId 

func (x *MySqlConnectionProfile) GetCloudSqlId() string

func (*MySqlConnectionProfile) GetVersion 

func (x *MySqlConnectionProfile) GetVersion() MySqlConnectionProfile_Version

func (*MySqlConnectionProfile) ProtoMessage 

func (*MySqlConnectionProfile) ProtoMessage()

func (*MySqlConnectionProfile) ProtoReflect 

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

func (*MySqlConnectionProfile) Reset 

func (x *MySqlConnectionProfile) Reset()

func (*MySqlConnectionProfile) String 

func (x *MySqlConnectionProfile) String() string

type MySqlConnectionProfile_Version 

type MySqlConnectionProfile_Version int32

The MySQL database version. 

const (
	// Unspecified version.
	MySqlConnectionProfile_VERSION_UNSPECIFIED MySqlConnectionProfile_Version = 0
	// MySQL 5.5.
	MySqlConnectionProfile_V5_5 MySqlConnectionProfile_Version = 1
	// MySQL 5.6.
	MySqlConnectionProfile_V5_6 MySqlConnectionProfile_Version = 2
	// MySQL 5.7.
	MySqlConnectionProfile_V5_7 MySqlConnectionProfile_Version = 3
	// MySQL 8.0.
	MySqlConnectionProfile_V8_0 MySqlConnectionProfile_Version = 4
)

func (MySqlConnectionProfile_Version) Descriptor 

func (MySqlConnectionProfile_Version) Descriptor() protoreflect.EnumDescriptor

func (MySqlConnectionProfile_Version) Enum 

func (x MySqlConnectionProfile_Version) Enum() *MySqlConnectionProfile_Version

func (MySqlConnectionProfile_Version) EnumDescriptor deprecated 

func (MySqlConnectionProfile_Version) EnumDescriptor() ([]byte, []int)

Deprecated: Use MySqlConnectionProfile_Version.Descriptor instead.

func (MySqlConnectionProfile_Version) Number 

func (x MySqlConnectionProfile_Version) Number() protoreflect.EnumNumber

func (MySqlConnectionProfile_Version) String 

func (x MySqlConnectionProfile_Version) String() string

func (MySqlConnectionProfile_Version) Type 

func (MySqlConnectionProfile_Version) Type() protoreflect.EnumType

type PostgreSqlConnectionProfile 

type PostgreSqlConnectionProfile struct {

	// The database version.
	Version PostgreSqlConnectionProfile_Version `` /* 142-byte string literal not displayed */
	// The Cloud SQL id for a Cloud SQL instance.
	CloudSqlId string `protobuf:"bytes,2,opt,name=cloud_sql_id,json=cloudSqlId,proto3" json:"cloud_sql_id,omitempty"`
	// contains filtered or unexported fields
}

An PostgreSQL connection profile.

func (*PostgreSqlConnectionProfile) Descriptor deprecated 

func (*PostgreSqlConnectionProfile) Descriptor() ([]byte, []int)

Deprecated: Use PostgreSqlConnectionProfile.ProtoReflect.Descriptor instead.

func (*PostgreSqlConnectionProfile) GetCloudSqlId 

func (x *PostgreSqlConnectionProfile) GetCloudSqlId() string

func (*PostgreSqlConnectionProfile) GetVersion 

func (x *PostgreSqlConnectionProfile) GetVersion() PostgreSqlConnectionProfile_Version

func (*PostgreSqlConnectionProfile) ProtoMessage 

func (*PostgreSqlConnectionProfile) ProtoMessage()

func (*PostgreSqlConnectionProfile) ProtoReflect 

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

func (*PostgreSqlConnectionProfile) Reset 

func (x *PostgreSqlConnectionProfile) Reset()

func (*PostgreSqlConnectionProfile) String 

func (x *PostgreSqlConnectionProfile) String() string

type PostgreSqlConnectionProfile_Version 

type PostgreSqlConnectionProfile_Version int32

The PostgreSQL database version. 

const (
	// Unspecified version.
	PostgreSqlConnectionProfile_VERSION_UNSPECIFIED PostgreSqlConnectionProfile_Version = 0
	// PostgreSQL 9.6.
	PostgreSqlConnectionProfile_V9_6 PostgreSqlConnectionProfile_Version = 1
	// PostgreSQL 11.
	PostgreSqlConnectionProfile_V11 PostgreSqlConnectionProfile_Version = 2
	// PostgreSQL 10.
	PostgreSqlConnectionProfile_V10 PostgreSqlConnectionProfile_Version = 3
	// PostgreSQL 12.
	PostgreSqlConnectionProfile_V12 PostgreSqlConnectionProfile_Version = 4
	// PostgreSQL 13.
	PostgreSqlConnectionProfile_V13 PostgreSqlConnectionProfile_Version = 5
)

func (PostgreSqlConnectionProfile_Version) Descriptor 

func (PostgreSqlConnectionProfile_Version) Descriptor() protoreflect.EnumDescriptor

func (PostgreSqlConnectionProfile_Version) Enum 

func (x PostgreSqlConnectionProfile_Version) Enum() *PostgreSqlConnectionProfile_Version

func (PostgreSqlConnectionProfile_Version) EnumDescriptor deprecated 

func (PostgreSqlConnectionProfile_Version) EnumDescriptor() ([]byte, []int)

Deprecated: Use PostgreSqlConnectionProfile_Version.Descriptor instead.

func (PostgreSqlConnectionProfile_Version) Number 

func (x PostgreSqlConnectionProfile_Version) Number() protoreflect.EnumNumber

func (PostgreSqlConnectionProfile_Version) String 

func (x PostgreSqlConnectionProfile_Version) String() string

func (PostgreSqlConnectionProfile_Version) Type 

func (PostgreSqlConnectionProfile_Version) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.