forked from fluent/fluent-bit
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'master' of https://github.com/fluent/fluent-bit into ot…
…elsat
- Loading branch information
Showing
1,506 changed files
with
18,646 additions
and
100,918 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,68 @@ | ||
| /* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ | ||
|
|
||
| /* Fluent Bit | ||
| * ========== | ||
| * Copyright (C) 2015-2024 The Fluent Bit Authors | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
| #ifndef FLB_CALYPTIA_CONSTANTS_H | ||
| #define FLB_CALYPTIA_CONSTANTS_H | ||
|
|
||
| /* End point */ | ||
| #define DEFAULT_CALYPTIA_HOST "cloud-api.calyptia.com" | ||
| #define DEFAULT_CALYPTIA_PORT "443" | ||
|
|
||
| /* HTTP action types */ | ||
| #define CALYPTIA_ACTION_REGISTER 0 | ||
| #define CALYPTIA_ACTION_PATCH 1 | ||
| #define CALYPTIA_ACTION_METRICS 2 | ||
| #define CALYPTIA_ACTION_TRACE 3 | ||
|
|
||
| /* Endpoints */ | ||
| #define CALYPTIA_ENDPOINT_CREATE "/v1/agents" | ||
| #define CALYPTIA_ENDPOINT_PATCH "/v1/agents/%s" | ||
| #define CALYPTIA_ENDPOINT_METRICS "/v1/agents/%s/metrics" | ||
| #define CALYPTIA_ENDPOINT_TRACE "/v1/traces/%s" | ||
|
|
||
| #define CALYPTIA_ENDPOINT_FLEETS "/v1/fleets" | ||
| #define CALYPTIA_ENDPOINT_FLEET_CONFIG_INI "/v1/fleets/%s/config?format=ini" | ||
| #define CALYPTIA_ENDPOINT_FLEET_FILES "/v1/fleets/%s/files" | ||
|
|
||
| /* Storage */ | ||
| #define CALYPTIA_SESSION_FILE "session.CALYPTIA" | ||
|
|
||
| /* Headers */ | ||
| #define CALYPTIA_HEADERS_PROJECT "X-Project-Token" | ||
| #define CALYPTIA_HEADERS_AGENT_TOKEN "X-Agent-Token" | ||
| #define CALYPTIA_HEADERS_CTYPE "Content-Type" | ||
| #define CALYPTIA_HEADERS_CTYPE_JSON "application/json" | ||
| #define CALYPTIA_HEADERS_CTYPE_MSGPACK "application/x-msgpack" | ||
|
|
||
| #ifndef FLB_SYSTEM_WINDOWS | ||
| #define FLEET_DEFAULT_CONFIG_DIR "/tmp/calyptia-fleet" | ||
| #else | ||
| #define FLEET_DEFAULT_CONFIG_DIR NULL | ||
| #endif | ||
|
|
||
| #ifndef PATH_SEPARATOR | ||
| #ifndef FLB_SYSTEM_WINDOWS | ||
| #define PATH_SEPARATOR "/" | ||
| #else | ||
| #define PATH_SEPARATOR "\\" | ||
| #endif | ||
| #endif /* PATH_SEPARATOR */ | ||
|
|
||
| #define CALYPTIA_MAX_DIR_SIZE 4096 | ||
|
|
||
| #endif /* FLB_CALYPTIA_CONSTANTS_H */ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,74 @@ | ||
| /* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ | ||
|
|
||
| /* Fluent Bit | ||
| * ========== | ||
| * Copyright (C) 2015-2024 The Fluent Bit Authors | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
||
| #ifndef FLB_CFL_RA_KEY_H | ||
| #define FLB_CFL_RA_KEY_H | ||
|
|
||
| #include <fluent-bit/flb_info.h> | ||
| #include <fluent-bit/flb_sds.h> | ||
| #include <fluent-bit/flb_regex.h> | ||
| #include <fluent-bit/record_accessor/flb_ra_parser.h> | ||
| #include <monkey/mk_core.h> | ||
| #include <cfl/cfl.h> | ||
|
|
||
| #include <stdbool.h> | ||
|
|
||
| enum cfl_ra_types { | ||
| FLB_CFL_RA_BOOL = 0, | ||
| FLB_CFL_RA_INT, | ||
| FLB_CFL_RA_FLOAT, | ||
| FLB_CFL_RA_STRING, | ||
| FLB_CFL_RA_NULL | ||
| }; | ||
|
|
||
| /* condition value types */ | ||
| typedef union { | ||
| bool boolean; | ||
| int64_t i64; | ||
| double f64; | ||
| flb_sds_t string; | ||
| } cfl_ra_val; | ||
|
|
||
| /* Represent any value object */ | ||
| struct flb_cfl_ra_value { | ||
| int type; | ||
| struct cfl_variant v; | ||
| cfl_ra_val val; | ||
| }; | ||
|
|
||
| struct flb_cfl_ra_value *flb_cfl_ra_key_to_value(flb_sds_t ckey, | ||
| struct cfl_variant vobj, | ||
| struct mk_list *subkeys); | ||
| void flb_cfl_ra_key_value_destroy(struct flb_cfl_ra_value *v); | ||
|
|
||
| int flb_cfl_ra_key_value_get(flb_sds_t ckey, struct cfl_variant vobj, | ||
| struct mk_list *subkeys, | ||
| cfl_sds_t *start_key, | ||
| cfl_sds_t *out_key, struct cfl_variant **out_val); | ||
|
|
||
| int flb_cfl_ra_key_strcmp(flb_sds_t ckey, struct cfl_variant vobj, | ||
| struct mk_list *subkeys, char *str, int len); | ||
| int flb_cfl_ra_key_regex_match(flb_sds_t ckey, struct cfl_variant vobj, | ||
| struct mk_list *subkeys, struct flb_regex *regex, | ||
| struct flb_regex_search *result); | ||
| int flb_cfl_ra_key_value_append(struct flb_ra_parser *rp, struct cfl_variant *vobj, | ||
| struct cfl_variant *in_val); | ||
| int flb_cfl_ra_key_value_update(struct flb_ra_parser *rp, struct cfl_variant *vobj, | ||
| cfl_sds_t in_key, struct cfl_variant *in_val); | ||
| #endif |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,64 @@ | ||
| /* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ | ||
|
|
||
| /* Fluent Bit | ||
| * ========== | ||
| * Copyright (C) 2015-2024 The Fluent Bit Authors | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
||
| #ifndef FLB_CFL_RECORD_ACCESSOR_H | ||
| #define FLB_CFL_RECORD_ACCESSOR_H | ||
|
|
||
| #include <fluent-bit/flb_info.h> | ||
| #include <fluent-bit/flb_regex.h> | ||
| #include <fluent-bit/flb_sds.h> | ||
| #include <fluent-bit/flb_sds_list.h> | ||
| #include <monkey/mk_core.h> | ||
| #include <cfl/cfl.h> | ||
|
|
||
| struct flb_cfl_record_accessor { | ||
| size_t size_hint; | ||
| flb_sds_t pattern; | ||
| struct mk_list list; /* List of parsed strings */ | ||
| struct mk_list _head; /* Head to custom list (only used by flb_mp.h) */ | ||
| }; | ||
| void flb_cfl_ra_destroy(struct flb_cfl_record_accessor *cra); | ||
| int flb_cfl_ra_subkey_count(struct flb_cfl_record_accessor *cra); | ||
| struct flb_cfl_record_accessor *flb_cfl_ra_create(char *str, int translate_env); | ||
| flb_sds_t flb_cfl_ra_create_str_from_list(struct flb_sds_list *str_list); | ||
| struct flb_cfl_record_accessor *flb_cfl_ra_create_from_list(struct flb_sds_list *str_list, int translate_env); | ||
| flb_sds_t flb_cfl_ra_translate(struct flb_cfl_record_accessor *cra, | ||
| char *tag, int tag_len, | ||
| struct cfl_variant var, struct flb_regex_search *result); | ||
| flb_sds_t flb_cfl_ra_translate_check(struct flb_cfl_record_accessor *cra, | ||
| char *tag, int tag_len, | ||
| struct cfl_variant var, struct flb_regex_search *result, | ||
| int check); | ||
| void flb_cfl_ra_dump(struct flb_cfl_record_accessor *cra); | ||
| int flb_cfl_ra_is_static(struct flb_cfl_record_accessor *cra); | ||
| int flb_cfl_ra_strcmp(struct flb_cfl_record_accessor *ra, struct cfl_variant var, | ||
| char *str, int len); | ||
| int flb_cfl_ra_regex_match(struct flb_cfl_record_accessor *cra, struct cfl_variant var, | ||
| struct flb_regex *regex, struct flb_regex_search *result); | ||
| int flb_cfl_ra_get_kv_pair(struct flb_cfl_record_accessor *ra, | ||
| struct cfl_variant var, | ||
| cfl_sds_t *start_key, | ||
| cfl_sds_t *out_key, struct cfl_variant **out_val); | ||
| struct flb_cfl_ra_value *flb_cfl_ra_get_value_object(struct flb_cfl_record_accessor *cra, | ||
| struct cfl_variant var); | ||
| int flb_cfl_ra_update_kv_pair(struct flb_cfl_record_accessor *cra, struct cfl_variant var, | ||
| cfl_sds_t in_key, struct cfl_variant *in_val); | ||
| int flb_cfl_ra_append_kv_pair(struct flb_cfl_record_accessor *cra, struct cfl_variant var, | ||
| struct cfl_variant *in_val); | ||
| #endif |
Oops, something went wrong.