store

Documentation

Index

• Variables
• type Command
• type Document
• type Scan
• type Store
  • func New(c sarif.Client) *Store
  • func (s *Store) Batch(p []Command, result interface{}) error
  • func (s *Store) Get(key string, result interface{}) error
  • func (s *Store) Put(key string, doc interface{}) (*Document, error)
  • func (st *Store) PutTriple(collection string, t Triple) error
  • func (s *Store) Scan(key string, p Scan, result interface{}) error
  • func (st *Store) ScanTriple(collection string, t Triple, scan Scan, result interface{}) error
• type Triple

Variables

var (
	ErrNotFound = errors.New("Document not found.")
	ErrNoReply  = errors.New("no reply received.")
)

Types

type Command

type Command struct {
	Type  string      `json:"type"`
	Key   string      `json:"key"`
	Value interface{} `json:"value,omitempty"`
}

type Document

type Document struct {
	Collection string `json:"collection"`
	Key        string `json:"key"`
	Value      []byte `json:"value,omitempty"`
}

type Scan

type Scan struct {
	Prefix  string `json:"prefix,omitempty"`
	Start   string `json:"start,omitempty"`
	End     string `json:"end,omitempty"`
	Only    string `json:"only,omitempty"`
	Limit   int    `json:"limit,omitempty"`
	Reverse bool   `json:"reverse,omitempty"`

	Filter interface{} `json:"filter,omitempty"`
}

type Store

type Store struct {
	StoreName string
	// contains filtered or unexported fields
}

func New

func New(c sarif.Client) *Store

func (*Store) Batch

func (s *Store) Batch(p []Command, result interface{}) error

func (*Store) Get

func (s *Store) Get(key string, result interface{}) error

func (*Store) Put

func (s *Store) Put(key string, doc interface{}) (*Document, error)

func (*Store) PutTriple

func (st *Store) PutTriple(collection string, t Triple) error

func (*Store) Scan

func (s *Store) Scan(key string, p Scan, result interface{}) error

func (*Store) ScanTriple

func (st *Store) ScanTriple(collection string, t Triple, scan Scan, result interface{}) error

type Triple

type Triple interface {
	Triple() (s, p, o string)
}