manager

Documentation

Index

• Variables
• func ExistsIgnoreCase(slice []string, target string) bool
• type FinalityService
  • func NewFinalityService(db *store.Storage, logger log.Logger) *FinalityService
  • func (f *FinalityService) SignatureByBlock(BlockNumber *big.Int) (interface{}, error)
• type Manager
  • func NewFinalityManager(ctx context.Context, db *store.Storage, wsServer server.IWebsocketManager, ...) (*Manager, error)
  • func (m *Manager) SignMsgBatch(request types.SignMsgRequest) ([]byte, error)
  • func (m *Manager) Start(ctx context.Context) error
  • func (m *Manager) Stop(ctx context.Context) error
  • func (m *Manager) Stopped() bool

Variables

var NotVerifiedBlock = errors.New("the manager has not verified this block")

Functions

func ExistsIgnoreCase

func ExistsIgnoreCase(slice []string, target string) bool

Types

type FinalityService

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

func NewFinalityService

func NewFinalityService(db *store.Storage, logger log.Logger) *FinalityService

func (*FinalityService) SignatureByBlock

func (f *FinalityService) SignatureByBlock(BlockNumber *big.Int) (interface{}, error)

type Manager

type Manager struct {
	NodeMembers []string
	// contains filtered or unexported fields
}

func NewFinalityManager

func NewFinalityManager(ctx context.Context, db *store.Storage, wsServer server.IWebsocketManager, cfg *config.Config, shutdown context.CancelCauseFunc, logger log.Logger, priv *ecdsa.PrivateKey) (*Manager, error)

func (*Manager) SignMsgBatch

func (m *Manager) SignMsgBatch(request types.SignMsgRequest) ([]byte, error)

func (*Manager) Start

func (m *Manager) Start(ctx context.Context) error

func (*Manager) Stop

func (m *Manager) Stop(ctx context.Context) error

func (*Manager) Stopped

func (m *Manager) Stopped() bool