Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

common

package

v1.11.2 Latest Latest Go to latest Published: Sep 16, 2026 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/coroot/coroot-cluster-agent

Links

Open Source Insights

Documentation ¶

Index ¶

func AuthHeaders(apiKey string) map[string]string
func Counter(desc *prometheus.Desc, value float64, labels ...string) prometheus.Metric
func DatabaseTLSConfig(creds TLSCredentials, insecureSkipVerify bool) (*tls.Config, error)
func Desc(name, help string, labels ...string) *prometheus.Desc
func Gauge(desc *prometheus.Desc, value float64, labels ...string) prometheus.Metric
func NewLoggerProvider(serviceName string, resourceAttrs ...attribute.KeyValue) (*sdk.LoggerProvider, error)
func SetAuthHeaders(r *http.Request, apiKey string)
func ShutdownLogs(ctx context.Context) error
func SplitHostPort(addr string) (host string, port int, err error)
func TlsConfig() *tls.Config
func TopN[T any](s []T, n int, less func(a, b T) bool) []T
func TopNMap[K comparable, V any, S cmp.Ordered](m map[K]V, n int, val func(V) S) map[K]V
func TopNMapByValue[K comparable, V cmp.Ordered](m map[K]V, n int) map[K]V
type Endpoint
type LogEmitter
- func NewLogEmitter(serviceName string) (*LogEmitter, error)
- func (e *LogEmitter) Callback() logparser.OnMsgCallbackF
- func (e *LogEmitter) Stop()
type TLSCredentials

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AuthHeaders ¶

func AuthHeaders(apiKey string) map[string]string

func Counter ¶

func Counter(desc *prometheus.Desc, value float64, labels ...string) prometheus.Metric

func DatabaseTLSConfig ¶ added in v1.9.0

func DatabaseTLSConfig(creds TLSCredentials, insecureSkipVerify bool) (*tls.Config, error)

func Desc ¶

func Desc(name, help string, labels ...string) *prometheus.Desc

func Gauge ¶

func Gauge(desc *prometheus.Desc, value float64, labels ...string) prometheus.Metric

func NewLoggerProvider ¶ added in v1.11.1

func NewLoggerProvider(serviceName string, resourceAttrs ...attribute.KeyValue) (*sdk.LoggerProvider, error)

func SetAuthHeaders ¶

func SetAuthHeaders(r *http.Request, apiKey string)

func ShutdownLogs ¶ added in v1.11.1

func ShutdownLogs(ctx context.Context) error

func SplitHostPort ¶ added in v1.3.0

func SplitHostPort(addr string) (host string, port int, err error)

func TlsConfig ¶ added in v1.6.4

func TlsConfig() *tls.Config

func TopN ¶ added in v1.9.0

func TopN[T any](s []T, n int, less func(a, b T) bool) []T

func TopNMap ¶ added in v1.9.0

func TopNMap[K comparable, V any, S cmp.Ordered](m map[K]V, n int, val func(V) S) map[K]V

func TopNMapByValue ¶ added in v1.9.0

func TopNMapByValue[K comparable, V cmp.Ordered](m map[K]V, n int) map[K]V

Types ¶

type Endpoint ¶ added in v1.11.2

type Endpoint struct {
	Host string
	Port string
}

type LogEmitter ¶ added in v1.11.2

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

func NewLogEmitter ¶ added in v1.11.2

func NewLogEmitter(serviceName string) (*LogEmitter, error)

func (*LogEmitter) Callback ¶ added in v1.11.2

func (e *LogEmitter) Callback() logparser.OnMsgCallbackF

func (*LogEmitter) Stop ¶ added in v1.11.2

func (e *LogEmitter) Stop()

type TLSCredentials ¶ added in v1.9.0

type TLSCredentials struct {
	CA, Cert, Key string
}

Source Files ¶

View all Source files