metastoreclient

Documentation

Index

• type Client
  • func New(config Config, r prometheus.Registerer) (c *Client, err error)
  • func (c *Client) Service() services.Service
• type Config
  • func (cfg *Config) RegisterFlags(f *flag.FlagSet)
  • func (cfg *Config) Validate() error

Types

type Client

type Client struct {
	metastorepb.MetastoreServiceClient
	// contains filtered or unexported fields
}

func New

func New(config Config, r prometheus.Registerer) (c *Client, err error)

func (*Client) Service

func (c *Client) Service() services.Service

type Config

type Config struct {
	MetastoreAddress string            `yaml:"address"`
	GRPCClientConfig grpcclient.Config `yaml:"grpc_client_config" doc:"description=Configures the gRPC client used to communicate with the metastore."`
}

func (*Config) RegisterFlags

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

func (*Config) Validate

func (cfg *Config) Validate() error