provider

Documentation

Overview

Package provider contains the cluster name provider

Index

• func Chain(logger *zap.Logger, providers map[string]source.Provider, ...) (source.Provider, error)
• func Config(hostname string) source.Provider
• func Once(provider source.Provider) source.Provider
• type ClusterNameProvider
  • func ChainCluster(logger *zap.Logger, providers map[string]ClusterNameProvider, ...) (ClusterNameProvider, error)

Functions

func Chain

func Chain(logger *zap.Logger, providers map[string]source.Provider, priorityList []string, timeout time.Duration) (source.Provider, error)

Chain providers into a single provider that returns the first available hostname.

func Config

func Config(hostname string) source.Provider

Config returns fixed hostname.

func Once

func Once(provider source.Provider) source.Provider

Once wraps a provider to call it only once.

Types

type ClusterNameProvider

type ClusterNameProvider interface {
	ClusterName(context.Context) (string, error)
}

func ChainCluster

func ChainCluster(logger *zap.Logger, providers map[string]ClusterNameProvider, priorityList []string) (ClusterNameProvider, error)

Chain providers into a single provider that returns the first available hostname.