datastore

Documentation

Index

• Constants
• Variables
• type Datastore
  • func New(ctx context.Context, c *config.DatastoreConfig, scc schema.Client, ...) *Datastore
  • func (d *Datastore) Candidates(ctx context.Context) ([]*sdcpb.DataStore, error)
  • func (d *Datastore) Commit(ctx context.Context, req *sdcpb.CommitRequest) error
  • func (d *Datastore) Config() *config.DatastoreConfig
  • func (d *Datastore) ConnectionState() string
  • func (d *Datastore) CreateCandidate(ctx context.Context, ds *sdcpb.DataStore) error
  • func (d *Datastore) DeleteCache(ctx context.Context) error
  • func (d *Datastore) DeleteCandidate(ctx context.Context, name string) error
  • func (d *Datastore) DeviationMgr(ctx context.Context)
  • func (d *Datastore) Diff(ctx context.Context, req *sdcpb.DiffRequest) (*sdcpb.DiffResponse, error)
  • func (d *Datastore) Discard(ctx context.Context, req *sdcpb.DiscardRequest) error
  • func (d *Datastore) Get(ctx context.Context, req *sdcpb.GetDataRequest, ...) error
  • func (d *Datastore) GetIntent(ctx context.Context, req *sdcpb.GetIntentRequest) (*sdcpb.GetIntentResponse, error)
  • func (d *Datastore) ListIntent(ctx context.Context, req *sdcpb.ListIntentRequest) (*sdcpb.ListIntentResponse, error)
  • func (d *Datastore) Name() string
  • func (d *Datastore) Rebase(ctx context.Context, req *sdcpb.RebaseRequest) error
  • func (d *Datastore) Schema() *config.SchemaConfig
  • func (d *Datastore) Set(ctx context.Context, req *sdcpb.SetDataRequest) (*sdcpb.SetDataResponse, error)
  • func (d *Datastore) SetIntent(ctx context.Context, req *sdcpb.SetIntentRequest) (*sdcpb.SetIntentResponse, error)
  • func (d *Datastore) SetIntentDelete(ctx context.Context, req *sdcpb.SetIntentRequest, candidateName string) error
  • func (d *Datastore) SetIntentUpdate(ctx context.Context, req *sdcpb.SetIntentRequest, candidateName string) error
  • func (d *Datastore) Stop() error
  • func (d *Datastore) StopDeviationsWatch(peer string)
  • func (d *Datastore) Subscribe(req *sdcpb.SubscribeRequest, stream sdcpb.DataServer_SubscribeServer) error
  • func (d *Datastore) Sync(ctx context.Context)
  • func (d *Datastore) WatchDeviations(req *sdcpb.WatchDeviationRequest, ...) error

Constants

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

Variables

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

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 (*Datastore) Subscribe

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