ckissu

Documentation

Index

• Variables
• type ColumnAdd
• type ColumnAdds
• type ColumnDrop
• type ColumnDrops
• type ColumnMod
• type ColumnRename
• type ColumnRenames
• type DatasourceInfo
• type IndexAdd
• type IndexAdds
• type Issu
  • func NewCKIssu(cfg *config.Config) (*Issu, error)
  • func (i *Issu) Close() error
  • func (i *Issu) RunRenameTable(ds *datasource.DatasourceManager) error
  • func (i *Issu) Start() error
• type TableModTTL
• type TableRename

Variables

var ColumnAdd573 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"vtap_flow", "vtap_flow_port"},
		Tables:      []string{"1m", "1m_local", "1s", "1s_local"},
		ColumnNames: []string{"service_id"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"vtap_flow_edge", "vtap_flow_edge_port"},
		Tables:      []string{"1m", "1m_local", "1s", "1s_local"},
		ColumnNames: []string{"service_id_0", "service_id_1"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local", "l7_http_log", "l7_http_log_local", "l7_dns_log", "l7_dns_log_local"},
		ColumnNames: []string{"service_id_0", "service_id_1"},
		ColumnType:  ckdb.UInt32,
	},
}

var ColumnAdd600 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"vtap_flow_port", "vtap_flow_edge_port"},
		Tables:      []string{"1m", "1m_local", "1s", "1s_local"},
		ColumnNames: []string{"l7_client_error", "l7_server_error", "l7_timeout", "l7_error", "rrt_max"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"vtap_flow_port", "vtap_flow_edge_port"},
		Tables:      []string{"1m", "1m_local", "1s", "1s_local"},
		ColumnNames: []string{"rrt_sum"},
		ColumnType:  ckdb.Float64,
	},
	&ColumnAdds{
		Dbs:         []string{"vtap_flow_port", "vtap_flow_edge_port"},
		Tables:      []string{"1m", "1m_local", "1s", "1s_local"},
		ColumnNames: []string{"rrt_count", "l7_request", "l7_response", "tcp_transfer_fail", "tcp_rst_fail"},
		ColumnType:  ckdb.UInt64,
	},
	&ColumnAdds{
		Dbs:         []string{"vtap_flow_edge_port", "vtap_flow_port", "vtap_app_port", "vtap_app_edge_port"},
		Tables:      []string{"1m", "1m_local", "1s", "1s_local"},
		ColumnNames: []string{"tap_port_type", "tunnel_type"},
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:          []string{"flow_log"},
		Tables:       []string{"l4_flow_log", "l4_flow_log_local", "l7_http_log", "l7_http_log_local", "l7_dns_log", "l7_dns_log_local"},
		ColumnNames:  []string{"tap_side"},
		ColumnType:   ckdb.LowCardinalityString,
		DefaultValue: "'rest'",
	},
	&ColumnAdds{
		Dbs: []string{"flow_log"},
		Tables: []string{"l4_flow_log", "l4_flow_log_local", "l7_http_log", "l7_http_log_local", "l7_dns_log", "l7_dns_log_local",
			"l7_mq_log", "l7_mq_log_local", "l7_sql_log", "l7_sql_log_local", "l7_nosql_log", "l7_nosql_log_local", "l7_rpc_log", "l7_rpc_log_local"},
		ColumnNames: []string{"tap_port_type", "tunnel_type"},
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local"},
		ColumnNames: []string{"syn_seq", "syn_ack_seq", "l7_error", "tunnel_tx_mac_0", "tunnel_tx_mac_1", "tunnel_rx_mac_0", "tunnel_rx_mac_1", "last_keepalive_seq", "last_keepalive_ack"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local"},
		ColumnNames: []string{"is_new_flow"},
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_http_log", "l7_http_log_local", "l7_dns_log", "l7_dns_log_local"},
		ColumnNames: []string{"req_tcp_seq", "resp_tcp_seq"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:          []string{"flow_log"},
		Tables:       []string{"l7_dns_log", "l7_dns_log_local"},
		ColumnNames:  []string{"protocol"},
		ColumnType:   ckdb.UInt8,
		DefaultValue: "17",
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_http_log", "l7_http_log_local", "l7_dns_log", "l7_dns_log_local"},
		ColumnNames: []string{"status_code"},
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_http_log", "l7_http_log_local", "l7_dns_log", "l7_dns_log_local"},
		ColumnNames: []string{"exception_desc"},
		ColumnType:  ckdb.LowCardinalityString,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_http_log", "l7_http_log_local"},
		ColumnNames: []string{"response_length"},
		ColumnType:  ckdb.Int64Nullable,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_http_log", "l7_http_log_local"},
		ColumnNames: []string{"span_id"},
		ColumnType:  ckdb.String,
	},
}

var ColumnAdd610 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local"},
		ColumnNames: []string{"auto_instance_id_0", "auto_service_id_0", "auto_instance_id_1", "auto_service_id_1"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local"},
		ColumnNames: []string{"auto_instance_type_0", "auto_service_type_0", "auto_instance_type_1", "auto_service_type_1", "status"},
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      []string{"vtap_flow_port.1m", "vtap_flow_port.1m_local", "vtap_flow_port.1s", "vtap_flow_port.1s_local", "vtap_app_port.1m", "vtap_app_port.1m_local", "vtap_app_port.1s", "vtap_app_port.1s_local"},
		ColumnNames: []string{"auto_instance_id", "auto_service_id"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      []string{"vtap_flow_port.1m", "vtap_flow_port.1m_local", "vtap_flow_port.1s", "vtap_flow_port.1s_local", "vtap_app_port.1m", "vtap_app_port.1m_local", "vtap_app_port.1s", "vtap_app_port.1s_local"},
		ColumnNames: []string{"auto_instance_type", "auto_service_type"},
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      []string{"vtap_flow_edge_port.1m", "vtap_flow_edge_port.1m_local", "vtap_flow_edge_port.1s", "vtap_flow_edge_port.1s_local", "vtap_app_edge_port.1m", "vtap_app_edge_port.1m_local", "vtap_app_edge_port.1s", "vtap_app_edge_port.1s_local"},
		ColumnNames: []string{"auto_instance_id_0", "auto_service_id_0", "auto_instance_id_1", "auto_service_id_1"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      []string{"vtap_flow_edge_port.1m", "vtap_flow_edge_port.1m_local", "vtap_flow_edge_port.1s", "vtap_flow_edge_port.1s_local", "vtap_app_edge_port.1m", "vtap_app_edge_port.1m_local", "vtap_app_edge_port.1s", "vtap_app_edge_port.1s_local"},
		ColumnNames: []string{"auto_instance_type_0", "auto_service_type_0", "auto_instance_type_1", "auto_service_type_1"},
		ColumnType:  ckdb.UInt8,
	},

	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log", "l7_flow_log_local"},
		ColumnNames: []string{"process_kname_0", "process_kname_1"},
		ColumnType:  ckdb.String,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log", "l7_flow_log_local"},
		ColumnNames: []string{"syscall_thread_0", "syscall_thread_1", "syscall_cap_seq_0", "syscall_cap_seq_1"},
		ColumnType:  ckdb.UInt32,
	},
}

var ColumnAdd611 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log", "l7_flow_log_local"},
		ColumnNames: []string{"attribute_names", "attribute_values"},
		ColumnType:  ckdb.ArrayString,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log", "l7_flow_log_local"},
		ColumnNames: []string{"l7_protocol_str", "service_name"},
		ColumnType:  ckdb.LowCardinalityString,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log", "l7_flow_log_local"},
		ColumnNames: []string{"span_kind"},
		ColumnType:  ckdb.UInt8Nullable,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log", "l7_flow_log_local"},
		ColumnNames: []string{"parent_span_id", "service_instance_id"},
		ColumnType:  ckdb.String,
	},
}

var ColumnAdd612 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local"},
		ColumnNames: []string{"cit_max", "syn_count", "synack_count", "retrans_syn", "retrans_synack"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local"},
		ColumnNames: []string{"cit_count"},
		ColumnType:  ckdb.UInt64,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local"},
		ColumnNames: []string{"cit_sum"},
		ColumnType:  ckdb.Float64,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      vtapFlowTables,
		ColumnNames: u64ColumnNameAdd612,
		ColumnType:  ckdb.UInt64,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      vtapFlowTables,
		ColumnNames: u32ColumnNameAdd612,
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      vtapFlowTables,
		ColumnNames: f64ColumnNameAdd612,
		ColumnType:  ckdb.Float64,
	},
}

var ColumnAdd613 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local"},
		ColumnNames: []string{"acl_gids"},
		ColumnType:  ckdb.ArrayUInt16,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log", "l7_flow_log_local"},
		ColumnNames: []string{"metrics_names"},
		ColumnType:  ckdb.ArrayString,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log", "l7_flow_log_local"},
		ColumnNames: []string{"metrics_values"},
		ColumnType:  ckdb.ArrayFloat64,
	},
}

var ColumnAdd615 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log", "l7_flow_log_local"},
		ColumnNames: []string{"endpoint"},
		ColumnType:  ckdb.String,
	},
}

var ColumnAdd618 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log", "l7_flow_log_local"},
		ColumnNames: []string{"signal_source"},
		ColumnType:  ckdb.UInt16,
	},
}

var ColumnAdd620 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      flowMetricsEdgeTables,
		ColumnNames: u8ColumnNameAdd620,
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local", "l7_flow_log", "l7_flow_log_local"},
		ColumnNames: u8ColumnNameAdd620,
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local"},
		ColumnNames: []string{"nat_real_ip4_0", "nat_real_ip4_1"},
		ColumnType:  ckdb.IPv4,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local"},
		ColumnNames: []string{"nat_real_port_0", "nat_real_port_1"},
		ColumnType:  ckdb.UInt16,
	},

	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      flowMetricsTables,
		ColumnNames: u32ColumnNameAdd620,
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      flowMetricsEdgeTables,
		ColumnNames: u32ColumnNameEdgeAdd620,
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local", "l7_flow_log", "l7_flow_log_local"},
		ColumnNames: u32ColumnNameEdgeAdd620,
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_packet", "l4_packet_local"},
		ColumnNames: []string{"packet_batch"},
		ColumnType:  ckdb.String,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_packet", "l7_packet_local"},
		ColumnNames: []string{"pcap_batch"},
		ColumnType:  ckdb.String,
	},
}

var ColumnAdd623 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      flowMetricsTables,
		ColumnNames: []string{"signal_source"},
		ColumnType:  ckdb.UInt16,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      flowMetricsEdgeTables,
		ColumnNames: []string{"signal_source"},
		ColumnType:  ckdb.UInt16,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      vtapAppTables,
		ColumnNames: []string{"app_service"},
		ColumnType:  ckdb.LowCardinalityString,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      vtapAppTables,
		ColumnNames: []string{"app_instance", "endpoint"},
		ColumnType:  ckdb.String,
	},
}

var ColumnAdd625 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      flowMetricsTables,
		ColumnNames: u8ColumnNameAdd625,
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      flowMetricsEdgeTables,
		ColumnNames: u8ColumnNameAdd625,
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      flowLogTables,
		ColumnNames: u8ColumnNameAdd625,
		ColumnType:  ckdb.UInt8,
	},
}

var ColumnAdd626 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"profile"},
		Tables:      profileTables,
		ColumnNames: u8ColumnProfileNameAdd626,
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"profile"},
		Tables:      profileTables,
		ColumnNames: u16ColumnProfileNameAdd626,
		ColumnType:  ckdb.UInt16,
	},
	&ColumnAdds{
		Dbs:         []string{"ext_metrics"},
		Tables:      []string{"metrics", "metrics_local"},
		ColumnNames: []string{"gprocess_id"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_packet", "l4_packet_local", "l7_packet", "l7_packet_local"},
		ColumnNames: []string{"start_time"},
		ColumnType:  ckdb.DateTime64us,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_packet", "l7_packet_local"},
		ColumnNames: []string{"acl_gids"},
		ColumnType:  ckdb.ArrayUInt16,
	},
}

var ColumnAdd633 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      []string{"vtap_flow_port.1m", "vtap_flow_port.1m_local", "vtap_flow_port.1s", "vtap_flow_port.1s_local", "vtap_app_port.1m", "vtap_app_port.1m_local", "vtap_app_port.1s", "vtap_app_port.1s_local"},
		ColumnNames: []string{"role"},
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"event"},
		Tables:      []string{"event", "event_local", "perf_event", "perf_event_local"},
		ColumnNames: u32ColumnNameAdd633,
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      vtapAppPortTables,
		ColumnNames: u32ColumnNameAdd633,
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      vtapAppEdgePortTables,
		ColumnNames: u32ColumnNameEdgeAdd633,
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      l7FlowLogTables,
		ColumnNames: u32ColumnNameEdgeAdd633,
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      flowMetricsTables,
		ColumnNames: u8ColumnNameAdd633,
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_metrics"},
		Tables:      flowMetricsEdgeTables,
		ColumnNames: u8ColumnNameEdgeAdd633,
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local", "l7_flow_log", "l7_flow_log_local"},
		ColumnNames: u8ColumnNameEdgeAdd633,
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log", "l7_flow_log_local"},
		ColumnNames: []string{"x_request_id_0", "x_request_id_1"},
		ColumnType:  ckdb.String,
	},
	&ColumnAdds{
		Dbs:         []string{"event"},
		Tables:      []string{"alarm_event", "alarm_event_local"},
		ColumnNames: []string{"alarm_target"},
		ColumnType:  ckdb.LowCardinalityString,
	},
	&ColumnAdds{
		Dbs:         []string{"event"},
		Tables:      []string{"alarm_event", "alarm_event_local"},
		ColumnNames: []string{"region_id"},
		ColumnType:  ckdb.UInt16,
	},
	&ColumnAdds{
		Dbs:         []string{"event"},
		Tables:      []string{"alarm_event", "alarm_event_local"},
		ColumnNames: []string{"policy_query_url", "policy_query_conditions", "policy_threshold_critical", "policy_threshold_error", "policy_threshold_warning"},
		ColumnType:  ckdb.String,
	},
}

var ColumnAdd635 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"profile"},
		Tables:      []string{"in_process", "in_process_local"},
		ColumnNames: []string{"compression_algo"},
		ColumnType:  ckdb.LowCardinalityString,
	},
	&ColumnAdds{
		Dbs:         []string{"profile"},
		Tables:      []string{"in_process", "in_process_local"},
		ColumnNames: []string{"process_id"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"profile"},
		Tables:      []string{"in_process", "in_process_local"},
		ColumnNames: []string{"process_start_time"},
		ColumnType:  ckdb.DateTime64,
	},
	&ColumnAdds{
		Dbs:         []string{"profile"},
		Tables:      []string{"in_process", "in_process_local"},
		ColumnNames: []string{"netns_id"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local"},
		ColumnNames: []string{"l7_parse_failed"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"event"},
		Tables:      []string{"alarm_event", "alarm_event_local"},
		ColumnNames: []string{"user_id"},
		ColumnType:  ckdb.UInt32,
	},
}

var ColumnAdd64 = []*ColumnAdds{
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log", "l7_flow_log_local"},
		ColumnNames: []string{"syscall_coroutine_0", "syscall_coroutine_1", "trace_id_index"},
		ColumnType:  ckdb.UInt64,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log", "l7_flow_log_local"},
		ColumnNames: []string{"is_tls"},
		ColumnType:  ckdb.UInt8,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local"},
		ColumnNames: []string{"rtt_client", "rtt_server"},
		ColumnType:  ckdb.Float64,
	},
	&ColumnAdds{
		Dbs:         []string{"profile"},
		Tables:      []string{"in_process", "in_process_local"},
		ColumnNames: []string{"gprocess_id"},
		ColumnType:  ckdb.UInt32,
	},
	&ColumnAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l4_flow_log", "l4_flow_log_local"},
		ColumnNames: []string{"tls_rtt"},
		ColumnType:  ckdb.Float64,
	},
}

var ColumnDrops635 = []*ColumnDrops{
	&ColumnDrops{
		Dbs:         []string{"profile"},
		Tables:      []string{"in_process", "in_process_local"},
		ColumnNames: []string{"profile_node_id", "profile_parent_node_id"},
	},
}

var ColumnMod611 = []*ColumnMod{
	&ColumnMod{
		Db:            "flow_log",
		Table:         "l7_flow_log",
		ColumnName:    "span_kind",
		NewColumnType: ckdb.UInt8Nullable,
		DropIndex:     false,
	},
	&ColumnMod{
		Db:            "flow_log",
		Table:         "l7_flow_log_local",
		ColumnName:    "span_kind",
		NewColumnType: ckdb.UInt8Nullable,
		DropIndex:     true,
	},
}

var ColumnMod615 = []*ColumnMod{
	&ColumnMod{
		Db:            "flow_log",
		Table:         "l7_flow_log",
		ColumnName:    "response_code",
		NewColumnType: ckdb.Int32Nullable,
		DropIndex:     false,
	},
	&ColumnMod{
		Db:            "flow_log",
		Table:         "l7_flow_log_local",
		ColumnName:    "response_code",
		NewColumnType: ckdb.Int32Nullable,
		DropIndex:     false,
	},
}

var ColumnRename572 = []*ColumnRename{
	&ColumnRename{
		Db:            "flow_log",
		Table:         "l4_flow_log",
		OldColumnName: "retans_tx",
		NewColumnName: "retrans_tx",
	},
	&ColumnRename{
		Db:            "flow_log",
		Table:         "l4_flow_log_local",
		OldColumnName: "retans_tx",
		NewColumnName: "retrans_tx",
	},
}

var ColumnRename600 = []*ColumnRename{
	&ColumnRename{
		Db:            "flow_log",
		Table:         "l7_http_log",
		OldColumnName: "status_code",
		NewColumnName: "answer_code",
	},
	&ColumnRename{
		Db:            "flow_log",
		Table:         "l7_http_log_local",
		OldColumnName: "status_code",
		NewColumnName: "answer_code",
	},
	&ColumnRename{
		Db:            "flow_log",
		Table:         "l7_http_log",
		OldColumnName: "content_length",
		NewColumnName: "request_length",
	},
	&ColumnRename{
		Db:            "flow_log",
		Table:         "l7_http_log_local",
		OldColumnName: "content_length",
		NewColumnName: "request_length",
	},
}

var ColumnRename618 = []*ColumnRename{
	&ColumnRename{
		Db:            "flow_log",
		Table:         "l4_flow_log_local",
		OldColumnName: "flow_source",
		NewColumnName: "signal_source",
		DropIndex:     true,
	},
	&ColumnRename{
		Db:            "flow_log",
		Table:         "l4_flow_log",
		OldColumnName: "flow_source",
		NewColumnName: "signal_source",
	},
}

var ColumnRename620 = []*ColumnRename{
	&ColumnRename{
		Db:              "flow_log",
		Table:           "l7_packet",
		OldColumnName:   "pcap_batch",
		CheckColumnType: true,
		OldColumnType:   ckdb.ArrayUInt8.String(),
		NewColumnName:   "pcap_batch_bak",
	},
	&ColumnRename{
		Db:              "flow_log",
		Table:           "l7_packet_local",
		OldColumnName:   "pcap_batch",
		CheckColumnType: true,
		OldColumnType:   ckdb.ArrayUInt8.String(),
		NewColumnName:   "pcap_batch_bak",
	},
	&ColumnRename{
		Db:              "flow_log",
		Table:           "l4_packet",
		OldColumnName:   "packet_batch",
		CheckColumnType: true,
		OldColumnType:   ckdb.ArrayUInt8.String(),
		NewColumnName:   "packet_batch_bak",
	},
	&ColumnRename{
		Db:              "flow_log",
		Table:           "l4_packet_local",
		OldColumnName:   "packet_batch",
		CheckColumnType: true,
		OldColumnType:   ckdb.ArrayUInt8.String(),
		NewColumnName:   "packet_batch_bak",
	},
}

var ColumnRename623 = []*ColumnRenames{
	&ColumnRenames{
		Db:             "flow_log",
		Tables:         []string{"l7_flow_log", "l7_flow_log_local"},
		OldColumnNames: []string{"service_name", "service_instance_id"},
		NewColumnNames: []string{"app_service", "app_instance"},
	},
	&ColumnRenames{
		Db:             "flow_log",
		Tables:         flowLogTables,
		OldColumnNames: u8OldColumnEdgeName623,
		NewColumnNames: u8NewColumnEdgeName623,
		DropIndex:      true,
	},
	&ColumnRenames{
		Db:             "flow_log",
		Tables:         flowLogTables,
		OldColumnNames: u32OldColumnEdgeName623,
		NewColumnNames: u32NewColumnEdgeName623,
		DropIndex:      true,
	},
	&ColumnRenames{
		Db:             "flow_metrics",
		Tables:         flowMetricsTables,
		OldColumnNames: u8OldColumnName623,
		NewColumnNames: u8NewColumnName623,
		DropIndex:      true,
		DropMvTable:    true,
	},
	&ColumnRenames{
		Db:             "flow_metrics",
		Tables:         flowMetricsTables,
		OldColumnNames: u32OldColumnName623,
		NewColumnNames: u32NewColumnName623,
		DropIndex:      true,
		DropMvTable:    true,
	},
	&ColumnRenames{
		Db:             "flow_metrics",
		Tables:         flowMetricsEdgeTables,
		OldColumnNames: u8OldColumnEdgeName623,
		NewColumnNames: u8NewColumnEdgeName623,
		DropIndex:      true,
		DropMvTable:    true,
	},
	&ColumnRenames{
		Db:             "flow_metrics",
		Tables:         flowMetricsEdgeTables,
		OldColumnNames: u32OldColumnEdgeName623,
		NewColumnNames: u32NewColumnEdgeName623,
		DropIndex:      true,
		DropMvTable:    true,
	},
	&ColumnRenames{
		Db:             "ext_metrics",
		Tables:         []string{"metrics", "metrics_local"},
		OldColumnNames: u8OldColumnName623,
		NewColumnNames: u8NewColumnName623,
		DropIndex:      true,
	},
	&ColumnRenames{
		Db:             "ext_metrics",
		Tables:         []string{"metrics", "metrics_local"},
		OldColumnNames: u32OldColumnName623,
		NewColumnNames: u32NewColumnName623,
		DropIndex:      true,
	},
}

var ColumnRenames626 = []*ColumnRenames{
	&ColumnRenames{
		Db:             "flow_log",
		Tables:         []string{"l7_packet", "l7_packet_local"},
		OldColumnNames: []string{"pcap_count", "pcap_batch"},
		NewColumnNames: []string{"packet_count", "packet_batch"},
	},
}

var IndexAdd64 = []*IndexAdds{
	&IndexAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log_local"},
		ColumnNames: []string{"trace_id", "x_request_id_0", "x_request_id_1", "request_resource", "request_domain", "endpoint"},
		IndexType:   ckdb.IndexBloomfilter,
	},
	&IndexAdds{
		Dbs:         []string{"flow_log"},
		Tables:      []string{"l7_flow_log_local"},
		ColumnNames: []string{"_id", "trace_id_index"},
		IndexType:   ckdb.IndexMinmax,
	},
}

var TableModTTL64 = []*TableModTTL{
	&TableModTTL{
		Db:     "flow_metrics",
		Table:  "vtap_acl.1m_local",
		NewTTL: 168,
	},
}

var TableRenames611 = []*TableRename{
	&TableRename{
		OldDb:     "vtap_acl",
		OldTables: []string{"1m_local"},
		NewDb:     "flow_metrics",
		NewTables: []string{"vtap_acl.1m_local"},
	},
	&TableRename{
		OldDb:     "vtap_flow_port",
		OldTables: []string{"1m_local", "1s_local"},
		NewDb:     "flow_metrics",
		NewTables: []string{"vtap_flow_port.1m_local", "vtap_flow_port.1s_local"},
	},
	&TableRename{
		OldDb:     "vtap_flow_edge_port",
		OldTables: []string{"1m_local", "1s_local"},
		NewDb:     "flow_metrics",
		NewTables: []string{"vtap_flow_edge_port.1m_local", "vtap_flow_edgeport.1s_local"},
	},
	&TableRename{
		OldDb:     "vtap_app_port",
		OldTables: []string{"1m_local", "1s_local"},
		NewDb:     "flow_metrics",
		NewTables: []string{"vtap_app_port.1m_local", "vtap_app_port.1s_local"},
	},
	&TableRename{
		OldDb:     "vtap_app_edge_port",
		OldTables: []string{"1m_local", "1s_local"},
		NewDb:     "flow_metrics",
		NewTables: []string{"vtap_app_edge_port.1m_local", "vtap_app_edge_port.1s_local"},
	},
}

var TableRenames626 = []*TableRename{
	&TableRename{
		OldDb:     "event",
		OldTables: []string{"event", "event_local"},
		NewDb:     "event",
		NewTables: []string{"event_v625", "event_local_v625"},
	},
}

Types

type ColumnAdd

type ColumnAdd struct {
	Db           string
	Table        string
	ColumnName   string
	ColumnType   ckdb.ColumnType
	DefaultValue string
}

type ColumnAdds

type ColumnAdds struct {
	Dbs          []string
	Tables       []string
	ColumnNames  []string
	ColumnType   ckdb.ColumnType
	DefaultValue string
}

type ColumnDrop

type ColumnDrop struct {
	Db         string
	Table      string
	ColumnName string
}

type ColumnDrops

type ColumnDrops struct {
	Dbs         []string
	Tables      []string
	ColumnNames []string
}

type ColumnMod

type ColumnMod struct {
	Db            string
	Table         string
	ColumnName    string
	NewColumnType ckdb.ColumnType
	DropIndex     bool
}

type ColumnRename

type ColumnRename struct {
	Db              string
	Table           string
	OldColumnName   string
	CheckColumnType bool
	OldColumnType   string
	NewColumnName   string
	DropIndex       bool
	DropMvTable     bool
}

type ColumnRenames

type ColumnRenames struct {
	Db              string
	Tables          []string
	OldColumnNames  []string
	CheckColumnType bool
	OldColumnType   string
	NewColumnNames  []string
	DropIndex       bool
	DropMvTable     bool
}

type DatasourceInfo

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

type IndexAdd

type IndexAdd struct {
	Db         string
	Table      string
	ColumnName string
	IndexType  ckdb.IndexType
}

type IndexAdds

type IndexAdds struct {
	Dbs         []string
	Tables      []string
	ColumnNames []string
	IndexType   ckdb.IndexType
}

type Issu

type Issu struct {
	Connections common.DBs
	Addrs       []string
	// contains filtered or unexported fields
}

func NewCKIssu

func NewCKIssu(cfg *config.Config) (*Issu, error)

func (*Issu) Close

func (i *Issu) Close() error

func (*Issu) RunRenameTable

func (i *Issu) RunRenameTable(ds *datasource.DatasourceManager) error

func (*Issu) Start

func (i *Issu) Start() error

type TableModTTL

type TableModTTL struct {
	Db     string
	Table  string
	NewTTL int
}

type TableRename

type TableRename struct {
	OldDb     string
	OldTables []string
	NewDb     string
	NewTables []string
}