Skip to content

Commit

Permalink
Add cloudfoundry common client into x-pack/common (elastic#16527)
Browse files Browse the repository at this point in the history 
* Add cloudfoundry common client into x-pack/common.

* Run mage fmt.

* Add support for tlscommon.Config, removing the uaago depedency as it didn't expose overriding the TLSConfig. Add comment for location of documentation for event types.

* Use common.Cache with addition of not updated expiration on get, instead of the kubernetes ttl cache. Fix other suggestions.

* Fix cache_test and new test for not updated access time.

* Handle error sooner in getAuthTokenWithExpiresIn.

(cherry picked from commit f4c71b4)
  • Loading branch information
@blakerouse
blakerouse committed Feb 25, 2020
1 parent 646c927 commit 7cae675
Show file tree
Hide file tree
Showing 127 changed files with 30,481 additions and 26 deletions.
202 changes: 202 additions & 0 deletions NOTICE.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -79,6 +79,114 @@ License type (autodetected): Apache-2.0
Apache License 2.0


--------------------------------------------------------------------
Dependency: code.cloudfoundry.org/go-diodes
Revision: f77fb823c7ee0156ed4cdadaf4f79ac3fd84613f
License type (autodetected): Apache-2.0
./vendor/code.cloudfoundry.org/go-diodes/LICENSE:
--------------------------------------------------------------------
Apache License 2.0

-------NOTICE-----
Copyright (c) 2017-Present CloudFoundry.org Foundation, Inc. All Rights Reserved.

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.

This project may include a number of subcomponents with separate
copyright notices and license terms. Your use of these subcomponents
is subject to the terms and conditions of each subcomponent's license,
as noted in the LICENSE file.

--------------------------------------------------------------------
Dependency: code.cloudfoundry.org/go-loggregator
Version: v7.7.0
Revision: b8d176783c8a6280a34f0e19e0e8f57d722773a1
License type (autodetected): Apache-2.0
./vendor/code.cloudfoundry.org/go-loggregator/LICENSE:
--------------------------------------------------------------------
Apache License 2.0

-------NOTICE-----
go-loggregator

Copyright (c) 2017-Present CloudFoundry.org Foundation, Inc. All Rights Reserved.

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.


--------------------------------------------------------------------
Dependency: code.cloudfoundry.org/gofileutils
Revision: 4d0c80011a0f37da1711c184028bc40137cd45af
License type (autodetected): Apache-2.0
./vendor/code.cloudfoundry.org/gofileutils/LICENSE:
--------------------------------------------------------------------
Apache License 2.0

-------NOTICE-----
Copyright (c) 2015-Present CloudFoundry.org Foundation, Inc. All Rights Reserved.

This project contains software that is Copyright (c) 2014-2015 Pivotal Software, Inc.

This project is licensed to you under the Apache License, Version 2.0 (the "License").

You may not use this project except in compliance with the License.

This project may include a number of subcomponents with separate copyright notices
and license terms. Your use of these subcomponents is subject to the terms and
conditions of the subcomponent's license, as noted in the LICENSE file.

--------------------------------------------------------------------
Dependency: code.cloudfoundry.org/rfc5424
Revision: 236a6d29298aea12f69978f33393d12465abc429
License type (autodetected): BSD-2-Clause
./vendor/code.cloudfoundry.org/rfc5424/LICENSE:
--------------------------------------------------------------------
BSD 2-Clause License

Copyright (c) 2016, Ross Kinder
All rights reserved.

Redistribution and use in source and binary forms, with or without
modification, are permitted provided that the following conditions are met:

* Redistributions of source code must retain the above copyright notice, this
list of conditions and the following disclaimer.

* Redistributions in binary form must reproduce the above copyright notice,
this list of conditions and the following disclaimer in the documentation
and/or other materials provided with the distribution.

THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

--------------------------------------------------------------------
Dependency: contrib.go.opencensus.io/exporter/ocagent
Revision: 8110e6c0236bb231b19119275a6be6ec666d05c8
Expand Down Expand Up @@ -660,6 +768,60 @@ LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

--------------------------------------------------------------------
Dependency: github.com/cloudfoundry-community/go-cfclient
Version: master
Revision: 35bcce23fc5f8b9969723ac38c0de1f82c4d3471
License type (autodetected): MIT
./vendor/github.com/cloudfoundry-community/go-cfclient/LICENSE:
--------------------------------------------------------------------
The MIT License

Copyright (c) 2017 Long Nguyen

Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in
all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
THE SOFTWARE.

--------------------------------------------------------------------
Dependency: github.com/cloudfoundry/sonde-go
Revision: b33733203bb48d7c56de7cb639d77f78b0449d19
License type (autodetected): Apache-2.0
./vendor/github.com/cloudfoundry/sonde-go/LICENSE:
--------------------------------------------------------------------
Apache License 2.0

-------NOTICE-----
sonde-go

Copyright (c) 2015-Present CloudFoundry.org Foundation, Inc. All Rights Reserved.

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.

--------------------------------------------------------------------
Dependency: github.com/containerd/containerd
Revision: 36cf5b690dcc00ff0f34ff7799209050c3d0c59a
Expand Down Expand Up @@ -4788,6 +4950,46 @@ License type (autodetected): Apache-2.0
Apache License 2.0


--------------------------------------------------------------------
Dependency: github.com/mailru/easyjson
Revision: 8edcc4e51f39ddbd3505a3386aff3f435a7fd028
License type (autodetected): MIT
./vendor/github.com/mailru/easyjson/LICENSE:
--------------------------------------------------------------------
Copyright (c) 2016 Mail.Ru Group

Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

--------------------------------------------------------------------
Dependency: github.com/Masterminds/semver
Revision: 910aa146bd66780c2815d652b92a7fc5331e533c
License type (autodetected): MIT
./vendor/github.com/Masterminds/semver/LICENSE.txt:
--------------------------------------------------------------------
Copyright (C) 2014-2019, Matt Butcher and Matt Farina

Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in
all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
THE SOFTWARE.

--------------------------------------------------------------------
Dependency: github.com/mattn/go-colorable
Revision: 941b50ebc6efddf4c41c8e4537a5f68a4e686b24
Expand Down
37 changes: 24 additions & 13 deletions libbeat/common/cache.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -68,18 +68,26 @@ func (e *element) UpdateLastAccessTime(now time.Time, expiration time.Duration)
// the cache will cause a panic.
type Cache struct {
sync.RWMutex
timeout time.Duration // Length of time before cache elements expire.
elements map[Key]*element // Data stored by the cache.
clock clock // Function used to get the current time.
listener RemovalListener // Callback listen to notify of evictions.
janitorQuit chan struct{} // Closing this channel stop the janitor.
timeout time.Duration // Length of time before cache elements expire.
accessExpire bool // Expire objects based on access time instead of addition time.
elements map[Key]*element // Data stored by the cache.
clock clock // Function used to get the current time.
listener RemovalListener // Callback listen to notify of evictions.
janitorQuit chan struct{} // Closing this channel stop the janitor.
}

// NewCache creates and returns a new Cache. d is the length of time after last
// access that cache elements expire. initialSize is the initial allocation size
// used for the Cache's underlying map.
func NewCache(d time.Duration, initialSize int) *Cache {
return newCache(d, initialSize, nil, time.Now)
return newCache(d, true, initialSize, nil, time.Now)
}

// NewCacheWithExpireOnAdd creates and returns a new Cache that does not updated
// the expiration time when the object is accessed. The expiration is only set when
// a new object is added to the cache and is not updated until it expires and re-inserted.
func NewCacheWithExpireOnAdd(d time.Duration, initialSize int) *Cache {
return newCache(d, false, initialSize, nil, time.Now)
}

// NewCacheWithRemovalListener creates and returns a new Cache and register a
Expand All @@ -88,15 +96,16 @@ func NewCache(d time.Duration, initialSize int) *Cache {
// for the Cache's underlying map. l is the callback function that will be
// invoked when cache elements are removed from the map on CleanUp.
func NewCacheWithRemovalListener(d time.Duration, initialSize int, l RemovalListener) *Cache {
return newCache(d, initialSize, l, time.Now)
return newCache(d, true, initialSize, l, time.Now)
}

func newCache(d time.Duration, initialSize int, l RemovalListener, t clock) *Cache {
func newCache(d time.Duration, accessExpire bool, initialSize int, l RemovalListener, t clock) *Cache {
return &Cache{
timeout: d,
elements: make(map[Key]*element, initialSize),
listener: l,
clock: t,
timeout: d,
accessExpire: accessExpire,
elements: make(map[Key]*element, initialSize),
listener: l,
clock: t,
}
}

Expand Down Expand Up @@ -254,7 +263,9 @@ func (c *Cache) get(k Key) (Value, bool) {
elem, exists := c.elements[k]
now := c.clock()
if exists && !elem.IsExpired(now) {
elem.UpdateLastAccessTime(now, elem.timeout)
if c.accessExpire {
elem.UpdateLastAccessTime(now, elem.timeout)
}
return elem.value, true
}
return nil, false
Expand Down
Loading

0 comments on commit 7cae675

Please sign in to comment.