Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + const ConfigSectionKey + func NewCatalogClient(ctx context.Context, authOpt ...grpc.DialOption) (catalog.Client, error) + type Config struct + DefaultServiceConfig string + Endpoint string + Insecure bool + MaxCacheAge config.Duration + Type DiscoveryType + UseAdminAuth bool + func GetConfig() *Config + func (cfg Config) GetPFlagSet(prefix string) *pflag.FlagSet + type DiscoveryType = string + const DataCatalogType + const NoOpDiscoveryType + type NOOPCatalog struct + 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 + func (n NOOPCatalog) Update(_ context.Context, _ catalog.Key, _ io.OutputReader, _ catalog.Metadata) (catalog.Status, error)
Go to main page