schemaClient

package
v0.0.66 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 6, 2025 License: Apache-2.0 Imports: 5 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	PATHSEP = "/"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type SchemaClientBound 

type SchemaClientBound interface {
	// GetSchema retrieves the schema for the given path
	GetSchemaSdcpbPath(ctx context.Context, path *sdcpb.Path) (*sdcpb.GetSchemaResponse, error)
	// GetSchemaElements retrieves the Schema Elements for all levels of the given path
	GetSchemaElements(ctx context.Context, path *sdcpb.Path, done chan struct{}) (chan *sdcpb.GetSchemaResponse, 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) Retrieve added in v0.0.54 

func (scb *SchemaClientBoundImpl) Retrieve(ctx context.Context, path *sdcpb.Path) (*sdcpb.GetSchemaResponse, error)

type SchemaIndexEntry added in v0.0.64 

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

func NewSchemaIndexEntry added in v0.0.54 

func NewSchemaIndexEntry(schemaRsp *sdcpb.GetSchemaResponse, err error) *SchemaIndexEntry

func (*SchemaIndexEntry) Get added in v0.0.64 

func (s *SchemaIndexEntry) Get() (*sdcpb.GetSchemaResponse, error)

func (*SchemaIndexEntry) GetError added in v0.0.64 

func (s *SchemaIndexEntry) GetError() error

func (*SchemaIndexEntry) GetReady added in v0.0.64 

func (s *SchemaIndexEntry) GetReady() bool

func (*SchemaIndexEntry) GetSchemaResponse added in v0.0.64 

func (s *SchemaIndexEntry) GetSchemaResponse() *sdcpb.GetSchemaResponse

func (*SchemaIndexEntry) Lock added in v0.0.64 

func (s *SchemaIndexEntry) Lock()

func (*SchemaIndexEntry) SetSchemaResponseAndError added in v0.0.64 

func (s *SchemaIndexEntry) SetSchemaResponseAndError(r *sdcpb.GetSchemaResponse, err error)

func (*SchemaIndexEntry) Unlock added in v0.0.64 

func (s *SchemaIndexEntry) Unlock()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.