server

func (*DatastoreMap) AddDatastore ¶ added in v0.0.56

func (d *DatastoreMap) AddDatastore(ds *datastore.Datastore) error

func (*DatastoreMap) DeleteDatastore ¶ added in v0.0.56

func (d *DatastoreMap) DeleteDatastore(ctx context.Context, name string) error

func (*DatastoreMap) GetDataStore ¶ added in v0.0.56

func (d *DatastoreMap) GetDataStore(name string) (*datastore.Datastore, error)

func (*DatastoreMap) GetDatastoreAll ¶ added in v0.0.56

func (d *DatastoreMap) GetDatastoreAll() []*datastore.Datastore

func (*DatastoreMap) StopAll ¶ added in v0.0.56

func (d *DatastoreMap) StopAll()

func (*Server) BlameConfig ¶ added in v0.0.60

func (s *Server) BlameConfig(ctx context.Context, req *sdcpb.BlameConfigRequest) (*sdcpb.BlameConfigResponse, error)

func (*Server) CreateDataStore ¶

func (s *Server) CreateDataStore(ctx context.Context, req *sdcpb.CreateDataStoreRequest) (*sdcpb.CreateDataStoreResponse, error)

func (*Server) CreateSchema ¶

func (s *Server) CreateSchema(ctx context.Context, req *sdcpb.CreateSchemaRequest) (*sdcpb.CreateSchemaResponse, error)

func (*Server) DeleteDataStore ¶

func (s *Server) DeleteDataStore(ctx context.Context, req *sdcpb.DeleteDataStoreRequest) (*sdcpb.DeleteDataStoreResponse, error)

func (*Server) DeleteSchema ¶

func (s *Server) DeleteSchema(ctx context.Context, req *sdcpb.DeleteSchemaRequest) (*sdcpb.DeleteSchemaResponse, error)

func (*Server) ExpandPath ¶

func (s *Server) ExpandPath(ctx context.Context, req *sdcpb.ExpandPathRequest) (*sdcpb.ExpandPathResponse, error)

func (*Server) GetDataStore ¶

func (s *Server) GetDataStore(ctx context.Context, req *sdcpb.GetDataStoreRequest) (*sdcpb.GetDataStoreResponse, error)

func (*Server) GetIntent ¶

func (s *Server) GetIntent(ctx context.Context, req *sdcpb.GetIntentRequest) (*sdcpb.GetIntentResponse, error)

func (*Server) GetSchema ¶

func (s *Server) GetSchema(ctx context.Context, req *sdcpb.GetSchemaRequest) (*sdcpb.GetSchemaResponse, error)

func (*Server) GetSchemaDetails ¶

func (s *Server) GetSchemaDetails(ctx context.Context, req *sdcpb.GetSchemaDetailsRequest) (*sdcpb.GetSchemaDetailsResponse, error)

func (*Server) GetSchemaElements ¶

func (s *Server) GetSchemaElements(req *sdcpb.GetSchemaRequest, stream sdcpb.SchemaServer_GetSchemaElementsServer) error

func (*Server) ListDataStore ¶

func (s *Server) ListDataStore(ctx context.Context, req *sdcpb.ListDataStoreRequest) (*sdcpb.ListDataStoreResponse, error)

datastore

func (*Server) ListIntent ¶

func (s *Server) ListIntent(ctx context.Context, req *sdcpb.ListIntentRequest) (*sdcpb.ListIntentResponse, error)

func (*Server) ListSchema ¶

func (s *Server) ListSchema(ctx context.Context, req *sdcpb.ListSchemaRequest) (*sdcpb.ListSchemaResponse, error)

func (*Server) ReloadSchema ¶

func (s *Server) ReloadSchema(ctx context.Context, req *sdcpb.ReloadSchemaRequest) (*sdcpb.ReloadSchemaResponse, error)

func (*Server) Serve ¶

func (s *Server) Serve(ctx context.Context) error

func (*Server) ServeHTTP ¶

func (s *Server) ServeHTTP(ctx context.Context)

func (*Server) Stop ¶

func (s *Server) Stop()

func (*Server) ToPath ¶

func (s *Server) ToPath(ctx context.Context, req *sdcpb.ToPathRequest) (*sdcpb.ToPathResponse, error)

func (*Server) TransactionCancel ¶ added in v0.0.54

func (s *Server) TransactionCancel(ctx context.Context, req *sdcpb.TransactionCancelRequest) (*sdcpb.TransactionCancelResponse, error)

func (*Server) TransactionConfirm ¶ added in v0.0.54

func (s *Server) TransactionConfirm(ctx context.Context, req *sdcpb.TransactionConfirmRequest) (*sdcpb.TransactionConfirmResponse, error)

func (*Server) TransactionSet ¶ added in v0.0.54

func (s *Server) TransactionSet(ctx context.Context, req *sdcpb.TransactionSetRequest) (*sdcpb.TransactionSetResponse, error)

func (*Server) UploadSchema ¶

func (s *Server) UploadSchema(stream sdcpb.SchemaServer_UploadSchemaServer) error

BROKEN

func (*Server) WatchDeviations ¶

func (s *Server) WatchDeviations(req *sdcpb.WatchDeviationRequest, stream sdcpb.DataServer_WatchDeviationsServer) error