digest

Documentation

Overview

Package digest provides api features.

Index

• Variables
• func PrepareTimeStamps(bs *cdigest.BlockSession, st base.State) (string, []mongo.WriteModel, error)
• func ProcessDigester(ctx context.Context) (context.Context, error)
• func TimestampDesign(st *cdigest.Database, contract string) (types.Design, base.State, error)
• func TimestampItem(db *cdigest.Database, contract, project string, idx uint64) (types.Item, base.State, error)
• type DesignDoc
  • func NewDesignDoc(st base.State, enc encoder.Encoder) (DesignDoc, error)
  • func (doc DesignDoc) MarshalBSON() ([]byte, error)
• type ItemDoc
  • func NewItemDoc(st base.State, enc encoder.Encoder) (ItemDoc, error)
  • func (doc ItemDoc) MarshalBSON() ([]byte, error)

Variables

var (
	DefaultColNameTimeStamp = "digest_ts"
)

var DefaultIndexes = cdigest.DefaultIndexes

Functions

func PrepareTimeStamps

func PrepareTimeStamps(bs *cdigest.BlockSession, st base.State) (string, []mongo.WriteModel, error)

func ProcessDigester

func ProcessDigester(ctx context.Context) (context.Context, error)

func TimestampDesign

func TimestampDesign(st *cdigest.Database, contract string) (types.Design, base.State, error)

func TimestampItem

func TimestampItem(db *cdigest.Database, contract, project string, idx uint64) (types.Item, base.State, error)

Types

type DesignDoc

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

func NewDesignDoc

func NewDesignDoc(st base.State, enc encoder.Encoder) (DesignDoc, error)

NewDesignDoc get the State of TimeStamp Design

func (DesignDoc) MarshalBSON

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

type ItemDoc

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

func NewItemDoc

func NewItemDoc(st base.State, enc encoder.Encoder) (ItemDoc, error)

func (ItemDoc) MarshalBSON

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