datastore

package

v0.0.37 Latest Latest Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/sdcio/data-server

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type Datastore
- func New(ctx context.Context, c *config.DatastoreConfig, scc schema.Client, ...) *Datastore

Constants ¶

View Source

const (
	// to be used for candidates created without an owner
	DefaultOwner = "__sdcio"
)

Variables ¶

View Source

var ErrIntentNotFound = errors.New("intent not found")

Functions ¶

This section is empty.

Types ¶

type Datastore ¶

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

func New ¶

func New(ctx context.Context, c *config.DatastoreConfig, scc schema.Client, cc cache.Client, opts ...grpc.DialOption) *Datastore

New creates a new datastore, its schema server client and initializes the SBI target func New(c *config.DatastoreConfig, schemaServer *config.RemoteSchemaServer) *Datastore {

func (*Datastore) Candidates ¶

func (d *Datastore) Candidates(ctx context.Context) ([]*sdcpb.DataStore, error)

func (*Datastore) Commit ¶

func (d *Datastore) Commit(ctx context.Context, req *sdcpb.CommitRequest) error

func (*Datastore) Config ¶

func (d *Datastore) Config() *config.DatastoreConfig

func (*Datastore) ConnectionState ¶

func (d *Datastore) ConnectionState() string

func (*Datastore) CreateCandidate ¶

func (d *Datastore) CreateCandidate(ctx context.Context, ds *sdcpb.DataStore) error

func (*Datastore) DeleteCache ¶

func (d *Datastore) DeleteCache(ctx context.Context) error

func (*Datastore) DeleteCandidate ¶

func (d *Datastore) DeleteCandidate(ctx context.Context, name string) error

func (*Datastore) DeviationMgr ¶

func (d *Datastore) DeviationMgr(ctx context.Context)

func (*Datastore) Diff ¶

func (d *Datastore) Diff(ctx context.Context, req *sdcpb.DiffRequest) (*sdcpb.DiffResponse, error)

func (*Datastore) Discard ¶

func (d *Datastore) Discard(ctx context.Context, req *sdcpb.DiscardRequest) error

func (*Datastore) Get ¶

func (d *Datastore) Get(ctx context.Context, req *sdcpb.GetDataRequest, nCh chan *sdcpb.GetDataResponse) error

func (*Datastore) GetIntent ¶

func (d *Datastore) GetIntent(ctx context.Context, req *sdcpb.GetIntentRequest) (*sdcpb.GetIntentResponse, error)

func (*Datastore) ListIntent ¶

func (d *Datastore) ListIntent(ctx context.Context, req *sdcpb.ListIntentRequest) (*sdcpb.ListIntentResponse, error)

func (*Datastore) Name ¶

func (d *Datastore) Name() string

func (*Datastore) Rebase ¶

func (d *Datastore) Rebase(ctx context.Context, req *sdcpb.RebaseRequest) error

func (*Datastore) Schema ¶

func (d *Datastore) Schema() *config.SchemaConfig

func (*Datastore) Set ¶

func (d *Datastore) Set(ctx context.Context, req *sdcpb.SetDataRequest) (*sdcpb.SetDataResponse, error)

func (*Datastore) SetIntent ¶

func (d *Datastore) SetIntent(ctx context.Context, req *sdcpb.SetIntentRequest) (*sdcpb.SetIntentResponse, error)

func (*Datastore) SetIntentDelete ¶

func (d *Datastore) SetIntentDelete(ctx context.Context, req *sdcpb.SetIntentRequest, candidateName string) error

func (*Datastore) SetIntentUpdate ¶

func (d *Datastore) SetIntentUpdate(ctx context.Context, req *sdcpb.SetIntentRequest, candidateName string) error

func (*Datastore) Stop ¶

func (d *Datastore) Stop() error

func (*Datastore) StopDeviationsWatch ¶

func (d *Datastore) StopDeviationsWatch(peer string)

func (d *Datastore) Subscribe(req *sdcpb.SubscribeRequest, stream sdcpb.DataServer_SubscribeServer) error

func (*Datastore) Sync ¶

func (d *Datastore) Sync(ctx context.Context)

func (*Datastore) WatchDeviations ¶

func (d *Datastore) WatchDeviations(req *sdcpb.WatchDeviationRequest, stream sdcpb.DataServer_WatchDeviationsServer) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
clients
cache
schema
ctree Package ctree implements a Tree container whose methods are all thread-safe allowing concurrent access for multiple goroutines.	Package ctree implements a Tree container whose methods are all thread-safe allowing concurrent access for multiple goroutines.
jbuilderv2
jsonBuilder
target
netconf
netconf/conversion
netconf/driver/scrapligo
netconf/types

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL