Documentation ¶
Index ¶
- Variables
- func NewDB(opts *Options) (*bolt.DB, error)
- type NodeStore
- type Options
- type Store
- func (s *Store) AppendEvent(ctx context.Context, env *messagev1.Envelope) (ev *types.Event, err error)
- func (s *Store) Events(ctx context.Context) (evs []*types.Event, err error)
- func (s *Store) FindMissingLinks(ctx context.Context) (links []multihash.Multihash, err error)
- func (s *Store) GetEvents(ctx context.Context, cids ...multihash.Multihash) (evs []*types.Event, err error)
- func (s *Store) Heads(ctx context.Context) (cids []multihash.Multihash, err error)
- func (s *Store) InsertEvent(ctx context.Context, ev *types.Event) (added bool, err error)
- func (s *Store) InsertHead(ctx context.Context, ev *types.Event) (added bool, err error)
- func (s *Store) InsertNewEvents(ctx context.Context, evs []*types.Event) error
- func (s *Store) Query(ctx context.Context, req *messagev1.QueryRequest) (resp *messagev1.QueryResponse, err error)
- func (s *Store) RemoveHead(ctx context.Context, cid multihash.Multihash) (have bool, err error)
Constants ¶
This section is empty.
Variables ¶
Functions ¶
Types ¶
type NodeStore ¶
type NodeStore struct {
// contains filtered or unexported fields
}
NodeStore using embedded BoltDB.
func NewNodeStore ¶
func (*NodeStore) DeleteTopic ¶
type Options ¶
type Options struct {
DataPath string `long:"data-path" env:"BOLT_DATA_PATH" description:"Path to the bolt DB file" default:""`
}
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store is a topic focused adaptor on top of Store
func (*Store) AppendEvent ¶
func (*Store) FindMissingLinks ¶
func (*Store) InsertEvent ¶
func (*Store) InsertHead ¶
func (*Store) InsertNewEvents ¶
func (*Store) Query ¶
func (s *Store) Query(ctx context.Context, req *messagev1.QueryRequest) (resp *messagev1.QueryResponse, err error)
Click to show internal directories.
Click to hide internal directories.