digest

package

v0.0.0-...-390575e Latest Latest Go to latest Published: Mar 13, 2024 License: GPL-3.0 Imports: 37 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ProtoconNet/mitum-timestamp

Links

Open Source Insights

Documentation ¶

Overview ¶

Package digest provides api features.

Index ¶

Variables
func DigestBlock(ctx context.Context, st *currencydigest.Database, blk base.BlockMap, ...) error
func Timestamp(st *currencydigest.Database, contract string) (types.Design, mitumbase.State, error)
func TimestampItem(st *currencydigest.Database, contract, project string, idx uint64) (types.TimeStampItem, mitumbase.State, error)
type BlockSession
- func NewBlockSession(st *currencydigest.Database, blk mitumbase.BlockMap, ops []mitumbase.Operation, ...) (*BlockSession, error)
type Digester
- func NewDigester(st *currencydigest.Database, root string, ...) *Digester
- func (di *Digester) Digest(blocks []base.BlockMap)
type Handlers
- func NewHandlers(ctx context.Context, networkID base.NetworkID, encs *encoder.Encoders, ...) *Handlers
type TimeStampItemDoc
- func NewTimeStampItemDoc(st base.State, enc encoder.Encoder) (TimeStampItemDoc, error)
- func (doc TimeStampItemDoc) MarshalBSON() ([]byte, error)
type TimeStampServiceDesignDoc
- func NewTimeStampServiceDesignDoc(st base.State, enc encoder.Encoder) (TimeStampServiceDesignDoc, error)
- func (doc TimeStampServiceDesignDoc) MarshalBSON() ([]byte, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	HandlerPathTimeStampService = `/timestamp/{contract:.*}/service`
	HandlerPathTimeStampItem    = `/timestamp/{contract:.*}/project/{project:.+}/id/{tid:[0-9]+}`
)

Functions ¶

func DigestBlock ¶

func DigestBlock(
	ctx context.Context,
	st *currencydigest.Database,
	blk base.BlockMap,
	ops []base.Operation,
	opstree fixedtree.Tree,
	sts []base.State,
	proposal base.ProposalSignFact,
) error

func Timestamp ¶

func Timestamp(st *currencydigest.Database, contract string) (types.Design, mitumbase.State, error)

func TimestampItem ¶

func TimestampItem(st *currencydigest.Database, contract, project string, idx uint64) (types.TimeStampItem, mitumbase.State, error)

Types ¶

type BlockSession ¶

type BlockSession struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewBlockSession ¶

func NewBlockSession(
	st *currencydigest.Database,
	blk mitumbase.BlockMap,
	ops []mitumbase.Operation,
	opstree fixedtree.Tree,
	sts []mitumbase.State,
	proposal mitumbase.ProposalSignFact,
) (*BlockSession, error)

func (*BlockSession) Close ¶

func (bs *BlockSession) Close() error

func (*BlockSession) Commit ¶

func (bs *BlockSession) Commit(ctx context.Context) error

func (*BlockSession) Prepare ¶

func (bs *BlockSession) Prepare() error

type Digester ¶

type Digester struct {
	sync.RWMutex
	*util.ContextDaemon
	*logging.Logging
	// contains filtered or unexported fields
}

func NewDigester ¶

func NewDigester(
	st *currencydigest.Database,
	root string,
	sourceReaders *isaac.BlockItemReaders,
	fromRemotes isaac.RemotesBlockItemReadFunc,
	networkID base.NetworkID,
	errChan chan error,
) *Digester

func (*Digester) Digest ¶

func (di *Digester) Digest(blocks []base.BlockMap)

type Handlers ¶

type Handlers struct {
	*zerolog.Logger
	// contains filtered or unexported fields
}

func NewHandlers ¶

func NewHandlers(
	ctx context.Context,
	networkID base.NetworkID,
	encs *encoder.Encoders,
	enc encoder.Encoder,
	st *currencydigest.Database,
	cache currencydigest.Cache,
	router *mux.Router,
	routes map[string]*mux.Route,
) *Handlers

func (*Handlers) Cache ¶

func (hd *Handlers) Cache() currencydigest.Cache

func (*Handlers) Handler ¶

func (hd *Handlers) Handler() http.Handler

func (*Handlers) Initialize ¶

func (hd *Handlers) Initialize() error

func (*Handlers) Router ¶

func (hd *Handlers) Router() *mux.Router

func (*Handlers) Routes ¶

func (hd *Handlers) Routes() map[string]*mux.Route

func (*Handlers) SetLimiter ¶

func (hd *Handlers) SetLimiter(f func(string) int64) *Handlers

type TimeStampItemDoc ¶

type TimeStampItemDoc struct {
	mongodb.BaseDoc
	// contains filtered or unexported fields
}

func NewTimeStampItemDoc ¶

func NewTimeStampItemDoc(st base.State, enc encoder.Encoder) (TimeStampItemDoc, error)

func (TimeStampItemDoc) MarshalBSON ¶

func (doc TimeStampItemDoc) MarshalBSON() ([]byte, error)

type TimeStampServiceDesignDoc ¶

type TimeStampServiceDesignDoc struct {
	mongodb.BaseDoc
	// contains filtered or unexported fields
}

func NewTimeStampServiceDesignDoc ¶

func NewTimeStampServiceDesignDoc(st base.State, enc encoder.Encoder) (TimeStampServiceDesignDoc, error)

NewTimeStampServiceDesignDoc gets the State of TimeStampServiceDesign

func (TimeStampServiceDesignDoc) MarshalBSON ¶

func (doc TimeStampServiceDesignDoc) MarshalBSON() ([]byte, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL