dkg

package
v2.0.6-testnet Latest Latest
Warning

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

 Go to latest Published: May 10, 2024 License: Apache-2.0, MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DKGControl_Command_FullMethodName      = "/dkg.DKGControl/Command"
	DKGControl_Packet_FullMethodName       = "/dkg.DKGControl/Packet"
	DKGControl_DKGStatus_FullMethodName    = "/dkg.DKGControl/DKGStatus"
	DKGControl_BroadcastDKG_FullMethodName = "/dkg.DKGControl/BroadcastDKG"
)

Variables

View Source 
var DKGControl_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dkg.DKGControl",
	HandlerType: (*DKGControlServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Command",
			Handler:    _DKGControl_Command_Handler,
		},
		{
			MethodName: "Packet",
			Handler:    _DKGControl_Packet_Handler,
		},
		{
			MethodName: "DKGStatus",
			Handler:    _DKGControl_DKGStatus_Handler,
		},
		{
			MethodName: "BroadcastDKG",
			Handler:    _DKGControl_BroadcastDKG_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dkg/dkg_control.proto",
}

DKGControl_ServiceDesc is the grpc.ServiceDesc for DKGControl service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_dkg_dkg_control_proto protoreflect.FileDescriptor
View Source 
var File_dkg_dkg_proto protoreflect.FileDescriptor

Functions

func RegisterDKGControlServer 

func RegisterDKGControlServer(s grpc.ServiceRegistrar, srv DKGControlServer)

Types

type AbortDKG 

type AbortDKG struct {
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*AbortDKG) Descriptor deprecated 

func (*AbortDKG) Descriptor() ([]byte, []int)

Deprecated: Use AbortDKG.ProtoReflect.Descriptor instead.

func (*AbortDKG) GetReason 

func (x *AbortDKG) GetReason() string

func (*AbortDKG) ProtoMessage 

func (*AbortDKG) ProtoMessage()

func (*AbortDKG) ProtoReflect 

func (x *AbortDKG) ProtoReflect() protoreflect.Message

func (*AbortDKG) Reset 

func (x *AbortDKG) Reset()

func (*AbortDKG) String 

func (x *AbortDKG) String() string

type AbortOptions 

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

func (*AbortOptions) Descriptor deprecated 

func (*AbortOptions) Descriptor() ([]byte, []int)

Deprecated: Use AbortOptions.ProtoReflect.Descriptor instead.

func (*AbortOptions) ProtoMessage 

func (*AbortOptions) ProtoMessage()

func (*AbortOptions) ProtoReflect 

func (x *AbortOptions) ProtoReflect() protoreflect.Message

func (*AbortOptions) Reset 

func (x *AbortOptions) Reset()

func (*AbortOptions) String 

func (x *AbortOptions) String() string

type AcceptOptions 

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

func (*AcceptOptions) Descriptor deprecated 

func (*AcceptOptions) Descriptor() ([]byte, []int)

Deprecated: Use AcceptOptions.ProtoReflect.Descriptor instead.

func (*AcceptOptions) ProtoMessage 

func (*AcceptOptions) ProtoMessage()

func (*AcceptOptions) ProtoReflect 

func (x *AcceptOptions) ProtoReflect() protoreflect.Message

func (*AcceptOptions) Reset 

func (x *AcceptOptions) Reset()

func (*AcceptOptions) String 

func (x *AcceptOptions) String() string

type AcceptProposal 

type AcceptProposal struct {
	Acceptor *Participant `protobuf:"bytes,1,opt,name=acceptor,proto3" json:"acceptor,omitempty"`
	// contains filtered or unexported fields
}

func (*AcceptProposal) Descriptor deprecated 

func (*AcceptProposal) Descriptor() ([]byte, []int)

Deprecated: Use AcceptProposal.ProtoReflect.Descriptor instead.

func (*AcceptProposal) GetAcceptor 

func (x *AcceptProposal) GetAcceptor() *Participant

func (*AcceptProposal) ProtoMessage 

func (*AcceptProposal) ProtoMessage()

func (*AcceptProposal) ProtoReflect 

func (x *AcceptProposal) ProtoReflect() protoreflect.Message

func (*AcceptProposal) Reset 

func (x *AcceptProposal) Reset()

func (*AcceptProposal) String 

func (x *AcceptProposal) String() string

type CommandMetadata 

type CommandMetadata struct {
	BeaconID string `protobuf:"bytes,1,opt,name=beaconID,proto3" json:"beaconID,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandMetadata) Descriptor deprecated 

func (*CommandMetadata) Descriptor() ([]byte, []int)

Deprecated: Use CommandMetadata.ProtoReflect.Descriptor instead.

func (*CommandMetadata) GetBeaconID 

func (x *CommandMetadata) GetBeaconID() string

func (*CommandMetadata) ProtoMessage 

func (*CommandMetadata) ProtoMessage()

func (*CommandMetadata) ProtoReflect 

func (x *CommandMetadata) ProtoReflect() protoreflect.Message

func (*CommandMetadata) Reset 

func (x *CommandMetadata) Reset()

func (*CommandMetadata) String 

func (x *CommandMetadata) String() string

type DKGCommand 

type DKGCommand struct {
	Metadata *CommandMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Types that are assignable to Command:
	//
	//	*DKGCommand_Initial
	//	*DKGCommand_Resharing
	//	*DKGCommand_Join
	//	*DKGCommand_Accept
	//	*DKGCommand_Reject
	//	*DKGCommand_Execute
	//	*DKGCommand_Abort
	Command isDKGCommand_Command `protobuf_oneof:"Command"`
	// contains filtered or unexported fields
}

func (*DKGCommand) Descriptor deprecated 

func (*DKGCommand) Descriptor() ([]byte, []int)

Deprecated: Use DKGCommand.ProtoReflect.Descriptor instead.

func (*DKGCommand) GetAbort 

func (x *DKGCommand) GetAbort() *AbortOptions

func (*DKGCommand) GetAccept 

func (x *DKGCommand) GetAccept() *AcceptOptions

func (*DKGCommand) GetCommand 

func (m *DKGCommand) GetCommand() isDKGCommand_Command

func (*DKGCommand) GetExecute 

func (x *DKGCommand) GetExecute() *ExecutionOptions

func (*DKGCommand) GetInitial 

func (x *DKGCommand) GetInitial() *FirstProposalOptions

func (*DKGCommand) GetJoin 

func (x *DKGCommand) GetJoin() *JoinOptions

func (*DKGCommand) GetMetadata 

func (x *DKGCommand) GetMetadata() *CommandMetadata

func (*DKGCommand) GetReject 

func (x *DKGCommand) GetReject() *RejectOptions

func (*DKGCommand) GetResharing 

func (x *DKGCommand) GetResharing() *ProposalOptions

func (*DKGCommand) ProtoMessage 

func (*DKGCommand) ProtoMessage()

func (*DKGCommand) ProtoReflect 

func (x *DKGCommand) ProtoReflect() protoreflect.Message

func (*DKGCommand) Reset 

func (x *DKGCommand) Reset()

func (*DKGCommand) String 

func (x *DKGCommand) String() string

type DKGCommand_Abort 

type DKGCommand_Abort struct {
	Abort *AbortOptions `protobuf:"bytes,9,opt,name=abort,proto3,oneof"`
}

type DKGCommand_Accept 

type DKGCommand_Accept struct {
	Accept *AcceptOptions `protobuf:"bytes,5,opt,name=accept,proto3,oneof"`
}

type DKGCommand_Execute 

type DKGCommand_Execute struct {
	Execute *ExecutionOptions `protobuf:"bytes,7,opt,name=execute,proto3,oneof"`
}

type DKGCommand_Initial 

type DKGCommand_Initial struct {
	Initial *FirstProposalOptions `protobuf:"bytes,2,opt,name=initial,proto3,oneof"`
}

type DKGCommand_Join 

type DKGCommand_Join struct {
	Join *JoinOptions `protobuf:"bytes,4,opt,name=join,proto3,oneof"`
}

type DKGCommand_Reject 

type DKGCommand_Reject struct {
	Reject *RejectOptions `protobuf:"bytes,6,opt,name=reject,proto3,oneof"`
}

type DKGCommand_Resharing 

type DKGCommand_Resharing struct {
	Resharing *ProposalOptions `protobuf:"bytes,3,opt,name=resharing,proto3,oneof"`
}

type DKGControlClient 

type DKGControlClient interface {
	Command(ctx context.Context, in *DKGCommand, opts ...grpc.CallOption) (*EmptyDKGResponse, error)
	Packet(ctx context.Context, in *GossipPacket, opts ...grpc.CallOption) (*EmptyDKGResponse, error)
	DKGStatus(ctx context.Context, in *DKGStatusRequest, opts ...grpc.CallOption) (*DKGStatusResponse, error)
	BroadcastDKG(ctx context.Context, in *DKGPacket, opts ...grpc.CallOption) (*EmptyDKGResponse, error)
}

DKGControlClient is the client API for DKGControl service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDKGControlClient 

func NewDKGControlClient(cc grpc.ClientConnInterface) DKGControlClient

type DKGControlServer 

type DKGControlServer interface {
	Command(context.Context, *DKGCommand) (*EmptyDKGResponse, error)
	Packet(context.Context, *GossipPacket) (*EmptyDKGResponse, error)
	DKGStatus(context.Context, *DKGStatusRequest) (*DKGStatusResponse, error)
	BroadcastDKG(context.Context, *DKGPacket) (*EmptyDKGResponse, error)
}

DKGControlServer is the server API for DKGControl service. All implementations should embed UnimplementedDKGControlServer for forward compatibility

type DKGEntry 

type DKGEntry struct {
	BeaconID    string                 `protobuf:"bytes,1,opt,name=beaconID,proto3" json:"beaconID,omitempty"`
	State       uint32                 `protobuf:"varint,2,opt,name=state,proto3" json:"state,omitempty"`
	Epoch       uint32                 `protobuf:"varint,3,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Threshold   uint32                 `protobuf:"varint,4,opt,name=threshold,proto3" json:"threshold,omitempty"`
	Timeout     *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	GenesisTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=genesis_time,json=genesisTime,proto3" json:"genesis_time,omitempty"`
	GenesisSeed []byte                 `protobuf:"bytes,7,opt,name=genesis_seed,json=genesisSeed,proto3" json:"genesis_seed,omitempty"`
	Leader      *Participant           `protobuf:"bytes,8,opt,name=leader,proto3" json:"leader,omitempty"`
	Remaining   []*Participant         `protobuf:"bytes,9,rep,name=remaining,proto3" json:"remaining,omitempty"`
	Joining     []*Participant         `protobuf:"bytes,10,rep,name=joining,proto3" json:"joining,omitempty"`
	Leaving     []*Participant         `protobuf:"bytes,11,rep,name=leaving,proto3" json:"leaving,omitempty"`
	Acceptors   []*Participant         `protobuf:"bytes,12,rep,name=acceptors,proto3" json:"acceptors,omitempty"`
	Rejectors   []*Participant         `protobuf:"bytes,13,rep,name=rejectors,proto3" json:"rejectors,omitempty"`
	FinalGroup  []string               `protobuf:"bytes,14,rep,name=finalGroup,proto3" json:"finalGroup,omitempty"`
	// contains filtered or unexported fields
}

func (*DKGEntry) Descriptor deprecated 

func (*DKGEntry) Descriptor() ([]byte, []int)

Deprecated: Use DKGEntry.ProtoReflect.Descriptor instead.

func (*DKGEntry) GetAcceptors 

func (x *DKGEntry) GetAcceptors() []*Participant

func (*DKGEntry) GetBeaconID 

func (x *DKGEntry) GetBeaconID() string

func (*DKGEntry) GetEpoch 

func (x *DKGEntry) GetEpoch() uint32

func (*DKGEntry) GetFinalGroup 

func (x *DKGEntry) GetFinalGroup() []string

func (*DKGEntry) GetGenesisSeed 

func (x *DKGEntry) GetGenesisSeed() []byte

func (*DKGEntry) GetGenesisTime 

func (x *DKGEntry) GetGenesisTime() *timestamppb.Timestamp

func (*DKGEntry) GetJoining 

func (x *DKGEntry) GetJoining() []*Participant

func (*DKGEntry) GetLeader 

func (x *DKGEntry) GetLeader() *Participant

func (*DKGEntry) GetLeaving 

func (x *DKGEntry) GetLeaving() []*Participant

func (*DKGEntry) GetRejectors 

func (x *DKGEntry) GetRejectors() []*Participant

func (*DKGEntry) GetRemaining 

func (x *DKGEntry) GetRemaining() []*Participant

func (*DKGEntry) GetState 

func (x *DKGEntry) GetState() uint32

func (*DKGEntry) GetThreshold 

func (x *DKGEntry) GetThreshold() uint32

func (*DKGEntry) GetTimeout 

func (x *DKGEntry) GetTimeout() *timestamppb.Timestamp

func (*DKGEntry) ProtoMessage 

func (*DKGEntry) ProtoMessage()

func (*DKGEntry) ProtoReflect 

func (x *DKGEntry) ProtoReflect() protoreflect.Message

func (*DKGEntry) Reset 

func (x *DKGEntry) Reset()

func (*DKGEntry) String 

func (x *DKGEntry) String() string

type DKGPacket 

type DKGPacket struct {
	Dkg *Packet `protobuf:"bytes,1,opt,name=dkg,proto3" json:"dkg,omitempty"`
	// contains filtered or unexported fields
}

DKGPacket is the packet that nodes send to others nodes as part of the broadcasting protocol.

func (*DKGPacket) Descriptor deprecated 

func (*DKGPacket) Descriptor() ([]byte, []int)

Deprecated: Use DKGPacket.ProtoReflect.Descriptor instead.

func (*DKGPacket) GetDkg 

func (x *DKGPacket) GetDkg() *Packet

func (*DKGPacket) ProtoMessage 

func (*DKGPacket) ProtoMessage()

func (*DKGPacket) ProtoReflect 

func (x *DKGPacket) ProtoReflect() protoreflect.Message

func (*DKGPacket) Reset 

func (x *DKGPacket) Reset()

func (*DKGPacket) String 

func (x *DKGPacket) String() string

type DKGStatusRequest 

type DKGStatusRequest struct {
	BeaconID string `protobuf:"bytes,1,opt,name=beaconID,proto3" json:"beaconID,omitempty"`
	// contains filtered or unexported fields
}

func (*DKGStatusRequest) Descriptor deprecated 

func (*DKGStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use DKGStatusRequest.ProtoReflect.Descriptor instead.

func (*DKGStatusRequest) GetBeaconID 

func (x *DKGStatusRequest) GetBeaconID() string

func (*DKGStatusRequest) ProtoMessage 

func (*DKGStatusRequest) ProtoMessage()

func (*DKGStatusRequest) ProtoReflect 

func (x *DKGStatusRequest) ProtoReflect() protoreflect.Message

func (*DKGStatusRequest) Reset 

func (x *DKGStatusRequest) Reset()

func (*DKGStatusRequest) String 

func (x *DKGStatusRequest) String() string

type DKGStatusResponse 

type DKGStatusResponse struct {
	Complete *DKGEntry `protobuf:"bytes,1,opt,name=complete,proto3" json:"complete,omitempty"`
	Current  *DKGEntry `protobuf:"bytes,2,opt,name=current,proto3" json:"current,omitempty"`
	// contains filtered or unexported fields
}

func (*DKGStatusResponse) Descriptor deprecated 

func (*DKGStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use DKGStatusResponse.ProtoReflect.Descriptor instead.

func (*DKGStatusResponse) GetComplete 

func (x *DKGStatusResponse) GetComplete() *DKGEntry

func (*DKGStatusResponse) GetCurrent 

func (x *DKGStatusResponse) GetCurrent() *DKGEntry

func (*DKGStatusResponse) ProtoMessage 

func (*DKGStatusResponse) ProtoMessage()

func (*DKGStatusResponse) ProtoReflect 

func (x *DKGStatusResponse) ProtoReflect() protoreflect.Message

func (*DKGStatusResponse) Reset 

func (x *DKGStatusResponse) Reset()

func (*DKGStatusResponse) String 

func (x *DKGStatusResponse) String() string

type Deal 

type Deal struct {
	ShareIndex uint32 `protobuf:"varint,1,opt,name=share_index,json=shareIndex,proto3" json:"share_index,omitempty"`
	// encryption of the share using ECIES
	EncryptedShare []byte `protobuf:"bytes,2,opt,name=encrypted_share,json=encryptedShare,proto3" json:"encrypted_share,omitempty"`
	// contains filtered or unexported fields
}

Deal contains a share for a participant.

func (*Deal) Descriptor deprecated 

func (*Deal) Descriptor() ([]byte, []int)

Deprecated: Use Deal.ProtoReflect.Descriptor instead.

func (*Deal) GetEncryptedShare 

func (x *Deal) GetEncryptedShare() []byte

func (*Deal) GetShareIndex 

func (x *Deal) GetShareIndex() uint32

func (*Deal) ProtoMessage 

func (*Deal) ProtoMessage()

func (*Deal) ProtoReflect 

func (x *Deal) ProtoReflect() protoreflect.Message

func (*Deal) Reset 

func (x *Deal) Reset()

func (*Deal) String 

func (x *Deal) String() string

type DealBundle 

type DealBundle struct {

	// Index of the dealer that issues these deals
	DealerIndex uint32 `protobuf:"varint,1,opt,name=dealer_index,json=dealerIndex,proto3" json:"dealer_index,omitempty"`
	// Coefficients of the public polynomial that is created from the
	// private polynomial from which the shares are derived.
	Commits [][]byte `protobuf:"bytes,2,rep,name=commits,proto3" json:"commits,omitempty"`
	// list of deals for each individual share holders.
	Deals []*Deal `protobuf:"bytes,3,rep,name=deals,proto3" json:"deals,omitempty"`
	// session identifier of the protocol run
	SessionId []byte `protobuf:"bytes,4,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// signature over the hash of the deal
	Signature []byte `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

DealBundle is a packet issued by a dealer that contains each individual deals, as well as the coefficients of the public polynomial he used.

func (*DealBundle) Descriptor deprecated 

func (*DealBundle) Descriptor() ([]byte, []int)

Deprecated: Use DealBundle.ProtoReflect.Descriptor instead.

func (*DealBundle) GetCommits 

func (x *DealBundle) GetCommits() [][]byte

func (*DealBundle) GetDealerIndex 

func (x *DealBundle) GetDealerIndex() uint32

func (*DealBundle) GetDeals 

func (x *DealBundle) GetDeals() []*Deal

func (*DealBundle) GetSessionId 

func (x *DealBundle) GetSessionId() []byte

func (*DealBundle) GetSignature 

func (x *DealBundle) GetSignature() []byte

func (*DealBundle) ProtoMessage 

func (*DealBundle) ProtoMessage()

func (*DealBundle) ProtoReflect 

func (x *DealBundle) ProtoReflect() protoreflect.Message

func (*DealBundle) Reset 

func (x *DealBundle) Reset()

func (*DealBundle) String 

func (x *DealBundle) String() string

type EmptyDKGResponse 

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

func (*EmptyDKGResponse) Descriptor deprecated 

func (*EmptyDKGResponse) Descriptor() ([]byte, []int)

Deprecated: Use EmptyDKGResponse.ProtoReflect.Descriptor instead.

func (*EmptyDKGResponse) ProtoMessage 

func (*EmptyDKGResponse) ProtoMessage()

func (*EmptyDKGResponse) ProtoReflect 

func (x *EmptyDKGResponse) ProtoReflect() protoreflect.Message

func (*EmptyDKGResponse) Reset 

func (x *EmptyDKGResponse) Reset()

func (*EmptyDKGResponse) String 

func (x *EmptyDKGResponse) String() string

type ExecutionOptions 

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

func (*ExecutionOptions) Descriptor deprecated 

func (*ExecutionOptions) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionOptions.ProtoReflect.Descriptor instead.

func (*ExecutionOptions) ProtoMessage 

func (*ExecutionOptions) ProtoMessage()

func (*ExecutionOptions) ProtoReflect 

func (x *ExecutionOptions) ProtoReflect() protoreflect.Message

func (*ExecutionOptions) Reset 

func (x *ExecutionOptions) Reset()

func (*ExecutionOptions) String 

func (x *ExecutionOptions) String() string

type FirstProposalOptions 

type FirstProposalOptions struct {
	Timeout              *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Threshold            uint32                 `protobuf:"varint,2,opt,name=threshold,proto3" json:"threshold,omitempty"`
	PeriodSeconds        uint32                 `protobuf:"varint,3,opt,name=period_seconds,json=periodSeconds,proto3" json:"period_seconds,omitempty"`
	Scheme               string                 `protobuf:"bytes,4,opt,name=scheme,proto3" json:"scheme,omitempty"`
	CatchupPeriodSeconds uint32                 `protobuf:"varint,5,opt,name=catchup_period_seconds,json=catchupPeriodSeconds,proto3" json:"catchup_period_seconds,omitempty"`
	GenesisTime          *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=genesis_time,json=genesisTime,proto3" json:"genesis_time,omitempty"`
	Joining              []*Participant         `protobuf:"bytes,7,rep,name=joining,proto3" json:"joining,omitempty"`
	// contains filtered or unexported fields
}

func (*FirstProposalOptions) Descriptor deprecated 

func (*FirstProposalOptions) Descriptor() ([]byte, []int)

Deprecated: Use FirstProposalOptions.ProtoReflect.Descriptor instead.

func (*FirstProposalOptions) GetCatchupPeriodSeconds 

func (x *FirstProposalOptions) GetCatchupPeriodSeconds() uint32

func (*FirstProposalOptions) GetGenesisTime 

func (x *FirstProposalOptions) GetGenesisTime() *timestamppb.Timestamp

func (*FirstProposalOptions) GetJoining 

func (x *FirstProposalOptions) GetJoining() []*Participant

func (*FirstProposalOptions) GetPeriodSeconds 

func (x *FirstProposalOptions) GetPeriodSeconds() uint32

func (*FirstProposalOptions) GetScheme 

func (x *FirstProposalOptions) GetScheme() string

func (*FirstProposalOptions) GetThreshold 

func (x *FirstProposalOptions) GetThreshold() uint32

func (*FirstProposalOptions) GetTimeout 

func (x *FirstProposalOptions) GetTimeout() *timestamppb.Timestamp

func (*FirstProposalOptions) ProtoMessage 

func (*FirstProposalOptions) ProtoMessage()

func (*FirstProposalOptions) ProtoReflect 

func (x *FirstProposalOptions) ProtoReflect() protoreflect.Message

func (*FirstProposalOptions) Reset 

func (x *FirstProposalOptions) Reset()

func (*FirstProposalOptions) String 

func (x *FirstProposalOptions) String() string

type GossipMetadata 

type GossipMetadata struct {
	BeaconID  string `protobuf:"bytes,1,opt,name=beaconID,proto3" json:"beaconID,omitempty"`
	Address   string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*GossipMetadata) Descriptor deprecated 

func (*GossipMetadata) Descriptor() ([]byte, []int)

Deprecated: Use GossipMetadata.ProtoReflect.Descriptor instead.

func (*GossipMetadata) GetAddress 

func (x *GossipMetadata) GetAddress() string

func (*GossipMetadata) GetBeaconID 

func (x *GossipMetadata) GetBeaconID() string

func (*GossipMetadata) GetSignature 

func (x *GossipMetadata) GetSignature() []byte

func (*GossipMetadata) ProtoMessage 

func (*GossipMetadata) ProtoMessage()

func (*GossipMetadata) ProtoReflect 

func (x *GossipMetadata) ProtoReflect() protoreflect.Message

func (*GossipMetadata) Reset 

func (x *GossipMetadata) Reset()

func (*GossipMetadata) String 

func (x *GossipMetadata) String() string

type GossipPacket 

type GossipPacket struct {
	Metadata *GossipMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Types that are assignable to Packet:
	//
	//	*GossipPacket_Proposal
	//	*GossipPacket_Accept
	//	*GossipPacket_Reject
	//	*GossipPacket_Execute
	//	*GossipPacket_Abort
	//	*GossipPacket_Dkg
	Packet isGossipPacket_Packet `protobuf_oneof:"Packet"`
	// contains filtered or unexported fields
}

func (*GossipPacket) Descriptor deprecated 

func (*GossipPacket) Descriptor() ([]byte, []int)

Deprecated: Use GossipPacket.ProtoReflect.Descriptor instead.

func (*GossipPacket) GetAbort 

func (x *GossipPacket) GetAbort() *AbortDKG

func (*GossipPacket) GetAccept 

func (x *GossipPacket) GetAccept() *AcceptProposal

func (*GossipPacket) GetDkg 

func (x *GossipPacket) GetDkg() *DKGPacket

func (*GossipPacket) GetExecute 

func (x *GossipPacket) GetExecute() *StartExecution

func (*GossipPacket) GetMetadata 

func (x *GossipPacket) GetMetadata() *GossipMetadata

func (*GossipPacket) GetPacket 

func (m *GossipPacket) GetPacket() isGossipPacket_Packet

func (*GossipPacket) GetProposal 

func (x *GossipPacket) GetProposal() *ProposalTerms

func (*GossipPacket) GetReject 

func (x *GossipPacket) GetReject() *RejectProposal

func (*GossipPacket) ProtoMessage 

func (*GossipPacket) ProtoMessage()

func (*GossipPacket) ProtoReflect 

func (x *GossipPacket) ProtoReflect() protoreflect.Message

func (*GossipPacket) Reset 

func (x *GossipPacket) Reset()

func (*GossipPacket) String 

func (x *GossipPacket) String() string

type GossipPacket_Abort 

type GossipPacket_Abort struct {
	Abort *AbortDKG `protobuf:"bytes,6,opt,name=abort,proto3,oneof"`
}

type GossipPacket_Accept 

type GossipPacket_Accept struct {
	Accept *AcceptProposal `protobuf:"bytes,3,opt,name=accept,proto3,oneof"`
}

type GossipPacket_Dkg 

type GossipPacket_Dkg struct {
	Dkg *DKGPacket `protobuf:"bytes,7,opt,name=dkg,proto3,oneof"`
}

type GossipPacket_Execute 

type GossipPacket_Execute struct {
	Execute *StartExecution `protobuf:"bytes,5,opt,name=execute,proto3,oneof"`
}

type GossipPacket_Proposal 

type GossipPacket_Proposal struct {
	Proposal *ProposalTerms `protobuf:"bytes,2,opt,name=proposal,proto3,oneof"`
}

type GossipPacket_Reject 

type GossipPacket_Reject struct {
	Reject *RejectProposal `protobuf:"bytes,4,opt,name=reject,proto3,oneof"`
}

type JoinOptions 

type JoinOptions struct {
	GroupFile []byte `protobuf:"bytes,1,opt,name=groupFile,proto3" json:"groupFile,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinOptions) Descriptor deprecated 

func (*JoinOptions) Descriptor() ([]byte, []int)

Deprecated: Use JoinOptions.ProtoReflect.Descriptor instead.

func (*JoinOptions) GetGroupFile 

func (x *JoinOptions) GetGroupFile() []byte

func (*JoinOptions) ProtoMessage 

func (*JoinOptions) ProtoMessage()

func (*JoinOptions) ProtoReflect 

func (x *JoinOptions) ProtoReflect() protoreflect.Message

func (*JoinOptions) Reset 

func (x *JoinOptions) Reset()

func (*JoinOptions) String 

func (x *JoinOptions) String() string

type Justification 

type Justification struct {

	// represents for who share holder this justification is
	ShareIndex uint32 `protobuf:"varint,1,opt,name=share_index,json=shareIndex,proto3" json:"share_index,omitempty"`
	// plaintext share so everyone can see it correct
	Share []byte `protobuf:"bytes,2,opt,name=share,proto3" json:"share,omitempty"`
	// contains filtered or unexported fields
}

Justification holds the justification from a dealer after a participant issued a complaint response because of a supposedly invalid deal.

func (*Justification) Descriptor deprecated 

func (*Justification) Descriptor() ([]byte, []int)

Deprecated: Use Justification.ProtoReflect.Descriptor instead.

func (*Justification) GetShare 

func (x *Justification) GetShare() []byte

func (*Justification) GetShareIndex 

func (x *Justification) GetShareIndex() uint32

func (*Justification) ProtoMessage 

func (*Justification) ProtoMessage()

func (*Justification) ProtoReflect 

func (x *Justification) ProtoReflect() protoreflect.Message

func (*Justification) Reset 

func (x *Justification) Reset()

func (*Justification) String 

func (x *Justification) String() string

type JustificationBundle 

type JustificationBundle struct {
	DealerIndex    uint32           `protobuf:"varint,1,opt,name=dealer_index,json=dealerIndex,proto3" json:"dealer_index,omitempty"`
	Justifications []*Justification `protobuf:"bytes,2,rep,name=justifications,proto3" json:"justifications,omitempty"`
	// session identifier of the protocol run
	SessionId []byte `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// signature over the hash of the justification
	Signature []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

JustificationBundle is a packet that holds all justifications a dealer must produce

func (*JustificationBundle) Descriptor deprecated 

func (*JustificationBundle) Descriptor() ([]byte, []int)

Deprecated: Use JustificationBundle.ProtoReflect.Descriptor instead.

func (*JustificationBundle) GetDealerIndex 

func (x *JustificationBundle) GetDealerIndex() uint32

func (*JustificationBundle) GetJustifications 

func (x *JustificationBundle) GetJustifications() []*Justification

func (*JustificationBundle) GetSessionId 

func (x *JustificationBundle) GetSessionId() []byte

func (*JustificationBundle) GetSignature 

func (x *JustificationBundle) GetSignature() []byte

func (*JustificationBundle) ProtoMessage 

func (*JustificationBundle) ProtoMessage()

func (*JustificationBundle) ProtoReflect 

func (x *JustificationBundle) ProtoReflect() protoreflect.Message

func (*JustificationBundle) Reset 

func (x *JustificationBundle) Reset()

func (*JustificationBundle) String 

func (x *JustificationBundle) String() string

type Packet 

type Packet struct {

	// Types that are assignable to Bundle:
	//
	//	*Packet_Deal
	//	*Packet_Response
	//	*Packet_Justification
	Bundle   isPacket_Bundle `protobuf_oneof:"Bundle"`
	Metadata *drand.Metadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Packet is a wrapper around the three different types of DKG messages

func (*Packet) Descriptor deprecated 

func (*Packet) Descriptor() ([]byte, []int)

Deprecated: Use Packet.ProtoReflect.Descriptor instead.

func (*Packet) GetBundle 

func (m *Packet) GetBundle() isPacket_Bundle

func (*Packet) GetDeal 

func (x *Packet) GetDeal() *DealBundle

func (*Packet) GetJustification 

func (x *Packet) GetJustification() *JustificationBundle

func (*Packet) GetMetadata 

func (x *Packet) GetMetadata() *drand.Metadata

func (*Packet) GetResponse 

func (x *Packet) GetResponse() *ResponseBundle

func (*Packet) ProtoMessage 

func (*Packet) ProtoMessage()

func (*Packet) ProtoReflect 

func (x *Packet) ProtoReflect() protoreflect.Message

func (*Packet) Reset 

func (x *Packet) Reset()

func (*Packet) String 

func (x *Packet) String() string

type Packet_Deal 

type Packet_Deal struct {
	Deal *DealBundle `protobuf:"bytes,1,opt,name=deal,proto3,oneof"`
}

type Packet_Justification 

type Packet_Justification struct {
	Justification *JustificationBundle `protobuf:"bytes,3,opt,name=justification,proto3,oneof"`
}

type Packet_Response 

type Packet_Response struct {
	Response *ResponseBundle `protobuf:"bytes,2,opt,name=response,proto3,oneof"`
}

type Participant 

type Participant struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Key     []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// BLS signature over the identity to prove possession of the private key, it also verify the scheme used
	Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

this is in sync with the Identity one in common.proto

func (*Participant) Descriptor deprecated 

func (*Participant) Descriptor() ([]byte, []int)

Deprecated: Use Participant.ProtoReflect.Descriptor instead.

func (*Participant) GetAddress 

func (x *Participant) GetAddress() string

func (*Participant) GetKey 

func (x *Participant) GetKey() []byte

func (*Participant) GetSignature 

func (x *Participant) GetSignature() []byte

func (*Participant) ProtoMessage 

func (*Participant) ProtoMessage()

func (*Participant) ProtoReflect 

func (x *Participant) ProtoReflect() protoreflect.Message

func (*Participant) Reset 

func (x *Participant) Reset()

func (*Participant) String 

func (x *Participant) String() string

type ProposalOptions 

type ProposalOptions struct {
	Timeout              *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Threshold            uint32                 `protobuf:"varint,2,opt,name=threshold,proto3" json:"threshold,omitempty"`
	CatchupPeriodSeconds uint32                 `protobuf:"varint,3,opt,name=catchup_period_seconds,json=catchupPeriodSeconds,proto3" json:"catchup_period_seconds,omitempty"`
	Joining              []*Participant         `protobuf:"bytes,4,rep,name=joining,proto3" json:"joining,omitempty"`
	Leaving              []*Participant         `protobuf:"bytes,5,rep,name=leaving,proto3" json:"leaving,omitempty"`
	Remaining            []*Participant         `protobuf:"bytes,6,rep,name=remaining,proto3" json:"remaining,omitempty"`
	// contains filtered or unexported fields
}

func (*ProposalOptions) Descriptor deprecated 

func (*ProposalOptions) Descriptor() ([]byte, []int)

Deprecated: Use ProposalOptions.ProtoReflect.Descriptor instead.

func (*ProposalOptions) GetCatchupPeriodSeconds 

func (x *ProposalOptions) GetCatchupPeriodSeconds() uint32

func (*ProposalOptions) GetJoining 

func (x *ProposalOptions) GetJoining() []*Participant

func (*ProposalOptions) GetLeaving 

func (x *ProposalOptions) GetLeaving() []*Participant

func (*ProposalOptions) GetRemaining 

func (x *ProposalOptions) GetRemaining() []*Participant

func (*ProposalOptions) GetThreshold 

func (x *ProposalOptions) GetThreshold() uint32

func (*ProposalOptions) GetTimeout 

func (x *ProposalOptions) GetTimeout() *timestamppb.Timestamp

func (*ProposalOptions) ProtoMessage 

func (*ProposalOptions) ProtoMessage()

func (*ProposalOptions) ProtoReflect 

func (x *ProposalOptions) ProtoReflect() protoreflect.Message

func (*ProposalOptions) Reset 

func (x *ProposalOptions) Reset()

func (*ProposalOptions) String 

func (x *ProposalOptions) String() string

type ProposalTerms 

type ProposalTerms struct {
	BeaconID             string                 `protobuf:"bytes,1,opt,name=beaconID,proto3" json:"beaconID,omitempty"`
	Epoch                uint32                 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Leader               *Participant           `protobuf:"bytes,3,opt,name=leader,proto3" json:"leader,omitempty"`
	Threshold            uint32                 `protobuf:"varint,4,opt,name=threshold,proto3" json:"threshold,omitempty"`
	Timeout              *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	CatchupPeriodSeconds uint32                 `protobuf:"varint,6,opt,name=catchup_period_seconds,json=catchupPeriodSeconds,proto3" json:"catchup_period_seconds,omitempty"`
	BeaconPeriodSeconds  uint32                 `protobuf:"varint,7,opt,name=beacon_period_seconds,json=beaconPeriodSeconds,proto3" json:"beacon_period_seconds,omitempty"`
	SchemeID             string                 `protobuf:"bytes,8,opt,name=schemeID,proto3" json:"schemeID,omitempty"`
	GenesisTime          *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=genesis_time,json=genesisTime,proto3" json:"genesis_time,omitempty"`
	GenesisSeed          []byte                 `protobuf:"bytes,10,opt,name=genesis_seed,json=genesisSeed,proto3" json:"genesis_seed,omitempty"` // joiners require this as they don't have the original group file to generate it
	Joining              []*Participant         `protobuf:"bytes,11,rep,name=joining,proto3" json:"joining,omitempty"`
	Remaining            []*Participant         `protobuf:"bytes,12,rep,name=remaining,proto3" json:"remaining,omitempty"`
	Leaving              []*Participant         `protobuf:"bytes,13,rep,name=leaving,proto3" json:"leaving,omitempty"`
	// contains filtered or unexported fields
}

func (*ProposalTerms) Descriptor deprecated 

func (*ProposalTerms) Descriptor() ([]byte, []int)

Deprecated: Use ProposalTerms.ProtoReflect.Descriptor instead.

func (*ProposalTerms) GetBeaconID 

func (x *ProposalTerms) GetBeaconID() string

func (*ProposalTerms) GetBeaconPeriodSeconds 

func (x *ProposalTerms) GetBeaconPeriodSeconds() uint32

func (*ProposalTerms) GetCatchupPeriodSeconds 

func (x *ProposalTerms) GetCatchupPeriodSeconds() uint32

func (*ProposalTerms) GetEpoch 

func (x *ProposalTerms) GetEpoch() uint32

func (*ProposalTerms) GetGenesisSeed 

func (x *ProposalTerms) GetGenesisSeed() []byte

func (*ProposalTerms) GetGenesisTime 

func (x *ProposalTerms) GetGenesisTime() *timestamppb.Timestamp

func (*ProposalTerms) GetJoining 

func (x *ProposalTerms) GetJoining() []*Participant

func (*ProposalTerms) GetLeader 

func (x *ProposalTerms) GetLeader() *Participant

func (*ProposalTerms) GetLeaving 

func (x *ProposalTerms) GetLeaving() []*Participant

func (*ProposalTerms) GetRemaining 

func (x *ProposalTerms) GetRemaining() []*Participant

func (*ProposalTerms) GetSchemeID 

func (x *ProposalTerms) GetSchemeID() string

func (*ProposalTerms) GetThreshold 

func (x *ProposalTerms) GetThreshold() uint32

func (*ProposalTerms) GetTimeout 

func (x *ProposalTerms) GetTimeout() *timestamppb.Timestamp

func (*ProposalTerms) ProtoMessage 

func (*ProposalTerms) ProtoMessage()

func (*ProposalTerms) ProtoReflect 

func (x *ProposalTerms) ProtoReflect() protoreflect.Message

func (*ProposalTerms) Reset 

func (x *ProposalTerms) Reset()

func (*ProposalTerms) String 

func (x *ProposalTerms) String() string

type RejectOptions 

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

func (*RejectOptions) Descriptor deprecated 

func (*RejectOptions) Descriptor() ([]byte, []int)

Deprecated: Use RejectOptions.ProtoReflect.Descriptor instead.

func (*RejectOptions) ProtoMessage 

func (*RejectOptions) ProtoMessage()

func (*RejectOptions) ProtoReflect 

func (x *RejectOptions) ProtoReflect() protoreflect.Message

func (*RejectOptions) Reset 

func (x *RejectOptions) Reset()

func (*RejectOptions) String 

func (x *RejectOptions) String() string

type RejectProposal 

type RejectProposal struct {

	// the person rejecting the proposal
	Rejector *Participant `protobuf:"bytes,1,opt,name=rejector,proto3" json:"rejector,omitempty"`
	// the reason for rejection, if applicable
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // signature over the proposal message that's being accepted
	// used to authenticate the user
	Secret []byte `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
	// In resharing cases, previous_group_hash is the hash of the previous group.
	// It is to make sure the nodes build on top of the correct previous group.
	PreviousGroupHash []byte `protobuf:"bytes,4,opt,name=previous_group_hash,json=previousGroupHash,proto3" json:"previous_group_hash,omitempty"`
	// a sha256 hash of the original proposal message
	ProposalHash []byte `protobuf:"bytes,5,opt,name=proposal_hash,json=proposalHash,proto3" json:"proposal_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*RejectProposal) Descriptor deprecated 

func (*RejectProposal) Descriptor() ([]byte, []int)

Deprecated: Use RejectProposal.ProtoReflect.Descriptor instead.

func (*RejectProposal) GetPreviousGroupHash 

func (x *RejectProposal) GetPreviousGroupHash() []byte

func (*RejectProposal) GetProposalHash 

func (x *RejectProposal) GetProposalHash() []byte

func (*RejectProposal) GetReason 

func (x *RejectProposal) GetReason() string

func (*RejectProposal) GetRejector 

func (x *RejectProposal) GetRejector() *Participant

func (*RejectProposal) GetSecret 

func (x *RejectProposal) GetSecret() []byte

func (*RejectProposal) ProtoMessage 

func (*RejectProposal) ProtoMessage()

func (*RejectProposal) ProtoReflect 

func (x *RejectProposal) ProtoReflect() protoreflect.Message

func (*RejectProposal) Reset 

func (x *RejectProposal) Reset()

func (*RejectProposal) String 

func (x *RejectProposal) String() string

type Response 

type Response struct {

	// index of the dealer for which this response is for
	DealerIndex uint32 `protobuf:"varint,1,opt,name=dealer_index,json=dealerIndex,proto3" json:"dealer_index,omitempty"`
	// Status represents a complaint if set to false, a success if set to
	// true.
	Status bool `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Response holds the response that a participant broadcast after having received a deal.

func (*Response) Descriptor deprecated 

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetDealerIndex 

func (x *Response) GetDealerIndex() uint32

func (*Response) GetStatus 

func (x *Response) GetStatus() bool

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type ResponseBundle 

type ResponseBundle struct {
	ShareIndex uint32      `protobuf:"varint,1,opt,name=share_index,json=shareIndex,proto3" json:"share_index,omitempty"`
	Responses  []*Response `protobuf:"bytes,2,rep,name=responses,proto3" json:"responses,omitempty"`
	// session identifier of the protocol run
	SessionId []byte `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// signature over the hash of the response
	Signature []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

ResponseBundle is a packet issued by a share holder that contains all the responses (complaint and/or success) to broadcast.

func (*ResponseBundle) Descriptor deprecated 

func (*ResponseBundle) Descriptor() ([]byte, []int)

Deprecated: Use ResponseBundle.ProtoReflect.Descriptor instead.

func (*ResponseBundle) GetResponses 

func (x *ResponseBundle) GetResponses() []*Response

func (*ResponseBundle) GetSessionId 

func (x *ResponseBundle) GetSessionId() []byte

func (*ResponseBundle) GetShareIndex 

func (x *ResponseBundle) GetShareIndex() uint32

func (*ResponseBundle) GetSignature 

func (x *ResponseBundle) GetSignature() []byte

func (*ResponseBundle) ProtoMessage 

func (*ResponseBundle) ProtoMessage()

func (*ResponseBundle) ProtoReflect 

func (x *ResponseBundle) ProtoReflect() protoreflect.Message

func (*ResponseBundle) Reset 

func (x *ResponseBundle) Reset()

func (*ResponseBundle) String 

func (x *ResponseBundle) String() string

type StartExecution 

type StartExecution struct {
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*StartExecution) Descriptor deprecated 

func (*StartExecution) Descriptor() ([]byte, []int)

Deprecated: Use StartExecution.ProtoReflect.Descriptor instead.

func (*StartExecution) GetTime 

func (x *StartExecution) GetTime() *timestamppb.Timestamp

func (*StartExecution) ProtoMessage 

func (*StartExecution) ProtoMessage()

func (*StartExecution) ProtoReflect 

func (x *StartExecution) ProtoReflect() protoreflect.Message

func (*StartExecution) Reset 

func (x *StartExecution) Reset()

func (*StartExecution) String 

func (x *StartExecution) String() string

type UnimplementedDKGControlServer 

type UnimplementedDKGControlServer struct {
}

UnimplementedDKGControlServer should be embedded to have forward compatible implementations.

func (UnimplementedDKGControlServer) BroadcastDKG 

func (UnimplementedDKGControlServer) BroadcastDKG(context.Context, *DKGPacket) (*EmptyDKGResponse, error)

func (UnimplementedDKGControlServer) Command 

func (UnimplementedDKGControlServer) Command(context.Context, *DKGCommand) (*EmptyDKGResponse, error)

func (UnimplementedDKGControlServer) DKGStatus 

func (UnimplementedDKGControlServer) DKGStatus(context.Context, *DKGStatusRequest) (*DKGStatusResponse, error)

func (UnimplementedDKGControlServer) Packet 

func (UnimplementedDKGControlServer) Packet(context.Context, *GossipPacket) (*EmptyDKGResponse, error)

type UnsafeDKGControlServer 

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

UnsafeDKGControlServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DKGControlServer will result in compilation errors.

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.