step

package
v1.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 21, 2020 License: GPL-3.0, MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AckMpcGPKStep 

type AckMpcGPKStep struct {
	BaseStep
	// contains filtered or unexported fields
}

func CreateAckMpcGPKStep 

func CreateAckMpcGPKStep(peers *[]mpcprotocol.PeerInfo) *AckMpcGPKStep

func (*AckMpcGPKStep) CreateMessage 

func (ack *AckMpcGPKStep) CreateMessage() []mpcprotocol.StepMessage

func (*AckMpcGPKStep) FinishStep 

func (ack *AckMpcGPKStep) FinishStep(result mpcprotocol.MpcResultInterface, mpc mpcprotocol.StoremanManager) error

func (*AckMpcGPKStep) HandleMessage 

func (ack *AckMpcGPKStep) HandleMessage(msg *mpcprotocol.StepMessage) bool

func (*AckMpcGPKStep) InitStep 

func (ack *AckMpcGPKStep) InitStep(result mpcprotocol.MpcResultInterface) error

type AckMpcStep 

type AckMpcStep struct {
	BaseStep
	// contains filtered or unexported fields
}

func CreateAckMpcStep 

func CreateAckMpcStep(peers *[]mpcprotocol.PeerInfo, messageType int64) *AckMpcStep

func (*AckMpcStep) CreateMessage 

func (ack *AckMpcStep) CreateMessage() []mpcprotocol.StepMessage

func (*AckMpcStep) FinishStep 

func (ack *AckMpcStep) FinishStep(result mpcprotocol.MpcResultInterface, mpc mpcprotocol.StoremanManager) error

func (*AckMpcStep) HandleMessage 

func (ack *AckMpcStep) HandleMessage(msg *mpcprotocol.StepMessage) bool

func (*AckMpcStep) InitStep 

func (ack *AckMpcStep) InitStep(mpcprotocol.MpcResultInterface) error

type BaseMpcStep 

type BaseMpcStep struct {
	BaseStep
	// contains filtered or unexported fields
}

func CreateBaseMpcStep 

func CreateBaseMpcStep(peers *[]mpcprotocol.PeerInfo, messageNum int) *BaseMpcStep

func (*BaseMpcStep) FinishStep 

func (mpcStep *BaseMpcStep) FinishStep() error

func (*BaseMpcStep) InitStep 

func (mpcStep *BaseMpcStep) InitStep(result mpcprotocol.MpcResultInterface) error

type BaseStep 

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

func CreateBaseStep 

func CreateBaseStep(peers *[]mpcprotocol.PeerInfo, wait int) *BaseStep

func (*BaseStep) FinishStep 

func (step *BaseStep) FinishStep() error

func (*BaseStep) GetMessageChan 

func (step *BaseStep) GetMessageChan() chan *mpcprotocol.StepMessage

func (*BaseStep) GetStepId 

func (step *BaseStep) GetStepId() int

func (*BaseStep) HandleMessage 

func (step *BaseStep) HandleMessage(msger mpcprotocol.GetMessageInterface) error

func (*BaseStep) InitMessageLoop 

func (step *BaseStep) InitMessageLoop(msger mpcprotocol.GetMessageInterface) error

func (*BaseStep) Quit 

func (step *BaseStep) Quit(err error)

func (*BaseStep) SetStepId 

func (step *BaseStep) SetStepId(stepId int)

func (*BaseStep) SetWaitAll 

func (step *BaseStep) SetWaitAll(waitAll bool)

func (*BaseStep) SetWaiting 

func (step *BaseStep) SetWaiting(waiting int)

type GetMpcReadyStep 

type GetMpcReadyStep struct {
	BaseStep
}

func CreateGetMpcReadyStep 

func CreateGetMpcReadyStep(peers *[]mpcprotocol.PeerInfo) *GetMpcReadyStep

func (*GetMpcReadyStep) CreateMessage 

func (ready *GetMpcReadyStep) CreateMessage() []mpcprotocol.StepMessage

func (*GetMpcReadyStep) FinishStep 

func (ready *GetMpcReadyStep) FinishStep(result mpcprotocol.MpcResultInterface,
	mpc mpcprotocol.StoremanManager) error

func (*GetMpcReadyStep) HandleMessage 

func (ready *GetMpcReadyStep) HandleMessage(msg *mpcprotocol.StepMessage) bool

func (*GetMpcReadyStep) InitStep 

func (ready *GetMpcReadyStep) InitStep(mpcprotocol.MpcResultInterface) error

type MpcAckRSStep 

type MpcAckRSStep struct {
	BaseStep
	// contains filtered or unexported fields
}

func CreateAckMpcRSStep 

func CreateAckMpcRSStep(peers *[]mpcprotocol.PeerInfo, accType string) *MpcAckRSStep

func (*MpcAckRSStep) CreateMessage 

func (mars *MpcAckRSStep) CreateMessage() []mpcprotocol.StepMessage

func (*MpcAckRSStep) FinishStep 

func (mars *MpcAckRSStep) FinishStep(result mpcprotocol.MpcResultInterface, mpc mpcprotocol.StoremanManager) error

func (*MpcAckRSStep) HandleMessage 

func (mars *MpcAckRSStep) HandleMessage(msg *mpcprotocol.StepMessage) bool

func (*MpcAckRSStep) InitStep 

func (mars *MpcAckRSStep) InitStep(result mpcprotocol.MpcResultInterface) error

type MpcGPKStep 

type MpcGPKStep struct {
	MpcPointStep
	// contains filtered or unexported fields
}

func CreateMpcGPKStep 

func CreateMpcGPKStep(peers *[]mpcprotocol.PeerInfo, accType string) *MpcGPKStep

func (*MpcGPKStep) FinishStep 

func (addStep *MpcGPKStep) FinishStep(result mpcprotocol.MpcResultInterface, mpc mpcprotocol.StoremanManager) error

type MpcMessageGenerator 

type MpcMessageGenerator interface {
	// contains filtered or unexported methods
}

type MpcPointStep 

type MpcPointStep struct {
	BaseMpcStep
	// contains filtered or unexported fields
}

func CreateMpcPointStep 

func CreateMpcPointStep(peers *[]mpcprotocol.PeerInfo, preValueKeys []string, resultKeys []string) *MpcPointStep

func (*MpcPointStep) CreateMessage 

func (ptStep *MpcPointStep) CreateMessage() []mpcprotocol.StepMessage

func (*MpcPointStep) FinishStep 

func (ptStep *MpcPointStep) FinishStep(result mpcprotocol.MpcResultInterface, mpc mpcprotocol.StoremanManager) error

func (*MpcPointStep) HandleMessage 

func (ptStep *MpcPointStep) HandleMessage(msg *mpcprotocol.StepMessage) bool

type MpcRSKShare_Step 

type MpcRSKShare_Step struct {
	BaseMpcStep
}

func CreateMpcRSKShareStep 

func CreateMpcRSKShareStep(degree int, peers *[]mpcprotocol.PeerInfo) *MpcRSKShare_Step

func (*MpcRSKShare_Step) CreateMessage 

func (jrss *MpcRSKShare_Step) CreateMessage() []mpcprotocol.StepMessage

func (*MpcRSKShare_Step) FinishStep 

func (jrss *MpcRSKShare_Step) FinishStep(result mpcprotocol.MpcResultInterface, mpc mpcprotocol.StoremanManager) error

func (*MpcRSKShare_Step) HandleMessage 

func (jrss *MpcRSKShare_Step) HandleMessage(msg *mpcprotocol.StepMessage) bool

type MpcRStep 

type MpcRStep struct {
	MpcPointStep
	// contains filtered or unexported fields
}

func CreateMpcRStep 

func CreateMpcRStep(peers *[]mpcprotocol.PeerInfo, accType string) *MpcRStep

func (*MpcRStep) FinishStep 

func (addStep *MpcRStep) FinishStep(result mpcprotocol.MpcResultInterface, mpc mpcprotocol.StoremanManager) error

type MpcReadyStep 

type MpcReadyStep struct {
	BaseStep
}

func CreateMpcReadyStep 

func CreateMpcReadyStep(peers *[]mpcprotocol.PeerInfo) *MpcReadyStep

func (*MpcReadyStep) CreateMessage 

func (ready *MpcReadyStep) CreateMessage() []mpcprotocol.StepMessage

func (*MpcReadyStep) FinishStep 

func (ready *MpcReadyStep) FinishStep(result mpcprotocol.MpcResultInterface, mpc mpcprotocol.StoremanManager) error

func (*MpcReadyStep) HandleMessage 

func (ready *MpcReadyStep) HandleMessage(msg *mpcprotocol.StepMessage) bool

func (*MpcReadyStep) InitStep 

func (ready *MpcReadyStep) InitStep(mpcprotocol.MpcResultInterface) error

type MpcSKShareStep 

type MpcSKShareStep struct {
	BaseMpcStep
}

func CreateMpcSKShareStep 

func CreateMpcSKShareStep(degree int, peers *[]mpcprotocol.PeerInfo) *MpcSKShareStep

func (*MpcSKShareStep) CreateMessage 

func (jrss *MpcSKShareStep) CreateMessage() []mpcprotocol.StepMessage

func (*MpcSKShareStep) FinishStep 

func (jrss *MpcSKShareStep) FinishStep(result mpcprotocol.MpcResultInterface, mpc mpcprotocol.StoremanManager) error

func (*MpcSKShareStep) HandleMessage 

func (jrss *MpcSKShareStep) HandleMessage(msg *mpcprotocol.StepMessage) bool

type MpcSStep 

type MpcSStep struct {
	BaseMpcStep
	// contains filtered or unexported fields
}

func CreateMpcSStep 

func CreateMpcSStep(peers *[]mpcprotocol.PeerInfo, preValueKeys []string, resultKeys []string) *MpcSStep

func (*MpcSStep) CreateMessage 

func (msStep *MpcSStep) CreateMessage() []mpcprotocol.StepMessage

func (*MpcSStep) FinishStep 

func (msStep *MpcSStep) FinishStep(result mpcprotocol.MpcResultInterface, mpc mpcprotocol.StoremanManager) error

func (*MpcSStep) HandleMessage 

func (msStep *MpcSStep) HandleMessage(msg *mpcprotocol.StepMessage) bool

type RandomPolynomialValue 

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

type RequestMpcStep 

type RequestMpcStep struct {
	BaseStep
	// contains filtered or unexported fields
}

func CreateRequestMpcStep 

func CreateRequestMpcStep(peers *[]mpcprotocol.PeerInfo, messageType int64) *RequestMpcStep

func (*RequestMpcStep) CreateMessage 

func (req *RequestMpcStep) CreateMessage() []mpcprotocol.StepMessage

func (*RequestMpcStep) FinishStep 

func (req *RequestMpcStep) FinishStep(result mpcprotocol.MpcResultInterface, mpc mpcprotocol.StoremanManager) error

func (*RequestMpcStep) HandleMessage 

func (req *RequestMpcStep) HandleMessage(msg *mpcprotocol.StepMessage) bool

func (*RequestMpcStep) InitStep 

func (req *RequestMpcStep) InitStep(result mpcprotocol.MpcResultInterface) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.