postgresstore

Documentation

Index

• Variables
• type DB
  • func NewDB(opts *Options) (*DB, error)
• type NodeStore
  • func NewNodeStore(ctx context.Context, db *DB) (*NodeStore, error)
  • func (s *NodeStore) Close() error
  • func (s *NodeStore) DeleteTopic(topic string) error
  • func (s *NodeStore) NewTopic(topic string) (crdt.Store, error)
  • func (s *NodeStore) Topics() (topics []string, err error)
• type Options
• type Store
  • func New(ctx context.Context, db *DB, topic string) *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)

Variables

var (
	ErrTODO          = errors.New("TODO")
	ErrTopicMismatch = errors.New("topic mismatch")
	ErrMissingTopic  = errors.New("missing topic")
	ErrTooManyTopics = errors.New("too many topics")
)

Types

type DB

type DB struct {
	*sql.DB
	DSN string
}

func NewDB

func NewDB(opts *Options) (*DB, error)

type NodeStore

type NodeStore struct {
	// contains filtered or unexported fields
}

func NewNodeStore

func NewNodeStore(ctx context.Context, db *DB) (*NodeStore, error)

func (*NodeStore) Close

func (s *NodeStore) Close() error

func (*NodeStore) DeleteTopic

func (s *NodeStore) DeleteTopic(topic string) error

func (*NodeStore) NewTopic

func (s *NodeStore) NewTopic(topic string) (crdt.Store, error)

func (*NodeStore) Topics

func (s *NodeStore) Topics() (topics []string, err error)

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 New

func New(ctx context.Context, db *DB, topic string) *Store

func (*Store) AppendEvent

func (s *Store) AppendEvent(ctx context.Context, env *messagev1.Envelope) (*types.Event, error)

func (*Store) Events

func (s *Store) Events(ctx context.Context) ([]*types.Event, error)

func (*Store) FindMissingLinks

func (s *Store) FindMissingLinks(ctx context.Context) ([]multihash.Multihash, error)

func (*Store) GetEvents

func (s *Store) GetEvents(ctx context.Context, cids ...multihash.Multihash) ([]*types.Event, error)

func (*Store) Heads

func (s *Store) Heads(ctx context.Context) ([]multihash.Multihash, error)

func (*Store) InsertEvent

func (s *Store) InsertEvent(ctx context.Context, ev *types.Event) (bool, error)

func (*Store) InsertHead

func (s *Store) InsertHead(ctx context.Context, ev *types.Event) (bool, error)

func (*Store) InsertNewEvents

func (s *Store) InsertNewEvents(ctx context.Context, evs []*types.Event) error

func (*Store) Query

func (s *Store) Query(ctx context.Context, req *messagev1.QueryRequest) (*messagev1.QueryResponse, error)

func (*Store) RemoveHead

func (s *Store) RemoveHead(ctx context.Context, cid multihash.Multihash) (bool, error)