node

Documentation

Index

• Variables
• type DKGMessage
  • func (*DKGMessage) Descriptor() ([]byte, []int)
  • func (m *DKGMessage) Marshal() (dAtA []byte, err error)
  • func (m *DKGMessage) MarshalTo(dAtA []byte) (int, error)
  • func (m *DKGMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*DKGMessage) ProtoMessage()
  • func (m *DKGMessage) Reset()
  • func (m *DKGMessage) Size() (n int)
  • func (m *DKGMessage) String() string
  • func (m *DKGMessage) Unmarshal(dAtA []byte) error
  • func (m *DKGMessage) XXX_DiscardUnknown()
  • func (m *DKGMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DKGMessage) XXX_Merge(src proto.Message)
  • func (m *DKGMessage) XXX_Size() int
  • func (m *DKGMessage) XXX_Unmarshal(b []byte) error
• type Node
  • func NewNode(rootPath string, endPoint string, seed string, role string) *Node
  • func (n *Node) Start()
  • func (n *Node) Stop()
• type NodeMessage
  • func (*NodeMessage) Descriptor() ([]byte, []int)
  • func (m *NodeMessage) GetData() []byte
  • func (m *NodeMessage) GetMsgType() NodeMessage_NodeMessageType
  • func (m *NodeMessage) Marshal() (dAtA []byte, err error)
  • func (m *NodeMessage) MarshalTo(dAtA []byte) (int, error)
  • func (m *NodeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*NodeMessage) ProtoMessage()
  • func (m *NodeMessage) Reset()
  • func (m *NodeMessage) Size() (n int)
  • func (m *NodeMessage) String() string
  • func (m *NodeMessage) Unmarshal(dAtA []byte) error
  • func (m *NodeMessage) XXX_DiscardUnknown()
  • func (m *NodeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *NodeMessage) XXX_Merge(src proto.Message)
  • func (m *NodeMessage) XXX_Size() int
  • func (m *NodeMessage) XXX_Unmarshal(b []byte) error
• type NodeMessage_NodeMessageType
  • func (NodeMessage_NodeMessageType) EnumDescriptor() ([]byte, []int)
  • func (x NodeMessage_NodeMessageType) String() string

Variables

var (
	ErrInvalidLengthMessageNode        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessageNode          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessageNode = fmt.Errorf("proto: unexpected end of group")
)

var NodeMessage_NodeMessageType_name = map[int32]string{
	0: "Unknown",
	1: "DKG",
}

var NodeMessage_NodeMessageType_value = map[string]int32{
	"Unknown": 0,
	"DKG":     1,
}

Types

type DKGMessage

type DKGMessage struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DKGMessage) Descriptor

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

func (*DKGMessage) Marshal

func (m *DKGMessage) Marshal() (dAtA []byte, err error)

func (*DKGMessage) MarshalTo

func (m *DKGMessage) MarshalTo(dAtA []byte) (int, error)

func (*DKGMessage) MarshalToSizedBuffer

func (m *DKGMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DKGMessage) ProtoMessage

func (*DKGMessage) ProtoMessage()

func (*DKGMessage) Reset

func (m *DKGMessage) Reset()

func (*DKGMessage) Size

func (m *DKGMessage) Size() (n int)

func (*DKGMessage) String

func (m *DKGMessage) String() string

func (*DKGMessage) Unmarshal

func (m *DKGMessage) Unmarshal(dAtA []byte) error

func (*DKGMessage) XXX_DiscardUnknown

func (m *DKGMessage) XXX_DiscardUnknown()

func (*DKGMessage) XXX_Marshal

func (m *DKGMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DKGMessage) XXX_Merge

func (m *DKGMessage) XXX_Merge(src proto.Message)

func (*DKGMessage) XXX_Size

func (m *DKGMessage) XXX_Size() int

func (*DKGMessage) XXX_Unmarshal

func (m *DKGMessage) XXX_Unmarshal(b []byte) error

type Node

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

func NewNode

func NewNode(rootPath string, endPoint string, seed string, role string) *Node

func (*Node) Start

func (n *Node) Start()

func (*Node) Stop

func (n *Node) Stop()

type NodeMessage

type NodeMessage struct {
	MsgType              NodeMessage_NodeMessageType `protobuf:"varint,1,opt,name=MsgType,proto3,enum=proto.NodeMessage_NodeMessageType" json:"msgType"`
	Data                 []byte                      `protobuf:"bytes,2,opt,name=Data,proto3" json:"data"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*NodeMessage) Descriptor

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

func (*NodeMessage) GetData

func (m *NodeMessage) GetData() []byte

func (*NodeMessage) GetMsgType

func (m *NodeMessage) GetMsgType() NodeMessage_NodeMessageType

func (*NodeMessage) Marshal

func (m *NodeMessage) Marshal() (dAtA []byte, err error)

func (*NodeMessage) MarshalTo

func (m *NodeMessage) MarshalTo(dAtA []byte) (int, error)

func (*NodeMessage) MarshalToSizedBuffer

func (m *NodeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeMessage) ProtoMessage

func (*NodeMessage) ProtoMessage()

func (*NodeMessage) Reset

func (m *NodeMessage) Reset()

func (*NodeMessage) Size

func (m *NodeMessage) Size() (n int)

func (*NodeMessage) String

func (m *NodeMessage) String() string

func (*NodeMessage) Unmarshal

func (m *NodeMessage) Unmarshal(dAtA []byte) error

func (*NodeMessage) XXX_DiscardUnknown

func (m *NodeMessage) XXX_DiscardUnknown()

func (*NodeMessage) XXX_Marshal

func (m *NodeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeMessage) XXX_Merge

func (m *NodeMessage) XXX_Merge(src proto.Message)

func (*NodeMessage) XXX_Size

func (m *NodeMessage) XXX_Size() int

func (*NodeMessage) XXX_Unmarshal

func (m *NodeMessage) XXX_Unmarshal(b []byte) error

type NodeMessage_NodeMessageType

type NodeMessage_NodeMessageType int32

const (
	NodeMessage_Unknown NodeMessage_NodeMessageType = 0
	NodeMessage_DKG     NodeMessage_NodeMessageType = 1
)

func (NodeMessage_NodeMessageType) EnumDescriptor

func (NodeMessage_NodeMessageType) EnumDescriptor() ([]byte, []int)

func (NodeMessage_NodeMessageType) String

func (x NodeMessage_NodeMessageType) String() string