db

Documentation

Overview

* Copyright (C) 2020 The poly network Authors * This file is part of The poly network library. * * The poly network is free software: you can redistribute it and/or modify * it under the terms of the GNU Lesser General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * The poly network is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Lesser General Public License for more details. * You should have received a copy of the GNU Lesser General Public License * along with The poly network . If not, see <http://www.gnu.org/licenses/>.

* Copyright (C) 2020 The poly network Authors * This file is part of The poly network library. * * The poly network is free software: you can redistribute it and/or modify * it under the terms of the GNU Lesser General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * The poly network is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Lesser General Public License for more details. * You should have received a copy of the GNU Lesser General Public License * along with The poly network . If not, see <http://www.gnu.org/licenses/>.

Index

• Constants
• Variables
• type BoltDB
  • func NewBoltDB(filePath string) (*BoltDB, error)
  • func (w *BoltDB) Close()
  • func (w *BoltDB) DeleteCheck(txHash string) error
  • func (w *BoltDB) DeleteRetry(k []byte) error
  • func (w *BoltDB) GetAllCheck() (map[string][]byte, error)
  • func (w *BoltDB) GetAllRetry() ([][]byte, error)
  • func (w *BoltDB) GetOntHeight() uint32
  • func (w *BoltDB) GetPolyHeight() uint32
  • func (w *BoltDB) PutCheck(txHash string, v []byte) error
  • func (w *BoltDB) PutOntHeight(height uint32) error
  • func (w *BoltDB) PutPolyHeight(height uint32) error
  • func (w *BoltDB) PutRetry(k []byte) error
• type Retry
  • func (this *Retry) Deserialization(source *common.ZeroCopySource) error
  • func (this *Retry) Serialization(sink *common.ZeroCopySink)

Constants

const MAX_NUM = 1000

Variables

var (
	BKTCheck  = []byte("Check")
	BKTRetry  = []byte("Retry")
	BKTHeight = []byte("Height")
)

Types

type BoltDB

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

func NewBoltDB

func NewBoltDB(filePath string) (*BoltDB, error)

func (*BoltDB) Close

func (w *BoltDB) Close()

func (*BoltDB) DeleteCheck

func (w *BoltDB) DeleteCheck(txHash string) error

func (*BoltDB) DeleteRetry

func (w *BoltDB) DeleteRetry(k []byte) error

func (*BoltDB) GetAllCheck

func (w *BoltDB) GetAllCheck() (map[string][]byte, error)

func (*BoltDB) GetAllRetry

func (w *BoltDB) GetAllRetry() ([][]byte, error)

func (*BoltDB) GetOntHeight

func (w *BoltDB) GetOntHeight() uint32

func (*BoltDB) GetPolyHeight

func (w *BoltDB) GetPolyHeight() uint32

func (*BoltDB) PutCheck

func (w *BoltDB) PutCheck(txHash string, v []byte) error

func (*BoltDB) PutOntHeight

func (w *BoltDB) PutOntHeight(height uint32) error

func (*BoltDB) PutPolyHeight

func (w *BoltDB) PutPolyHeight(height uint32) error

func (*BoltDB) PutRetry

func (w *BoltDB) PutRetry(k []byte) error

type Retry

type Retry struct {
	Height uint32
	Key    string
}

func (*Retry) Deserialization

func (this *Retry) Deserialization(source *common.ZeroCopySource) error

func (*Retry) Serialization

func (this *Retry) Serialization(sink *common.ZeroCopySink)