Versions in this module Expand all Collapse all v1 v1.0.1 Oct 17, 2020 Changes in this version + type Action struct + Collection string + Instance []byte + InstanceID string + Type ActionType + type ActionType int + const ActionCreate + const ActionDelete + const ActionSave + type Client struct + func NewClient(target string, opts ...grpc.DialOption) (*Client, error) + func (c *Client) Close() error + func (c *Client) Create(ctx context.Context, dbID thread.ID, collectionName string, ...) ([]string, error) + func (c *Client) CreateInstanceWithPayload(ctx context.Context, dbID thread.ID, collectionName string, payloads [][]byte, ...) ([]string, error) + func (c *Client) Delete(ctx context.Context, dbID thread.ID, collectionName string, ...) error + func (c *Client) DeleteCollection(ctx context.Context, dbID thread.ID, name string, opts ...db.ManagedOption) error + func (c *Client) DeleteDB(ctx context.Context, dbID thread.ID, opts ...db.ManagedOption) error + func (c *Client) Find(ctx context.Context, dbID thread.ID, collectionName string, query *db.Query, ...) (interface{}, error) + func (c *Client) FindByID(ctx context.Context, dbID thread.ID, collectionName, instanceID string, ...) error + func (c *Client) GetCollectionIndexes(ctx context.Context, dbID thread.ID, name string, opts ...db.ManagedOption) ([]db.Index, error) + func (c *Client) GetCollectionInfo(ctx context.Context, dbID thread.ID, name string, opts ...db.ManagedOption) (db.CollectionConfig, error) + func (c *Client) GetDBInfo(ctx context.Context, dbID thread.ID, opts ...db.ManagedOption) (db.Info, error) + func (c *Client) GetToken(ctx context.Context, identity thread.Identity) (tok thread.Token, err error) + func (c *Client) Has(ctx context.Context, dbID thread.ID, collectionName string, ...) (bool, error) + func (c *Client) ListCollections(ctx context.Context, dbID thread.ID, opts ...db.ManagedOption) ([]db.CollectionConfig, error) + func (c *Client) ListDBs(ctx context.Context, opts ...db.ManagedOption) (map[thread.ID]db.Info, error) + func (c *Client) Listen(ctx context.Context, dbID thread.ID, listenOptions []ListenOption, ...) (<-chan ListenEvent, error) + func (c *Client) NewCollection(ctx context.Context, dbID thread.ID, config db.CollectionConfig, ...) error + func (c *Client) NewDB(ctx context.Context, dbID thread.ID, opts ...db.NewManagedOption) error + func (c *Client) NewDBFromAddr(ctx context.Context, dbAddr ma.Multiaddr, dbKey thread.Key, ...) error + func (c *Client) ReadTransaction(ctx context.Context, dbID thread.ID, collectionName string, ...) (*ReadTransaction, error) + func (c *Client) Save(ctx context.Context, dbID thread.ID, collectionName string, ...) error + func (c *Client) UpdateCollection(ctx context.Context, dbID thread.ID, config db.CollectionConfig, ...) error + func (c *Client) Verify(ctx context.Context, dbID thread.ID, collectionName string, ...) error + func (c *Client) WriteTransaction(ctx context.Context, dbID thread.ID, collectionName string, ...) (*WriteTransaction, error) + type EndTransactionFunc = func() error + type Instances []interface + type ListenActionType int + const ListenAll + const ListenCreate + const ListenDelete + const ListenSave + type ListenEvent struct + Action Action + Err error + type ListenOption struct + Collection string + InstanceID string + Type ListenActionType + type ReadTransaction struct + func (t *ReadTransaction) Find(query *db.Query, dummy interface{}) (interface{}, error) + func (t *ReadTransaction) FindByID(instanceID string, instance interface{}) error + func (t *ReadTransaction) Has(instanceIDs ...string) (bool, error) + func (t *ReadTransaction) Start() (EndTransactionFunc, error) + type WriteTransaction struct + func (t *WriteTransaction) Create(items ...interface{}) ([]string, error) + func (t *WriteTransaction) Delete(instanceIDs ...string) error + func (t *WriteTransaction) Discard() error + func (t *WriteTransaction) Find(query *db.Query, dummy interface{}) (interface{}, error) + func (t *WriteTransaction) FindByID(instanceID string, instance interface{}) error + func (t *WriteTransaction) Has(instanceIDs ...string) (bool, error) + func (t *WriteTransaction) Save(items ...interface{}) error + func (t *WriteTransaction) Start() (EndTransactionFunc, error) + func (t *WriteTransaction) Verify(items ...interface{}) error
Go to main page