catalog

Documentation

Index

• Constants
• func NewCatalogClient(ctx context.Context) (catalog.Client, error)
• type Config
  • func GetConfig() *Config
  • func (cfg Config) GetPFlagSet(prefix string) *pflag.FlagSet
• type DiscoveryType
• type NOOPCatalog
  • func (n NOOPCatalog) Get(_ context.Context, _ catalog.Key) (catalog.Entry, error)
  • func (n NOOPCatalog) GetOrExtendReservation(_ context.Context, _ catalog.Key, _ string, _ time.Duration) (*datacatalog.Reservation, error)
  • func (n NOOPCatalog) Put(_ context.Context, _ catalog.Key, _ io.OutputReader, _ catalog.Metadata) (catalog.Status, error)
  • func (n NOOPCatalog) ReleaseReservation(_ context.Context, _ catalog.Key, _ string) error

Constants

const ConfigSectionKey = "catalog-cache"

Functions

func NewCatalogClient

func NewCatalogClient(ctx context.Context) (catalog.Client, error)

Types

type Config

type Config struct {
	Type        DiscoveryType   `json:"type" pflag:"\"noop\", Catalog Implementation to use"`
	Endpoint    string          `json:"endpoint" pflag:"\"\", Endpoint for catalog service"`
	Insecure    bool            `json:"insecure" pflag:"false, Use insecure grpc connection"`
	MaxCacheAge config.Duration `json:"max-cache-age" pflag:", Cache entries past this age will incur cache miss. 0 means cache never expires"`
}

func GetConfig

func GetConfig() *Config

Gets loaded config for Discovery

func (Config) GetPFlagSet

func (cfg Config) GetPFlagSet(prefix string) *pflag.FlagSet

GetPFlagSet will return strongly types pflags for all fields in Config and its nested types. The format of the flags is json-name.json-sub-name... etc.

type DiscoveryType

type DiscoveryType = string

const (
	NoOpDiscoveryType DiscoveryType = "noop"
	DataCatalogType   DiscoveryType = "datacatalog"
)

type NOOPCatalog

type NOOPCatalog struct {
}

func (NOOPCatalog) Get

func (n NOOPCatalog) Get(_ context.Context, _ catalog.Key) (catalog.Entry, error)

func (NOOPCatalog) GetOrExtendReservation

func (n NOOPCatalog) GetOrExtendReservation(_ context.Context, _ catalog.Key, _ string, _ time.Duration) (*datacatalog.Reservation, error)

func (NOOPCatalog) Put

func (n NOOPCatalog) Put(_ context.Context, _ catalog.Key, _ io.OutputReader, _ catalog.Metadata) (catalog.Status, error)

func (NOOPCatalog) ReleaseReservation

func (n NOOPCatalog) ReleaseReservation(_ context.Context, _ catalog.Key, _ string) error