server

package
v0.0.62 Latest Latest
Warning

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

 Go to latest Published: Aug 11, 2025 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DatastoreMap added in v0.0.56 

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

func NewDatastoreMap added in v0.0.56 

func NewDatastoreMap() *DatastoreMap

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()

type Server 

type Server struct {
	sdcpb.UnimplementedDataServerServer
	sdcpb.UnimplementedSchemaServerServer
	// contains filtered or unexported fields
}

func New 

func New(ctx context.Context, c *config.Config) (*Server, error)

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()

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

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.