Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

operator

package

Go to main page

Versions in this module

v1

v1.2.0

Feb 14, 2024

v1.1.0

Jan 1, 2024

Changes in this version

+ const ErrTooManyRouteRequests

+ func GetOperatorID(operators []*wire.Operator, pkBytes []byte) (uint64, error)

type Switch

+ OperatorID uint64

+ PubKeyBytes []byte

+ Version []byte

+ func (s *Switch) MarshallAndSign(msg wire.SSZMarshaller, msgType wire.TransportType, operatorID uint64, ...) ([]byte, error)

+ func (s *Switch) Pong() ([]byte, error)

+ func (s *Switch) SaveResultData(incMsg *wire.SignedTransport) error

+ func (s *Switch) VerifyIncomingMessage(incMsg *wire.SignedTransport) (uint64, error)

+ func (s *Switch) VerifySig(incMsg *wire.SignedTransport, initiatorPubKey *rsa.PublicKey) error

v1.0.2

Nov 22, 2023

v1.0.1

Nov 13, 2023

v1.0.0

Nov 9, 2023

Changes in this version

type Instance

+ GetLocalOwner func() *dkg.LocalOwner

type Server

+ DB *kv.BadgerDB

type Switch

+ DB *kv.BadgerDB

+ func (s *Switch) CreateInstanceReshare(reqID [24]byte, reshare *wire.Reshare, initiatorPublicKey *rsa.PublicKey, ...) (Instance, []byte, error)

+ func (s *Switch) DecryptSecretDB(bin []byte) ([]byte, error)

+ func (s *Switch) EncryptSecretDB(bin []byte) ([]byte, error)

+ func (s *Switch) GetSecretShare(id [24]byte) (*kyber_dkg.DistKeyShare, error)

+ func (s *Switch) InitInstanceReshare(reqID [24]byte, reshareMsg *wire.Transport, initiatorSignature []byte) ([]byte, error)

+ func (s *Switch) StoreSecretShare(reqID [24]byte, key *kyber_dkg.DistKeyShare) error

v0

v0.0.1

Oct 18, 2023

Changes in this version

+ const ErrTooManyDKGRequests

+ const ErrTooManyOperatorRequests

+ const MaxInstanceTime

+ const MaxInstances

+ var ErrAlreadyExists = errors.New("got init msg for existing instance")

+ var ErrMaxInstances = errors.New("max number of instances ongoing, please wait")

+ var ErrMissingInstance = errors.New("got message to instance that I don't have, send Init first")

+ func ReconstructSignatures(signatures map[uint64][]byte) (*bls.Sign, error)

+ func RegisterRoutes(s *Server)

+ func SplitBytes(buf []byte, lim int) [][]byte

+ func VerifyReconstructedSignature(sig *bls.Sign, validatorPubKey []byte, msg []byte) error

+ type Instance interface

+ Process func(uint64, *wire.SignedTransport) error

+ ReadError func() error

+ ReadResponse func() []byte

+ VerifyInitiatorMessage func(msg, sig []byte) error

+ type InstanceID [24]byte

+ type KeySign struct

+ SigningRoot []byte

+ ValidatorPK ssvspec_types.ValidatorPK

+ func (msg *KeySign) Decode(data []byte) error

+ func (msg *KeySign) Encode() ([]byte, error)

+ type Server struct

+ HttpServer *http.Server

+ Logger *zap.Logger

+ Router chi.Router

+ State *Switch

+ func New(key *rsa.PrivateKey, logger *zap.Logger) *Server

+ func (s *Server) Start(port uint16) error

+ func (s *Server) Stop() error

+ type Switch struct

+ InstanceInitTime map[InstanceID]time.Time

+ Instances map[InstanceID]Instance

+ Logger *zap.Logger

+ Mtx sync.RWMutex

+ PrivateKey *rsa.PrivateKey

+ func NewSwitch(pv *rsa.PrivateKey, logger *zap.Logger) *Switch

+ func (s *Switch) CleanInstances() int

+ func (s *Switch) CreateInstance(reqID [24]byte, init *wire.Init, initiatorPublicKey *rsa.PublicKey) (Instance, []byte, error)

+ func (s *Switch) CreateVerifyFunc(ops []*wire.Operator) (func(id uint64, msg []byte, sig []byte) error, error)

+ func (s *Switch) Decrypt(ciphertext []byte) ([]byte, error)

+ func (s *Switch) Encrypt(msg []byte) ([]byte, error)

+ func (s *Switch) InitInstance(reqID [24]byte, initMsg *wire.Transport, initiatorSignature []byte) ([]byte, error)

+ func (s *Switch) ProcessMessage(dkgMsg []byte) ([]byte, error)

+ func (s *Switch) Sign(msg []byte) ([]byte, error)

+ type TestOperator struct

+ HttpSrv *httptest.Server

+ ID uint64

+ PrivKey *rsa.PrivateKey

+ Srv *Server

+ func CreateTestOperator(t *testing.T, id uint64) *TestOperator

+ func CreateTestOperatorFromFile(t *testing.T, id uint64, examplePath string) *TestOperator