Versions in this module Expand all Collapse all v1 v1.6.65 Sep 23, 2024 v1.6.64 Sep 13, 2024 v1.6.4 Sep 13, 2024 Changes in this version + const ACCEPT_JSON + const ACL_STATE_ENABLE + const AGENT_IDENTIFIE_IP + const AGENT_IDENTIFIE_IP_AND_MAC + const AGENT_SYNC + const AGENT_SYNC_EN + const ALIYUN + const ALIYUN_CH + const ALIYUN_EN + const ANALYZER_ALLOC_BY_AGENT_COUNT + const ANALYZER_ALLOC_BY_INGESTED_DATA + const APSARA_STACK + const APSARA_STACK_EN + const ARCH_ARM + const ARCH_X86 + const AWS + const AWS_CH + const AWS_EN + const AZURE + const AZURE_EN + const BAIDU_BCE + const BAIDU_BCE_CH + const BAIDU_BCE_EN + const BILLING_METHOD_LICENSE + const BILLING_METHOD_VOUCHER + const CLOUD_METRIC_NAME_API_COST + const CLOUD_METRIC_NAME_API_COUNT + const CLOUD_METRIC_NAME_INFO_COUNT + const CLOUD_METRIC_NAME_TASK_COST + const CLOUD_TOWER + const CLOUD_TOWER_CH + const CLOUD_TOWER_EN + const CMB_CMDB + const CMB_CMDB_EN + const CONTACT_CREATE_METHOD_LEARN + const CONTENT_TYPE_JSON + const CONTEXT_TYPE_FORM + const CONTROLLER_NODE_TYPE_MASTER + const CONTROLLER_NODE_TYPE_SLAVE + const CONTROLLER_STATE_EXCEPTION + const CONTROLLER_STATE_NORMAL + const CREATE_METHOD_LEARN + const CREATE_METHOD_USER_DEFINE + const DATA_SOURCE_APPLICATION + const DATA_SOURCE_DEEPFLOW_SYSTEM_INTERVAL + const DATA_SOURCE_NETWORK + const DATA_SOURCE_STATE_EXCEPTION + const DATA_SOURCE_STATE_NORMAL + const DATA_SOURCE_TRAFFIC_POLICY + const DEFAULT_ALL_MATCH_REGEX + const DEFAULT_APP_KEY + const DEFAULT_AZ + const DEFAULT_DOMAIN + const DEFAULT_DOMAIN_ICON + const DEFAULT_ENCRYPTION_PASSWORD + const DEFAULT_NOT_MATCH_REGEX + const DEFAULT_ORG_ID + const DEFAULT_PORT_NAME_REGEX + const DEFAULT_REGION + const DEFAULT_REGION_NAME + const DEFAULT_TEAM_ID + const DEFAULT_USER_ID + const DEFAULT_USER_TYPE + const DEFAULT_VTAP_GROUP_ID + const DOMAIN_ENABLED_FALSE + const DOMAIN_ENABLED_TRUE + const DOMAIN_STATE_NORMAL + const ESHORE + const ESHORE_CH + const ESHORE_EN + const F5 + const F5_EN + const FILEREADER + const FILEREADER_EN + const GENESIS_METRIC_NAME_K8SINFO_DELAY + const GO_BIRTHDAY + const H3C + const H3C_CH + const H3C_EN + const HEADER_KEY_ACCEPT + const HEADER_KEY_CONTENT_TYPE + const HEADER_KEY_X_APP_KEY + const HEADER_KEY_X_ORG_ID + const HEADER_KEY_X_USER_ID + const HEADER_KEY_X_USER_TYPE + const HEALTH_CHECK_INTERVAL + const HEALTH_CHECK_URL + const HOST_HTYPE_ESXI + const HOST_HTYPE_GATEWAY + const HOST_HTYPE_HYPER_V + const HOST_HTYPE_KVM + const HOST_MEMORY_MB + const HOST_STATE_COMPLETE + const HOST_STATE_EXCEPTION + const HOST_STATE_MAINTENANCE + const HOST_TYPE_ANALYZER + const HOST_TYPE_CONTROLLER + const HOST_TYPE_DFI + const HOST_TYPE_NSP + const HOST_TYPE_VM + const HOST_VCPUS + const HUAWEI + const HUAWEI_CH + const HUAWEI_EN + const HUAWEI_PRIVATE + const HUAWEI_PRIVATE_EN + const INGESTER_API_PORT + const INGESTER_BODY_ORG_ID + const INTERVAL_1DAY + const INTERVAL_1HOUR + const INTERVAL_1MINUTE + const INTERVAL_1MONTH + const INTERVAL_1WEEK + const INTERVAL_1YEAR + const IPV4_DEFAULT_NETMASK + const IPV4_MAX_MASK + const IPV6_DEFAULT_NETMASK + const IPV6_MAX_MASK + const K8S_CA_CRT_PATH + const K8S_POD_IPV4_NETMASK + const K8S_POD_IPV6_NETMASK + const KINGSOFT_PRIVATE + const KINGSOFT_PRIVATE_CH + const KINGSOFT_PRIVATE_EN + const KUBERNETES + const KUBERNETES_CH + const KUBERNETES_EN + const LB_MODEL_EXTERNAL + const LB_MODEL_INTERNAL + const LB_SERVER_TYPE_IP + const LB_SERVER_TYPE_VM + const LOCALHOST + const MASTER_CONTROLLER_CHECK_PORT + const MICROSOFT_ACS + const MICROSOFT_ACS_EN + const MICROSOFT_CH + const NAME_SPACE_KEY + const NETWORK_ISP_LCUUID + const NETWORK_TYPE_LAN + const NETWORK_TYPE_WAN + const NFVO + const NFVO_CH + const NFVO_EN + const NODE_IP_KEY + const NODE_NAME_KEY + const NPB_POLICY_FLOW_DISTRIBUTE + const NPB_POLICY_FLOW_DROP + const NSP + const NSP_CH + const NSP_EN + const OPENSTACK + const OPENSTACK_CH + const OPENSTACK_EN + const ORG_ID_MAX + const OS_ANDROID + const OS_CENTOS + const OS_REDHAT + const OS_SUSE + const OS_UBUNTU + const OS_WINDOWS + const PLUGIN_TYPE_LUA + const PLUGIN_TYPE_SO + const PLUGIN_TYPE_WASM + const POD_GROUP_CLONESET + const POD_GROUP_DAEMON_SET + const POD_GROUP_DEPLOYMENT + const POD_GROUP_RC + const POD_GROUP_REPLICASET_CONTROLLER + const POD_GROUP_STATEFULSET + const POD_IP_KEY + const POD_NAME_KEY + const POD_NODE_SERVER_TYPE_HOST + const POD_NODE_SERVER_TYPE_VM + const POD_NODE_STATE_EXCEPTION + const POD_NODE_STATE_NORMAL + const POD_NODE_TYPE_MASTER + const POD_NODE_TYPE_NODE + const POD_SERVICE_TYPE_CLUSTERIP + const POD_SERVICE_TYPE_LOADBALANCER + const POD_SERVICE_TYPE_NODEPORT + const POD_STATE_EXCEPTION + const POD_STATE_RUNNING + const PROCESS_INSTANCE_TYPE + const PROMETHEUS_TARGET_CREATE_METHOD_PROMETHEUS + const PROMETHEUS_TARGET_CREATE_METHOD_RECORDER + const QINGCLOUD + const QINGCLOUD_CH + const QINGCLOUD_EN + const QINGCLOUD_K8S_EN + const QINGCLOUD_PRIVATE + const QINGCLOUD_PRIVATE_EN + const RDS_MODEL_GUARD + const RDS_MODEL_PRIMARY + const RDS_MODEL_READONLY + const RDS_MODEL_SHARE + const RDS_MODEL_TEMPORARY + const RDS_SERIES_BASIC + const RDS_SERIES_HA + const RDS_STATE_RESTORING + const RDS_STATE_RUNNING + const RDS_TYPE_MARIADB + const RDS_TYPE_MYSQL + const RDS_TYPE_PPAS + const RDS_TYPE_PSQL + const RDS_TYPE_SQL_SERVER + const RDS_UNKNOWN + const REDIS_STATE_RUNNING + const REMOTE_API_TIMEOUT + const RESOURCE_STATE_CODE_DELETING + const RESOURCE_STATE_CODE_EXCEPTION + const RESOURCE_STATE_CODE_SUCCESS + const RESOURCE_STATE_CODE_WARNING + const RESOURCE_TYPE_ALL_IP_EN + const RESOURCE_TYPE_AZ_EN + const RESOURCE_TYPE_CEN_EN + const RESOURCE_TYPE_DHCP_PORT_EN + const RESOURCE_TYPE_FLOATING_IP_EN + const RESOURCE_TYPE_HOST_EN + const RESOURCE_TYPE_IP_EN + const RESOURCE_TYPE_LAN_IP_EN + const RESOURCE_TYPE_LB_EN + const RESOURCE_TYPE_LB_LISTENER_EN + const RESOURCE_TYPE_LB_RULE_EN + const RESOURCE_TYPE_LB_TARGET_SERVER_EN + const RESOURCE_TYPE_LB_VM_CONNECTION_EN + const RESOURCE_TYPE_NAT_GATEWAY_EN + const RESOURCE_TYPE_NAT_RULE_EN + const RESOURCE_TYPE_NAT_VM_CONNECTION_EN + const RESOURCE_TYPE_NETWORK_EN + const RESOURCE_TYPE_ORG_EN + const RESOURCE_TYPE_PEER_CONNECTION_EN + const RESOURCE_TYPE_POD_CLUSTER_EN + const RESOURCE_TYPE_POD_EN + const RESOURCE_TYPE_POD_GROUP_EN + const RESOURCE_TYPE_POD_GROUP_PORT_EN + const RESOURCE_TYPE_POD_INGRESS_EN + const RESOURCE_TYPE_POD_INGRESS_RULE_BACKEND_EN + const RESOURCE_TYPE_POD_INGRESS_RULE_EN + const RESOURCE_TYPE_POD_NAMESPACE_EN + const RESOURCE_TYPE_POD_NODE_EN + const RESOURCE_TYPE_POD_REPLICA_SET_EN + const RESOURCE_TYPE_POD_SERVICE_EN + const RESOURCE_TYPE_POD_SERVICE_PORT_EN + const RESOURCE_TYPE_PROCESS_EN + const RESOURCE_TYPE_PROMETHEUS_TARGET_EN + const RESOURCE_TYPE_RDS_INSTANCE_EN + const RESOURCE_TYPE_REDIS_INSTANCE_EN + const RESOURCE_TYPE_REGION_EN + const RESOURCE_TYPE_ROUTING_TABLE_EN + const RESOURCE_TYPE_SECURITY_GROUP_EN + const RESOURCE_TYPE_SECURITY_GROUP_RULE_EN + const RESOURCE_TYPE_SUBNET_EN + const RESOURCE_TYPE_SUB_DOMAIN_EN + const RESOURCE_TYPE_VINTERFACE_EN + const RESOURCE_TYPE_VIP_EN + const RESOURCE_TYPE_VM_EN + const RESOURCE_TYPE_VM_POD_NODE_CONNECTION_EN + const RESOURCE_TYPE_VM_SECURITY_GROUP_EN + const RESOURCE_TYPE_VPC_EN + const RESOURCE_TYPE_VROUTER_EN + const RESOURCE_TYPE_VTAP_EN + const RESOURCE_TYPE_WAN_IP_EN + const ROUTING_TABLE_TYPE_INSTANCE + const ROUTING_TABLE_TYPE_IP + const ROUTING_TABLE_TYPE_LOCAL + const ROUTING_TABLE_TYPE_NAT_GATEWAY + const ROUTING_TABLE_TYPE_PEER_CONNECTION + const ROUTING_TABLE_TYPE_ROUTER + const ROUTING_TABLE_TYPE_VPN + const RUNNING_MODE_KEY + const RUNNING_MODE_STANDALONE + const SECURITY_GROUP_IP_TYPE_UNKNOWN + const SECURITY_GROUP_RULE_ACCEPT + const SECURITY_GROUP_RULE_DROP + const SECURITY_GROUP_RULE_EGRESS + const SECURITY_GROUP_RULE_INGRESS + const SECURITY_GROUP_RULE_IPV4 + const SECURITY_GROUP_RULE_IPV4_CIDR + const SECURITY_GROUP_RULE_IPV6 + const SECURITY_GROUP_RULE_IPV6_CIDR + const SECURITY_GROUP_RULE_UNKNOWN + const SET_RESOURCE_TYPE_AGENT + const SET_RESOURCE_TYPE_AGENT_GROUP + const SET_RESOURCE_TYPE_AGENT_GROUP_CONFIG + const SET_RESOURCE_TYPE_DATA_SOURCE + const SET_RESOURCE_TYPE_DOMAIN + const SET_RESOURCE_TYPE_SUB_DOMAIN + const SHORT_UUID_LENGTH + const SIMULATION + const SIMULATION_EN + const STRINGS_JOIN_COMMA + const SUBNET_ISP_LCUUID + const SUB_DOMAIN_ERROR_DISPLAY_NUM + const SUGON + const SUGON_CH + const SUGON_EN + const TAPMODE_ANALYZER + const TAPMODE_DECAP + const TAPMODE_LOCAL + const TAPMODE_MIRROR + const TENCENT + const TENCENT_CH + const TENCENT_EN + const TENCENT_TCE + const TENCENT_TCE_EN + const TRISOLARIS_NODE_TYPE_MASTER + const USER_ID_SUPER_ADMIN + const USER_TYPE_ADMIN + const USER_TYPE_SUPER_ADMIN + const VIF_DEFAULT_MAC + const VIF_DEVICE_TYPE_DHCP_PORT + const VIF_DEVICE_TYPE_GPROCESS + const VIF_DEVICE_TYPE_HOST + const VIF_DEVICE_TYPE_INTERNET + const VIF_DEVICE_TYPE_IP + const VIF_DEVICE_TYPE_LB + const VIF_DEVICE_TYPE_NAT_GATEWAY + const VIF_DEVICE_TYPE_POD + const VIF_DEVICE_TYPE_POD_CLUSTER + const VIF_DEVICE_TYPE_POD_GROUP + const VIF_DEVICE_TYPE_POD_GROUP_CLONESET + const VIF_DEVICE_TYPE_POD_GROUP_DAEMON_SET + const VIF_DEVICE_TYPE_POD_GROUP_DEPLOYMENT + const VIF_DEVICE_TYPE_POD_GROUP_RC + const VIF_DEVICE_TYPE_POD_GROUP_REPLICASET_CONTROLLER + const VIF_DEVICE_TYPE_POD_GROUP_STATEFULSET + const VIF_DEVICE_TYPE_POD_NODE + const VIF_DEVICE_TYPE_POD_SERVICE + const VIF_DEVICE_TYPE_RDS_INSTANCE + const VIF_DEVICE_TYPE_REDIS_INSTANCE + const VIF_DEVICE_TYPE_SERVICE + const VIF_DEVICE_TYPE_VM + const VIF_DEVICE_TYPE_VROUTER + const VIF_TYPE_LAN + const VIF_TYPE_WAN + const VM_HTYPE_BM_C + const VM_HTYPE_BM_N + const VM_HTYPE_BM_S + const VM_HTYPE_VM_C + const VM_HTYPE_VM_N + const VM_HTYPE_VM_S + const VM_STATE_EXCEPTION + const VM_STATE_RUNNING + const VM_STATE_STOPPED + const VOLCENGINE + const VOLCENGINE_CH + const VOLCENGINE_EN + const VSPHERE + const VSPHERE_CH + const VSPHERE_EN + const VTAP_ALL_LICENSE_FUNCTIONS + const VTAP_ENABLE_FALSE + const VTAP_ENABLE_TRUE + const VTAP_EXCEPTION_ALLOC_ANALYZER_FAILED + const VTAP_EXCEPTION_ALLOC_CONTROLLER_FAILED + const VTAP_EXCEPTION_LICENSE_NOT_ENGOUTH + const VTAP_LICENSE_CHECK_INTERVAL + const VTAP_LICENSE_FUNCTION_APPLICATION_MONITORING + const VTAP_LICENSE_FUNCTION_CALL_MONITORING + const VTAP_LICENSE_FUNCTION_DATABASE_MONITORING + const VTAP_LICENSE_FUNCTION_FUNCTION_MONITORING + const VTAP_LICENSE_FUNCTION_INDICATOR_MONITORING + const VTAP_LICENSE_FUNCTION_LOG_MONITORING + const VTAP_LICENSE_FUNCTION_MAX + const VTAP_LICENSE_FUNCTION_NETWORK_MONITORING + const VTAP_LICENSE_FUNCTION_NONE + const VTAP_LICENSE_FUNCTION_TRAFFIC_DISTRIBUTION + const VTAP_LICENSE_TYPE_A + const VTAP_LICENSE_TYPE_B + const VTAP_LICENSE_TYPE_C + const VTAP_LICENSE_TYPE_DEDICATED + const VTAP_LICENSE_TYPE_MAX + const VTAP_LICENSE_TYPE_NONE + const VTAP_STATE_DISABLE + const VTAP_STATE_DISABLE_STR + const VTAP_STATE_NORMAL + const VTAP_STATE_NORMAL_STR + const VTAP_STATE_NOT_CONNECTED + const VTAP_STATE_NOT_CONNECTED_STR + const VTAP_STATE_PENDING + const VTAP_STATE_PENDING_STR + const VTAP_TYPE_DEDICATED + const VTAP_TYPE_ESXI + const VTAP_TYPE_HYPER_V + const VTAP_TYPE_K8S_SIDECAR + const VTAP_TYPE_KVM + const VTAP_TYPE_POD_HOST + const VTAP_TYPE_POD_VM + const VTAP_TYPE_TUNNEL_DECAPSULATION + const VTAP_TYPE_WORKLOAD_P + const VTAP_TYPE_WORKLOAD_V + const ZSTACK + const ZSTACK_CH + const ZSTACK_EN + var CAMD5 string + var CloudMonitorExceptionAPI = map[string]string + var DefaultAnalyzerIP = "" + var DefaultAnalyzerPort = 30033 + var DefaultBandwidthProbeInterval = 10 + var DefaultCaptureBpf = "" + var DefaultCapturePacketSize = 65535 + var DefaultCaptureSocketType = 0 + var DefaultCollectorEnabled = 1 + var DefaultCollectorSocketType = "TCP" + var DefaultCompressorSocketType = "TCP" + var DefaultDecapType = "1,2" + var DefaultDomains = "0" + var DefaultExternalAgentHTTPProxyEnabled = 1 + var DefaultExternalAgentHTTPProxyPort = 38086 + var DefaultExtraNetnsRegex = "" + var DefaultHTTPLogProxyClient = "X-Forwarded-For" + var DefaultHTTPLogSpanID = "traceparent, sw8" + var DefaultHTTPLogTraceID = "traceparent, sw8" + var DefaultHTTPLogXRequestID = "X-Request-ID" + var DefaultIfMacSource = 0 + var DefaultInactiveIPEnabled = 1 + var DefaultInactiveServerPortEnabled = 1 + var DefaultL4LogCollectNpsThreshold = 10000 + var DefaultL4LogIgnoreTapSides = "" + var DefaultL4LogTapTypes = "0" + var DefaultL4PerformanceEnabled = 1 + var DefaultL7LogCollectNpsThreshold = 10000 + var DefaultL7LogIgnoreTapSides = "" + var DefaultL7LogPacketSize = 1024 + var DefaultL7LogStoreTapTypes = "0" + var DefaultL7MetricsEnabled = 1 + var DefaultLogFileSize = 1000 + var DefaultLogLevel = "INFO" + var DefaultLogRetention = 30 + var DefaultLogThreshold = 300 + var DefaultMaxCPUs = 1 + var DefaultMaxCollectPps = 200000 + var DefaultMaxEscapeSeconds = 3600 + var DefaultMaxMemory = 768 + var DefaultMaxMilliCPUs = 1000 + var DefaultMaxNpbBps = int64(1000000000) + var DefaultMaxTxBandwidth = int64(0) + var DefaultMtu = 1500 + var DefaultNatIPEnabled = 0 + var DefaultNpbDedupEnabled = 1 + var DefaultNpbSocketType = "RAW_UDP" + var DefaultNpbVlanMode = 0 + var DefaultNtpEnabled = 0 + var DefaultOutputVlan = 0 + var DefaultPlatformEnabled = 0 + var DefaultPlatformSyncInterval = 10 + var DefaultPodClusterInternalIP = 0 + var DefaultProcessThreshold = 10 + var DefaultProxyControllerIP = "" + var DefaultProxyControllerPort = 30035 + var DefaultRsyslogEnabled = 1 + var DefaultSoPlugins = "" + var DefaultStatsInterval = 10 + var DefaultSyncInterval = 60 + var DefaultSysFreeMemoryLimit = 0 + var DefaultSystemLoadCircuitBreakerMetric = "load15" + var DefaultSystemLoadCircuitBreakerRecover = float32(0.9) + var DefaultSystemLoadCircuitBreakerThreshold = float32(1.0) + var DefaultTapInterfaceRegex = "^(tap.*|cali.*|veth.*|eth.*|en[osipx].*|lxc.*|lo|[0-9a-f]+_h)$" + var DefaultTapMode = TAPMODE_LOCAL + var DefaultThreadThreshold = 500 + var DefaultVMXMLPath = "/etc/libvirt/qemu/" + var DefaultVTapFlow1sEnabled = 1 + var DefaultVTapGroupConfig = &agent_config.AgentGroupConfigModel + var DefaultWasmPlugins = "" + var DomainTypeToIconID = map[int]int + var ErrorFail = errors.New("FAIL") + var ErrorPending = errors.New("PENDING") + var IconNameToDomainTypes = map[string][]int + var NameSpace string + var NodeIP string + var NodeName string + var PluginTypeName = map[int]string + var PodIP string + var PodName string + var ProtocolMap = map[string]int + var SUCCESS = "SUCCESS" + var TCP = 6 + var UDP = 17 + var VIF_DEVICE_TYPE_TO_RESOURCE_TYPE = map[int]string + var VTAP_TYPE_TO_DEVICE_TYPE = map[int]int + var VTapExceptionChinese = map[int64]string + var VTapStateToChinese = map[int]string + var VTapToChangeTapModes = map[int][]int + var VTapTypeChinese = map[int]string + var VTapTypeName = map[int]string + var VtapTapModeName = map[int]string + func AesDecrypt(cryptedStr, keyStr string) (string, error) + func AesEncrypt(origDataStr, keyStr string) (string, error) + func CURLForm(method string, url string, values url.Values, options ...HeaderOption) (*simplejson.Json, error) + func CURLPerform(method string, url string, body map[string]interface{}, ...) (*simplejson.Json, error) + func CheckSelfAndGetMasterControllerHostPort() (ok bool, masterCtrlIP string, httpPort, grpcPort int, err error) + func Contains[T Comparable](slice []T, val T) bool + func DecryptSecretKey(secretKey string) (string, error) + func EncryptSecretKey(secretKey string) (string, error) + func GenerateAesKey(input []byte) string + func GenerateKuberneteClusterIDByMD5(md5 string) (string, error) + func GenerateShortUUID() string + func GenerateUUID(str string) string + func GenerateUUIDByOrgID(orgID int, s string) string + func GetArchType(arch string) int + func GetCAMD5() string + func GetCURLIP(ip string) string + func GetEncryptKey(controllerIP, grpcServerPort, key string) (string, error) + func GetLocalClusterID() (string, error) + func GetMasterControllerHostPort() (masterIP string, httpPort, grpcPort int, err error) + func GetNameSpace() string + func GetNodeIP() string + func GetNodeName() string + func GetOsType(os string) int + func GetPodIP() string + func GetPodName() string + func GetSelfController() (*mysqlmodel.Controller, error) + func GetUUID(str string, namespace uuid.UUID) string + func GetUUIDByOrgID(orgID int, s string) string + func GetUUIDByOrgIDAndNamespaceDNS(orgID int, s string) string + func IDGenerateUUID(orgID int, s string) string + func InitEnvData() + func IsStandaloneRunningMode() bool + func IsTCPActive(ip string, port int) error + func PKCS7Padding(ciphertext []byte, blockSize int) []byte + func PKCS7UnPadding(origData []byte) []byte + func StrToJsonAndMap(str string) (resJson string, resMap map[string]string) + type Comparable interface + type DataChanged string + const DATA_CHANGED_ANALYZER + const DATA_CHANGED_FLOW_ACL + const DATA_CHANGED_GROUP + const DATA_CHANGED_PLATFORM_DATA + const DATA_CHANGED_SERVICE + const DATA_CHANGED_TAP_TYPE + const DATA_CHANGED_VTAP + type FPermit struct + Enabled bool + Host string + Port int + Timeout int + type GlobalConfig struct + GRPCNodePort int + GRPCPort int + HTTPNodePort int + HTTPPort int + var GConfig *GlobalConfig + type HeaderOption func(req *http.Request) + func WithHeader(key, value string) HeaderOption + func WithORGHeader(value string) HeaderOption + type IngesterApi struct + NodePort int + Port int + Timeout int + type KVPair struct + Key string + Value int