queryservice

type Config struct {
	Endpoints    []Endpoint    `yaml:"endpoints,omitempty"`
	QueryTimeout time.Duration `yaml:"queryTimeout,omitempty"`
}

type ConfigService interface {
	UnmarshalKey(key string, rawVal interface{}) error
}

type Endpoint struct {
	Address               string        `yaml:"address,omitempty"`
	ConnectionTimeout     time.Duration `yaml:"connectionTimeout,omitempty"`
	TLSEnabled            bool          `yaml:"tlsEnabled,omitempty"`
	TLSRootCertFile       string        `yaml:"tlsRootCertFile,omitempty"`
	TLSServerNameOverride string        `yaml:"tlsServerNameOverride,omitempty"`
}

type Provider interface {
	Get(network, channel string) (QueryService, error)
}

type QueryService interface {
	GetState(ns driver.Namespace, key driver.PKey) (*driver.VaultValue, error)
	GetStates(map[driver.Namespace][]driver.PKey) (map[driver.Namespace]map[driver.PKey]driver.VaultValue, error)
}

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

type RemoteQueryServiceProvider struct {
	ConfigProvider config.Provider
}