Documentation ¶
Index ¶
- Variables
- type DB
- type NodeStore
- type Options
- type Store
- func (s *Store) AppendEvent(ctx context.Context, env *messagev1.Envelope) (*types.Event, error)
- func (s *Store) Events(ctx context.Context) ([]*types.Event, error)
- func (s *Store) FindMissingLinks(ctx context.Context) ([]multihash.Multihash, error)
- func (s *Store) GetEvents(ctx context.Context, cids ...multihash.Multihash) ([]*types.Event, error)
- func (s *Store) Heads(ctx context.Context) ([]multihash.Multihash, error)
- func (s *Store) InsertEvent(ctx context.Context, ev *types.Event) (bool, error)
- func (s *Store) InsertHead(ctx context.Context, ev *types.Event) (bool, error)
- func (s *Store) InsertNewEvents(ctx context.Context, evs []*types.Event) error
- func (s *Store) Query(ctx context.Context, req *messagev1.QueryRequest) (*messagev1.QueryResponse, error)
- func (s *Store) RemoveHead(ctx context.Context, cid multihash.Multihash) (bool, error)
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type NodeStore ¶
type NodeStore struct {
// contains filtered or unexported fields
}
func (*NodeStore) DeleteTopic ¶
type Options ¶
type Options struct {
DSN string `long:"dsn" env:"POSTGRES_DSN" description:"Postgres connection string" default:""`
}
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
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) (*messagev1.QueryResponse, error)
Click to show internal directories.
Click to hide internal directories.