core

Documentation

Index

• type BlockDB
  • func (n *BlockDB) InitDefault()
  • func (n *BlockDB) Name() string
  • func (n *BlockDB) Setup()
  • func (n *BlockDB) Start()
  • func (n *BlockDB) Stop()
• type BusinessReader
  • func NewBusinessReader(storageExecutor core_interface.StorageExecutor) *BusinessReader
  • func (s *BusinessReader) Action(ctx context.Context, opHash string, version int) ([]byte, error)
  • func (s *BusinessReader) Actions(ctx context.Context, opHash string) ([]byte, error)
  • func (s *BusinessReader) Close(ctx context.Context) error
  • func (s *BusinessReader) CurrentValue(ctx context.Context, opHash string) ([]byte, error)
  • func (s *BusinessReader) Info(ctx context.Context, opHash string) ([]byte, error)
  • func (s *BusinessReader) Value(ctx context.Context, opHash string, version int) ([]byte, error)
  • func (s *BusinessReader) Values(ctx context.Context, opHash string) ([]byte, error)
• type Component
• type DefaultCommandProcessor
  • func (d DefaultCommandProcessor) Process(command core_interface.BlockDBCommand) (core_interface.CommandProcessResult, error)
• type DefaultJsonCommandParser
  • func (d DefaultJsonCommandParser) FromJson(json string) (core_interface.BlockDBCommand, error)

Types

type BlockDB

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

func (*BlockDB) InitDefault

func (n *BlockDB) InitDefault()

func (*BlockDB) Name

func (n *BlockDB) Name() string

func (*BlockDB) Setup

func (n *BlockDB) Setup()

func (*BlockDB) Start

func (n *BlockDB) Start()

func (*BlockDB) Stop

func (n *BlockDB) Stop()

type BusinessReader

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

func NewBusinessReader

func NewBusinessReader(storageExecutor core_interface.StorageExecutor) *BusinessReader

func (*BusinessReader) Action

func (s *BusinessReader) Action(ctx context.Context, opHash string, version int) ([]byte, error)

func (*BusinessReader) Actions

func (s *BusinessReader) Actions(ctx context.Context, opHash string) ([]byte, error)

func (*BusinessReader) Close

func (s *BusinessReader) Close(ctx context.Context) error

func (*BusinessReader) CurrentValue

func (s *BusinessReader) CurrentValue(ctx context.Context, opHash string) ([]byte, error)

func (*BusinessReader) Info

func (s *BusinessReader) Info(ctx context.Context, opHash string) ([]byte, error)

func (*BusinessReader) Value

func (s *BusinessReader) Value(ctx context.Context, opHash string, version int) ([]byte, error)

func (*BusinessReader) Values

func (s *BusinessReader) Values(ctx context.Context, opHash string) ([]byte, error)

type Component

type Component interface {
	Start()
	Stop()
	// Get the component name
	Name() string
}

type DefaultCommandProcessor

type DefaultCommandProcessor struct {
}

func (DefaultCommandProcessor) Process

func (d DefaultCommandProcessor) Process(command core_interface.BlockDBCommand) (core_interface.CommandProcessResult, error)

type DefaultJsonCommandParser

type DefaultJsonCommandParser struct {
}

func (DefaultJsonCommandParser) FromJson

func (d DefaultJsonCommandParser) FromJson(json string) (core_interface.BlockDBCommand, error)