schemaClient

Documentation

Index

• type SchemaClientBound
  • func NewSchemaClientBound(s *sdcpb.Schema, sc schema.Client) *SchemaClientBound
  • func (scb *SchemaClientBound) GetSchema(ctx context.Context, path *sdcpb.Path) (*sdcpb.GetSchemaResponse, error)
  • func (scb *SchemaClientBound) GetSchemaElements(ctx context.Context, p *sdcpb.Path, done chan struct{}) (chan *sdcpb.GetSchemaResponse, error)

Types

type SchemaClientBound

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

func NewSchemaClientBound

func NewSchemaClientBound(s *sdcpb.Schema, sc schema.Client) *SchemaClientBound

func (*SchemaClientBound) GetSchema

func (scb *SchemaClientBound) GetSchema(ctx context.Context, path *sdcpb.Path) (*sdcpb.GetSchemaResponse, error)

GetSchema retrieves the schema for the given path

func (*SchemaClientBound) GetSchemaElements

func (scb *SchemaClientBound) GetSchemaElements(ctx context.Context, p *sdcpb.Path, done chan struct{}) (chan *sdcpb.GetSchemaResponse, error)