shutter

Documentation

Index

• Constants
• Variables
• func NewDecryptionKeysP2pValidatorEx(logger log.Logger, config Config) pubsub.ValidatorEx
• type Config
  • func ConfigByChainName(chainName string) Config
• type DecryptionKeysListener
  • func NewDecryptionKeysListener(logger log.Logger, config Config) DecryptionKeysListener
  • func (dkl DecryptionKeysListener) RegisterObserver(observer event.Observer[*proto.DecryptionKeys]) event.UnregisterFunc
  • func (dkl DecryptionKeysListener) Run(ctx context.Context) error
• type DecryptionKeysProcessor
  • func NewDecryptionKeysProcessor(logger log.Logger) DecryptionKeysProcessor
  • func (dkp DecryptionKeysProcessor) Enqueue(msg *proto.DecryptionKeys)
  • func (dkp DecryptionKeysProcessor) Run(ctx context.Context) error
• type DecryptionKeysValidator
  • func NewDecryptionKeysValidator(config Config) DecryptionKeysValidator
  • func (v DecryptionKeysValidator) Validate(msg *proto.DecryptionKeys) error
• type P2pConfig
  • func (c P2pConfig) BootstrapNodesAddrInfo() ([]peer.AddrInfo, error)
• type Pool
  • func NewPool(logger log.Logger, config Config, secondaryTxnProvider txnprovider.TxnProvider, ...) *Pool
  • func (p Pool) ProvideTxns(ctx context.Context, opts ...txnprovider.ProvideOption) ([]types.Transaction, error)
  • func (p Pool) Run(ctx context.Context) error

Constants

const (
	ProtocolVersion     = "/shutter/0.1.0"
	DecryptionKeysTopic = "decryptionKeys"
)

Variables

var (
	ErrInstanceIdMismatch     = errors.New("instance id mismatch")
	ErrMissingGnosisExtraData = errors.New("missing gnosis extra data")
	ErrSlotTooLarge           = errors.New("slot too large")
	ErrTxPointerTooLarge      = errors.New("tx pointer too large")
	ErrEonTooLarge            = errors.New("eon too large")
	ErrEmptyKeys              = errors.New("empty keys")
	ErrTooManyKeys            = errors.New("too many keys")
)

Functions

func NewDecryptionKeysP2pValidatorEx

func NewDecryptionKeysP2pValidatorEx(logger log.Logger, config Config) pubsub.ValidatorEx

Types

type Config

type Config struct {
	P2pConfig
	Enabled                          bool
	InstanceId                       uint64
	SequencerContractAddress         string
	ValidatorRegistryContractAddress string
	KeyBroadcastContractAddress      string
	KeyperSetManagerContractAddress  string
	MaxNumKeysPerMessage             uint64
}

func ConfigByChainName

func ConfigByChainName(chainName string) Config

type DecryptionKeysListener

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

func NewDecryptionKeysListener

func NewDecryptionKeysListener(logger log.Logger, config Config) DecryptionKeysListener

func (DecryptionKeysListener) RegisterObserver

func (dkl DecryptionKeysListener) RegisterObserver(observer event.Observer[*proto.DecryptionKeys]) event.UnregisterFunc

func (DecryptionKeysListener) Run

func (dkl DecryptionKeysListener) Run(ctx context.Context) error

type DecryptionKeysProcessor

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

func NewDecryptionKeysProcessor

func NewDecryptionKeysProcessor(logger log.Logger) DecryptionKeysProcessor

func (DecryptionKeysProcessor) Enqueue

func (dkp DecryptionKeysProcessor) Enqueue(msg *proto.DecryptionKeys)

func (DecryptionKeysProcessor) Run

func (dkp DecryptionKeysProcessor) Run(ctx context.Context) error

type DecryptionKeysValidator

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

func NewDecryptionKeysValidator

func NewDecryptionKeysValidator(config Config) DecryptionKeysValidator

func (DecryptionKeysValidator) Validate

func (v DecryptionKeysValidator) Validate(msg *proto.DecryptionKeys) error

type P2pConfig

type P2pConfig struct {
	PrivateKey     *ecdsa.PrivateKey
	ListenPort     uint64
	BootstrapNodes []string
}

func (P2pConfig) BootstrapNodesAddrInfo

func (c P2pConfig) BootstrapNodesAddrInfo() ([]peer.AddrInfo, error)

type Pool

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

func NewPool

func NewPool(
	logger log.Logger,
	config Config,
	secondaryTxnProvider txnprovider.TxnProvider,
	contractBackend bind.ContractBackend,
) *Pool

func (Pool) ProvideTxns

func (p Pool) ProvideTxns(ctx context.Context, opts ...txnprovider.ProvideOption) ([]types.Transaction, error)

func (Pool) Run

func (p Pool) Run(ctx context.Context) error