Documentation
¶
Index ¶
- Variables
- func DiffDoubleStringPathSlice(s1, s2 [][]string) string
- func DiffStringSlice(s1, s2 []string, forceNoSideEffect bool) string
- func DiffUpdates(a, b []*types.Update) string
- func GetLeafListTvProto(tvs []*sdcpb.TypedValue) *sdcpb.TypedValue
- func GetSchemaClientBound(t *testing.T, mockCtrl *gomock.Controller) (*mockschemaclientbound.MockSchemaClientBound, error)
- func GetStringTvProto(s string) *sdcpb.TypedValue
- func GetTestFilename() string
- func GetUIntTvProto(i uint64) *sdcpb.TypedValue
- func InitSDCIOSchema() (dataschema.Client, *dConfig.SchemaConfig, error)
- func PathMapIndex(elems []string) string
- func UpdateSliceToStringSlice(s []*types.Update) []string
- type SchemaClient
- func (s *SchemaClient) CreateSchema(ctx context.Context, in *sdcpb.CreateSchemaRequest, opts ...grpc.CallOption) (*sdcpb.CreateSchemaResponse, error)
- func (s *SchemaClient) DeleteSchema(ctx context.Context, in *sdcpb.DeleteSchemaRequest, opts ...grpc.CallOption) (*sdcpb.DeleteSchemaResponse, error)
- func (s *SchemaClient) ExpandPath(ctx context.Context, in *sdcpb.ExpandPathRequest, opts ...grpc.CallOption) (*sdcpb.ExpandPathResponse, error)
- func (s *SchemaClient) GetSchema(ctx context.Context, in *sdcpb.GetSchemaRequest, opts ...grpc.CallOption) (*sdcpb.GetSchemaResponse, error)
- func (s *SchemaClient) GetSchemaDetails(ctx context.Context, in *sdcpb.GetSchemaDetailsRequest, ...) (*sdcpb.GetSchemaDetailsResponse, error)
- func (s *SchemaClient) GetSchemaElements(ctx context.Context, req *sdcpb.GetSchemaRequest, opts ...grpc.CallOption) (chan *sdcpb.SchemaElem, error)
- func (s *SchemaClient) ListSchema(ctx context.Context, in *sdcpb.ListSchemaRequest, opts ...grpc.CallOption) (*sdcpb.ListSchemaResponse, error)
- func (s *SchemaClient) ReloadSchema(ctx context.Context, in *sdcpb.ReloadSchemaRequest, opts ...grpc.CallOption) (*sdcpb.ReloadSchemaResponse, error)
- func (s *SchemaClient) ToPath(ctx context.Context, in *sdcpb.ToPathRequest, opts ...grpc.CallOption) (*sdcpb.ToPathResponse, error)
- func (s *SchemaClient) UploadSchema(ctx context.Context, opts ...grpc.CallOption) (sdcpb.SchemaServer_UploadSchemaClient, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var (
// location of the test schema from the projects root
SDCIO_SCHEMA_LOCATION = "tests/schema"
)
Functions ¶
func DiffStringSlice ¶
DiffStringSlice compares two string slices returning the
func DiffUpdates ¶ added in v0.0.56
diffCacheUpdates takes two []*cache.Update and compares the diff
func GetLeafListTvProto ¶ added in v0.0.40
func GetLeafListTvProto(tvs []*sdcpb.TypedValue) *sdcpb.TypedValue
func GetSchemaClientBound ¶ added in v0.0.44
func GetSchemaClientBound(t *testing.T, mockCtrl *gomock.Controller) (*mockschemaclientbound.MockSchemaClientBound, error)
GetSchemaClientBound creates a SchemaClientBound mock that responds to certain GetSchema requests
func GetStringTvProto ¶
func GetStringTvProto(s string) *sdcpb.TypedValue
GetStringTvProto takes a string and returns the sdcpb.TypedValue for it in proto encoding as []byte
func GetTestFilename ¶
func GetTestFilename() string
func GetUIntTvProto ¶
func GetUIntTvProto(i uint64) *sdcpb.TypedValue
GetStringTvProto takes a string and returns the sdcpb.TypedValue for it in proto encoding as []byte
func InitSDCIOSchema ¶
func InitSDCIOSchema() (dataschema.Client, *dConfig.SchemaConfig, error)
func PathMapIndex ¶
PathMapIndex calculates a common map index for string slice based paths
func UpdateSliceToStringSlice ¶ added in v0.0.56
UpdateSliceToStringSlice converts a []*Update to []string
Types ¶
type SchemaClient ¶
type SchemaClient struct {
schemaStore.Store
}
func (*SchemaClient) CreateSchema ¶
func (s *SchemaClient) CreateSchema(ctx context.Context, in *sdcpb.CreateSchemaRequest, opts ...grpc.CallOption) (*sdcpb.CreateSchemaResponse, error)
creates a schema
func (*SchemaClient) DeleteSchema ¶
func (s *SchemaClient) DeleteSchema(ctx context.Context, in *sdcpb.DeleteSchemaRequest, opts ...grpc.CallOption) (*sdcpb.DeleteSchemaResponse, error)
delete a schema
func (*SchemaClient) ExpandPath ¶
func (s *SchemaClient) ExpandPath(ctx context.Context, in *sdcpb.ExpandPathRequest, opts ...grpc.CallOption) (*sdcpb.ExpandPathResponse, error)
ExpandPath returns a list of sub paths given a single path
func (*SchemaClient) GetSchema ¶
func (s *SchemaClient) GetSchema(ctx context.Context, in *sdcpb.GetSchemaRequest, opts ...grpc.CallOption) (*sdcpb.GetSchemaResponse, error)
returns the schema of an item identified by a gNMI-like path
func (*SchemaClient) GetSchemaDetails ¶
func (s *SchemaClient) GetSchemaDetails(ctx context.Context, in *sdcpb.GetSchemaDetailsRequest, opts ...grpc.CallOption) (*sdcpb.GetSchemaDetailsResponse, error)
returns schema name, vendor, version, and files path(s)
func (*SchemaClient) GetSchemaElements ¶
func (s *SchemaClient) GetSchemaElements(ctx context.Context, req *sdcpb.GetSchemaRequest, opts ...grpc.CallOption) (chan *sdcpb.SchemaElem, error)
func (*SchemaClient) ListSchema ¶
func (s *SchemaClient) ListSchema(ctx context.Context, in *sdcpb.ListSchemaRequest, opts ...grpc.CallOption) (*sdcpb.ListSchemaResponse, error)
lists known schemas with name, vendor, version and status
func (*SchemaClient) ReloadSchema ¶
func (s *SchemaClient) ReloadSchema(ctx context.Context, in *sdcpb.ReloadSchemaRequest, opts ...grpc.CallOption) (*sdcpb.ReloadSchemaResponse, error)
trigger schema reload
func (*SchemaClient) ToPath ¶
func (s *SchemaClient) ToPath(ctx context.Context, in *sdcpb.ToPathRequest, opts ...grpc.CallOption) (*sdcpb.ToPathResponse, error)
ToPath converts a list of items into a schema.proto.Path
func (*SchemaClient) UploadSchema ¶
func (s *SchemaClient) UploadSchema(ctx context.Context, opts ...grpc.CallOption) (sdcpb.SchemaServer_UploadSchemaClient, error)
Source Files
Click to show internal directories.
Click to hide internal directories.