store

Documentation

Index

• Constants
• type ApplyResponse
• type FSMSnapshot
  • func (f *FSMSnapshot) Persist(sink raft.SnapshotSink) error
  • func (f *FSMSnapshot) Release()
• type LogCommand
• type Store
  • func New(dbPath string) (*Store, error)
  • func (s *Store) Apply(log *raft.Log) interface{}
  • func (s *Store) Close() error
  • func (s *Store) Ping() error
  • func (s *Store) Query(sql string) ([]pgproto3.FieldDescription, [][][]byte, error)
  • func (s *Store) Replicate(sql string) error
  • func (s *Store) ReplicateBatch(batch []string) error
  • func (s *Store) Restore(snapshot io.ReadCloser) error
  • func (s *Store) SetRaft(r *raft.Raft)
  • func (s *Store) Snapshot() (raft.FSMSnapshot, error)

Constants

const (
	OIDBytea     uint32 = 17
	OIDInt8      uint32 = 20
	OIDText      uint32 = 25
	OIDFloat8    uint32 = 701
	OIDTimestamp uint32 = 1114
)

const SnapshotVersion byte = 1

Types

type ApplyResponse

type ApplyResponse struct {
	Error  error
	Result sql.Result
}

type FSMSnapshot

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

func (*FSMSnapshot) Persist

func (f *FSMSnapshot) Persist(sink raft.SnapshotSink) error

func (*FSMSnapshot) Release

func (f *FSMSnapshot) Release()

type LogCommand

type LogCommand struct {
	Type  string
	SQL   string
	Batch []string
}

type Store

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

func New

func New(dbPath string) (*Store, error)

func (*Store) Apply

func (s *Store) Apply(log *raft.Log) interface{}

func (*Store) Close

func (s *Store) Close() error

func (*Store) Ping

func (s *Store) Ping() error

func (*Store) Query

func (s *Store) Query(sql string) ([]pgproto3.FieldDescription, [][][]byte, error)

func (*Store) Replicate

func (s *Store) Replicate(sql string) error

func (*Store) ReplicateBatch

func (s *Store) ReplicateBatch(batch []string) error

func (*Store) Restore

func (s *Store) Restore(snapshot io.ReadCloser) error

func (*Store) SetRaft

func (s *Store) SetRaft(r *raft.Raft)

func (*Store) Snapshot

func (s *Store) Snapshot() (raft.FSMSnapshot, error)