Documentation
¶
Index ¶
- Constants
- func NewSchemaIndexEntry(schemaRsp *sdcpb.GetSchemaResponse, err error) *schemaIndexEntry
- type SchemaClientBound
- type SchemaClientBoundImpl
- func (scb *SchemaClientBoundImpl) GetSchemaElements(ctx context.Context, p *sdcpb.Path, done chan struct{}) (chan *sdcpb.GetSchemaResponse, error)
- func (scb *SchemaClientBoundImpl) GetSchemaSdcpbPath(ctx context.Context, path *sdcpb.Path) (*sdcpb.GetSchemaResponse, error)
- func (scb *SchemaClientBoundImpl) GetSchemaSlicePath(ctx context.Context, path []string) (*sdcpb.GetSchemaResponse, error)
- func (scb *SchemaClientBoundImpl) Retrieve(ctx context.Context, path *sdcpb.Path) (*sdcpb.GetSchemaResponse, error)
- func (scb *SchemaClientBoundImpl) ToPath(ctx context.Context, path []string) (*sdcpb.Path, error)
Constants ¶
View Source
const (
PATHSEP = "/"
)
Variables ¶
This section is empty.
Functions ¶
func NewSchemaIndexEntry ¶ added in v0.0.54
func NewSchemaIndexEntry(schemaRsp *sdcpb.GetSchemaResponse, err error) *schemaIndexEntry
Types ¶
type SchemaClientBound ¶
type SchemaClientBound interface {
// GetSchema retrieves the schema for the given path
GetSchemaSdcpbPath(ctx context.Context, path *sdcpb.Path) (*sdcpb.GetSchemaResponse, error)
GetSchemaSlicePath(ctx context.Context, path []string) (*sdcpb.GetSchemaResponse, error)
// GetSchemaElements retrieves the Schema Elements for all levels of the given path
GetSchemaElements(ctx context.Context, p *sdcpb.Path, done chan struct{}) (chan *sdcpb.GetSchemaResponse, error)
ToPath(ctx context.Context, path []string) (*sdcpb.Path, error)
}
SchemaClientBound provides access to a certain vendor + model + version based schema
type SchemaClientBoundImpl ¶ added in v0.0.39
type SchemaClientBoundImpl struct {
// contains filtered or unexported fields
}
func NewSchemaClientBound ¶
func NewSchemaClientBound(s *config.SchemaConfig, sc schema.Client) *SchemaClientBoundImpl
func (*SchemaClientBoundImpl) GetSchemaElements ¶ added in v0.0.39
func (scb *SchemaClientBoundImpl) GetSchemaElements(ctx context.Context, p *sdcpb.Path, done chan struct{}) (chan *sdcpb.GetSchemaResponse, error)
func (*SchemaClientBoundImpl) GetSchemaSdcpbPath ¶ added in v0.0.54
func (scb *SchemaClientBoundImpl) GetSchemaSdcpbPath(ctx context.Context, path *sdcpb.Path) (*sdcpb.GetSchemaResponse, error)
GetSchema retrieves the schema for the given path
func (*SchemaClientBoundImpl) GetSchemaSlicePath ¶ added in v0.0.54
func (scb *SchemaClientBoundImpl) GetSchemaSlicePath(ctx context.Context, path []string) (*sdcpb.GetSchemaResponse, error)
GetSchema retrieves the given schema element from the schema-server. relies on TreeSchemaCacheClientImpl.retrieveSchema(...) to source the internal lookup index (cache) of schemas
func (*SchemaClientBoundImpl) Retrieve ¶ added in v0.0.54
func (scb *SchemaClientBoundImpl) Retrieve(ctx context.Context, path *sdcpb.Path) (*sdcpb.GetSchemaResponse, error)
Click to show internal directories.
Click to hide internal directories.