-
Notifications
You must be signed in to change notification settings - Fork 70
Support local logging of events #755
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Merged
Merged
Changes from 1 commit
Commits
Show all changes
169 commits
Select commit
Hold shift + click to select a range
c7f4627
POC
attilakreiner 1a7592f
fix
attilakreiner 3609baa
WIP HttpEventContext
attilakreiner d4a6ec6
WIP core Event
attilakreiner ddef06c
WIP EngineWorker logEvent
attilakreiner a4399ca
WIP code BindingEvent
attilakreiner 66202a9
WIP h2
attilakreiner d67cf9e
WIP identity
attilakreiner 95aefb3
WIP mqtt
attilakreiner e137363
fix
attilakreiner 7cd659f
fix
attilakreiner 3c40746
WIP MessageConsumer
attilakreiner e58cd98
WIP SchemaRegistryEventContext
attilakreiner e6a4c09
WIP TcpEventContext
attilakreiner 2916bed
WIP tls
attilakreiner 35a723c
WIP kafka
attilakreiner d304db7
WIP kafka apiversion
attilakreiner 5d3d78b
mv schmea_registry.idl
attilakreiner 4b86a93
WIP fix rm Result
attilakreiner d18a716
ref lvl
attilakreiner 66ea78f
Add catalogId
attilakreiner 10663a8
fix rm initialId
attilakreiner adba065
fix 1
attilakreiner 5504201
fix 2
attilakreiner bd145f6
fix 3
attilakreiner 2162630
fix 4
attilakreiner 1b9d779
fix 5
attilakreiner f2e867b
fix 6
attilakreiner 6af5130
fix 7
attilakreiner 4efa893
WIP kafka api version
attilakreiner a8e6e8c
Merge branch 'develop' into log
attilakreiner 3be3ed3
fix
attilakreiner 377ca3c
ref proxy.idl to tls.idl
attilakreiner 45d33e4
ref proxy.idl to tcp.idl
attilakreiner ded8235
fix
attilakreiner 431300d
fix
attilakreiner 33d1745
WIP EventsLayout
attilakreiner f8e4ced
WIP timestamp
attilakreiner a8d6b19
WIP StdoutExporter
attilakreiner a675aac
WIP EventsLayout
attilakreiner da36031
WIP spy
attilakreiner 907aacc
WIP PrintableEventsStream
attilakreiner b972881
fix
attilakreiner 5083758
fix
attilakreiner 168cad4
fix
attilakreiner 54447ad
fix capacity
attilakreiner a04f78f
WIP EventsLayoutReader rotate
attilakreiner 056a1a8
fix StdoutEventsStream
attilakreiner 9ff65ea
fix schema
attilakreiner c3b8844
fix typeId
attilakreiner ada8412
fix logger
attilakreiner c0f74bb
fix authorization
attilakreiner 62ed116
fix namespacedId
attilakreiner cd263c6
fix supply*
attilakreiner f8c0174
fix logger
attilakreiner e33e09b
fix
attilakreiner 7a8e33e
fix
attilakreiner c712d7b
fix lookupLabelId
attilakreiner 2c0ea9f
fix
attilakreiner be4fa06
WIP ref
attilakreiner 786d434
WIP spies
attilakreiner d0f8585
WIP spies
attilakreiner c5a482c
WIP spies
attilakreiner 1c31152
WIP spies
attilakreiner b934025
WIP StdoutEventsStream
attilakreiner 5fe3ab4
Merge branch 'develop' into log
attilakreiner be6486b
add EventsLayoutTest
attilakreiner 8824343
fix pom
attilakreiner bfa4aca
add StdoutExporterHandlerTest
attilakreiner 62f976e
fix
attilakreiner 624e7ef
fix
attilakreiner 3f9b66c
fix
attilakreiner 8f39a77
fix onDecodeResponseErrorCode
attilakreiner 0f57f30
rm accessDeinied
attilakreiner 393b00b
fix internal
attilakreiner 705ad99
cleanup
attilakreiner 8d63a5d
fix EventReader
attilakreiner b7dfcd9
cleanup
attilakreiner 7ef306d
fix EventHandler
attilakreiner 4a5a7f6
fix
attilakreiner 633ed14
fix tcp
attilakreiner 1289396
fix
attilakreiner c47719f
fix
attilakreiner ed04985
WIP RingBufferSpy
attilakreiner db2cf89
Revert "WIP RingBufferSpy"
attilakreiner 6b74346
WIP eventReadingQueue
attilakreiner 29d06f3
WIP sortEventIndicesByTimestamps
attilakreiner 5740ead
test stdout
attilakreiner 0acc7f4
fix Engine readEvent
attilakreiner baf1c19
WIP http server log
attilakreiner 39e737d
rm level
attilakreiner da6cb7b
fix onDecodeResponseErrorCode
attilakreiner 05db0f4
fix tcp remoteAddress
attilakreiner cf554b6
fix tcp traceId doNetConnect
attilakreiner 776c2ec
fix tcp traceId 0 onNetConnect
attilakreiner 10cfdfc
fix mv MessageReader
attilakreiner f302779
fix Engine supplyEventReader
attilakreiner 035589e
fix mv lookupTypeId
attilakreiner ceb2efc
fix mv remoteaddressrejected
attilakreiner d2665ac
fix mv supplyEventWriter
attilakreiner 7415d67
fix mv tcp.idl
attilakreiner 68e1b0c
fix mv http.idl
attilakreiner e888bcf
fix mv kafka.idl
attilakreiner 730ecaf
fix mv mqtt.idl
attilakreiner 4c4b0e6
fix mv schema_registry.idl
attilakreiner f359b76
fix mv tls.idl
attilakreiner 154f0ef
fix Clock
attilakreiner 31f69a8
fix EventReader inner class
attilakreiner 853f794
fix timestamp
attilakreiner 4f9009d
fix kafka
attilakreiner 68d6ffd
fix tcp
attilakreiner 856d40d
fix engine
attilakreiner e2a4edf
fix stdout exp
attilakreiner 6559700
fix tcp
attilakreiner 7261233
fix supplyTypeId
attilakreiner fa8db9b
fix tls
attilakreiner df71e7f
fix rm http response
attilakreiner d766096
fix http auth failure
attilakreiner de6cdaf
fix kafka auth failure
attilakreiner c57b3d2
fix mqtt auth failure
attilakreiner d681727
fix http log format
attilakreiner cbb6316
fix kafka log format
attilakreiner 11790f1
fix mqtt log format
attilakreiner c802e2c
fix tcp log format
attilakreiner 41a8d3b
fix tls log format
attilakreiner cc4987c
fix schreg log format
attilakreiner 71a6818
fix revert schreg
attilakreiner 02f3b7b
fix identity
attilakreiner 0532c2c
fix rm traceId
attilakreiner 4736c14
fix rm event type name
attilakreiner af555ce
fix http
attilakreiner 787424b
fix kafka
attilakreiner 74ee442
fix mqtt
attilakreiner 43c7b7c
fix date time format
attilakreiner 64ccd2c
fix const
attilakreiner 37dc1fb
fix supplyQName
attilakreiner 96f0866
fix Stdout*Handler
attilakreiner 12afe60
fix context
attilakreiner 94c2e69
fix http add fields
attilakreiner 858be23
fix http event names
attilakreiner 9f2d72a
fix add http authority
attilakreiner e807d04
fix
attilakreiner bd9c1a4
impl first k3po test in stdexp
attilakreiner 434cbee
fix stdexp formats
attilakreiner a0b1ddb
fix engine test
attilakreiner bcd2944
fix kafka
attilakreiner 9c54422
fix tls
attilakreiner 115405d
fix bindingId in *EventContext
attilakreiner e1d6a98
fix idl
attilakreiner 4f3ecc0
WIP jwt authFail
attilakreiner e01ae34
WIP jwt traceId, bindingId
attilakreiner 15937c6
WIP rm mqtt
attilakreiner 259e5fb
WIP fix Http11EventsIT
attilakreiner 3ca772b
WIP fix rm http authFail
attilakreiner bb83580
fix kafka authFail
attilakreiner 864a587
add http2 test
attilakreiner 39ea9a7
add kafka test
attilakreiner 18d823f
add tls test
attilakreiner 814f74e
add tcp test
attilakreiner 3922e15
add jwt test
attilakreiner 15711a1
add sch-reg test
attilakreiner 1cc1e1b
fix
attilakreiner 9c4f1f3
fix tcp 1
attilakreiner 7f9d7a6
fix tcp 2
attilakreiner e30ec02
fix tcp 3
attilakreiner 0a0d97d
rm sch-reg test
attilakreiner 9748627
ref jwt test
attilakreiner b149557
fix
attilakreiner 3076f6f
revert model-json chg
attilakreiner File filter
Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
WIP StdoutExporter
- Loading branch information
commit a8d6b19a3fe86088e53d5ee47eae1efd0b321e33
There are no files selected for viewing
This file contains hidden or 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 hidden or 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 hidden or 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,12 @@ | ||
| Copyright ${copyrightYears} Aklivity Inc | ||
|
|
||
| Licensed under the Aklivity Community License (the "License"); you may not use | ||
| this file except in compliance with the License. You may obtain a copy of the | ||
| License at | ||
|
|
||
| https://www.aklivity.io/aklivity-community-license/ | ||
|
|
||
| Unless required by applicable law or agreed to in writing, software | ||
| distributed under the License is distributed on an "AS IS" BASIS, WITHOUT | ||
| WARRANTIES OF ANY KIND, either express or implied. See the License for the | ||
| specific language governing permissions and limitations under the License. |
This file contains hidden or 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,114 @@ | ||
| Aklivity Community License Agreement | ||
| Version 1.0 | ||
|
|
||
| This Aklivity Community License Agreement Version 1.0 (the “Agreement”) sets | ||
| forth the terms on which Aklivity, Inc. (“Aklivity”) makes available certain | ||
| software made available by Aklivity under this Agreement (the “Software”). BY | ||
| INSTALLING, DOWNLOADING, ACCESSING, USING OR DISTRIBUTING ANY OF THE SOFTWARE, | ||
| YOU AGREE TO THE TERMS AND CONDITIONS OF THIS AGREEMENT. IF YOU DO NOT AGREE TO | ||
| SUCH TERMS AND CONDITIONS, YOU MUST NOT USE THE SOFTWARE. IF YOU ARE RECEIVING | ||
| THE SOFTWARE ON BEHALF OF A LEGAL ENTITY, YOU REPRESENT AND WARRANT THAT YOU | ||
| HAVE THE ACTUAL AUTHORITY TO AGREE TO THE TERMS AND CONDITIONS OF THIS | ||
| AGREEMENT ON BEHALF OF SUCH ENTITY. “Licensee” means you, an individual, or | ||
| the entity on whose behalf you are receiving the Software. | ||
|
|
||
| 1. LICENSE GRANT AND CONDITIONS. | ||
|
|
||
| 1.1 License. Subject to the terms and conditions of this Agreement, | ||
| Aklivity hereby grants to Licensee a non-exclusive, royalty-free, | ||
| worldwide, non-transferable, non-sublicenseable license during the term | ||
| of this Agreement to: (a) use the Software; (b) prepare modifications and | ||
| derivative works of the Software; (c) distribute the Software (including | ||
| without limitation in source code or object code form); and (d) reproduce | ||
| copies of the Software (the “License”). Licensee is not granted the | ||
| right to, and Licensee shall not, exercise the License for an Excluded | ||
| Purpose. For purposes of this Agreement, “Excluded Purpose” means making | ||
| available any software-as-a-service, platform-as-a-service, | ||
| infrastructure-as-a-service or other similar online service that competes | ||
| with Aklivity products or services that provide the Software. | ||
|
|
||
| 1.2 Conditions. In consideration of the License, Licensee’s distribution | ||
| of the Software is subject to the following conditions: | ||
|
|
||
| (a) Licensee must cause any Software modified by Licensee to carry | ||
| prominent notices stating that Licensee modified the Software. | ||
|
|
||
| (b) On each Software copy, Licensee shall reproduce and not remove or | ||
| alter all Aklivity or third party copyright or other proprietary | ||
| notices contained in the Software, and Licensee must provide the | ||
| notice below with each copy. | ||
|
|
||
| “This software is made available by Aklivity, Inc., under the | ||
| terms of the Aklivity Community License Agreement, Version 1.0 | ||
| located at http://www.Aklivity.io/Aklivity-community-license. BY | ||
| INSTALLING, DOWNLOADING, ACCESSING, USING OR DISTRIBUTING ANY OF | ||
| THE SOFTWARE, YOU AGREE TO THE TERMS OF SUCH LICENSE AGREEMENT.” | ||
|
|
||
| 1.3 Licensee Modifications. Licensee may add its own copyright notices | ||
| to modifications made by Licensee and may provide additional or different | ||
| license terms and conditions for use, reproduction, or distribution of | ||
| Licensee’s modifications. While redistributing the Software or | ||
| modifications thereof, Licensee may choose to offer, for a fee or free of | ||
| charge, support, warranty, indemnity, or other obligations. Licensee, and | ||
| not Aklivity, will be responsible for any such obligations. | ||
|
|
||
| 1.4 No Sublicensing. The License does not include the right to | ||
| sublicense the Software, however, each recipient to which Licensee | ||
| provides the Software may exercise the Licenses so long as such recipient | ||
| agrees to the terms and conditions of this Agreement. | ||
|
|
||
| 2. TERM AND TERMINATION. This Agreement will continue unless and until | ||
| earlier terminated as set forth herein. If Licensee breaches any of its | ||
| conditions or obligations under this Agreement, this Agreement will | ||
| terminate automatically and the License will terminate automatically and | ||
| permanently. | ||
|
|
||
| 3. INTELLECTUAL PROPERTY. As between the parties, Aklivity will retain all | ||
| right, title, and interest in the Software, and all intellectual property | ||
| rights therein. Aklivity hereby reserves all rights not expressly granted | ||
| to Licensee in this Agreement. Aklivity hereby reserves all rights in its | ||
| trademarks and service marks, and no licenses therein are granted in this | ||
| Agreement. | ||
|
|
||
| 4. DISCLAIMER. Aklivity HEREBY DISCLAIMS ANY AND ALL WARRANTIES AND | ||
| CONDITIONS, EXPRESS, IMPLIED, STATUTORY, OR OTHERWISE, AND SPECIFICALLY | ||
| DISCLAIMS ANY WARRANTY OF MERCHANTABILITY OR FITNESS FOR A PARTICULAR | ||
| PURPOSE, WITH RESPECT TO THE SOFTWARE. | ||
|
|
||
| 5. LIMITATION OF LIABILITY. Aklivity WILL NOT BE LIABLE FOR ANY DAMAGES OF | ||
| ANY KIND, INCLUDING BUT NOT LIMITED TO, LOST PROFITS OR ANY CONSEQUENTIAL, | ||
| SPECIAL, INCIDENTAL, INDIRECT, OR DIRECT DAMAGES, HOWEVER CAUSED AND ON ANY | ||
| THEORY OF LIABILITY, ARISING OUT OF THIS AGREEMENT. THE FOREGOING SHALL | ||
| APPLY TO THE EXTENT PERMITTED BY APPLICABLE LAW. | ||
|
|
||
| 6.GENERAL. | ||
|
|
||
| 6.1 Governing Law. This Agreement will be governed by and interpreted in | ||
| accordance with the laws of the state of California, without reference to | ||
| its conflict of laws principles. If Licensee is located within the | ||
| United States, all disputes arising out of this Agreement are subject to | ||
| the exclusive jurisdiction of courts located in Santa Clara County, | ||
| California. USA. If Licensee is located outside of the United States, | ||
| any dispute, controversy or claim arising out of or relating to this | ||
| Agreement will be referred to and finally determined by arbitration in | ||
| accordance with the JAMS International Arbitration Rules. The tribunal | ||
| will consist of one arbitrator. The place of arbitration will be Palo | ||
| Alto, California. The language to be used in the arbitral proceedings | ||
| will be English. Judgment upon the award rendered by the arbitrator may | ||
| be entered in any court having jurisdiction thereof. | ||
|
|
||
| 6.2 Assignment. Licensee is not authorized to assign its rights under | ||
| this Agreement to any third party. Aklivity may freely assign its rights | ||
| under this Agreement to any third party. | ||
|
|
||
| 6.3 Other. This Agreement is the entire agreement between the parties | ||
| regarding the subject matter hereof. No amendment or modification of | ||
| this Agreement will be valid or binding upon the parties unless made in | ||
| writing and signed by the duly authorized representatives of both | ||
| parties. In the event that any provision, including without limitation | ||
| any condition, of this Agreement is held to be unenforceable, this | ||
| Agreement and all licenses and rights granted hereunder will immediately | ||
| terminate. Waiver by Aklivity of a breach of any provision of this | ||
| Agreement or the failure by Aklivity to exercise any right hereunder | ||
| will not be construed as a waiver of any subsequent breach of that right | ||
| or as a waiver of any other right. |
This file contains hidden or 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,18 @@ | ||
| Licensed under the Aklivity Community License (the "License"); you may not use | ||
| this file except in compliance with the License. You may obtain a copy of the | ||
| License at | ||
|
|
||
| https://www.aklivity.io/aklivity-community-license/ | ||
|
|
||
| Unless required by applicable law or agreed to in writing, software | ||
| distributed under the License is distributed on an "AS IS" BASIS, WITHOUT | ||
| WARRANTIES OF ANY KIND, either express or implied. See the License for the | ||
| specific language governing permissions and limitations under the License. | ||
|
|
||
| This project includes: | ||
| agrona under The Apache License, Version 2.0 | ||
| ICU4J under Unicode/ICU License | ||
| Jakarta JSON Processing API under Eclipse Public License 2.0 or GNU General Public License, version 2 with the GNU Classpath Exception | ||
| org.leadpony.justify under The Apache Software License, Version 2.0 | ||
| zilla::specs::engine.spec under The Apache Software License, Version 2.0 | ||
|
|
This file contains hidden or 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,13 @@ | ||
| Licensed under the Aklivity Community License (the "License"); you may not use | ||
| this file except in compliance with the License. You may obtain a copy of the | ||
| License at | ||
|
|
||
| https://www.aklivity.io/aklivity-community-license/ | ||
|
|
||
| Unless required by applicable law or agreed to in writing, software | ||
| distributed under the License is distributed on an "AS IS" BASIS, WITHOUT | ||
| WARRANTIES OF ANY KIND, either express or implied. See the License for the | ||
| specific language governing permissions and limitations under the License. | ||
|
|
||
| This project includes: | ||
| #GENERATED_NOTICES# |
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Uh oh!
There was an error while loading. Please reload this page.