rpc

package
v0.0.0-...-97f3c37 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PacketType_name = map[int32]string{
		0: "TransT",
		1: "BlockT",
	}
	PacketType_value = map[string]int32{
		"TransT": 0,
		"BlockT": 1,
	}
)

Enum value maps for PacketType.

View Source 
var File_rpc_rpc_proto protoreflect.FileDescriptor
View Source 
var Koorde_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.Koorde",
	HandlerType: (*KoordeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BootStarpRPC",
			Handler:    _Koorde_BootStarpRPC_Handler,
		},
		{
			MethodName: "BroadCastRPC",
			Handler:    _Koorde_BroadCastRPC_Handler,
		},
		{
			MethodName: "LookupRPC",
			Handler:    _Koorde_LookupRPC_Handler,
		},
		{
			MethodName: "GetSuccessorRPC",
			Handler:    _Koorde_GetSuccessorRPC_Handler,
		},
		{
			MethodName: "GetPredecessorRPC",
			Handler:    _Koorde_GetPredecessorRPC_Handler,
		},
		{
			MethodName: "UpdatePredecessorRPC",
			Handler:    _Koorde_UpdatePredecessorRPC_Handler,
		},
		{
			MethodName: "UpdateSuccessorRPC",
			Handler:    _Koorde_UpdateSuccessorRPC_Handler,
		},
		{
			MethodName: "NotifyRPC",
			Handler:    _Koorde_NotifyRPC_Handler,
		},
		{
			MethodName: "UpdateDPointerRPC",
			Handler:    _Koorde_UpdateDPointerRPC_Handler,
		},
		{
			MethodName: "AddDParentRPC",
			Handler:    _Koorde_AddDParentRPC_Handler,
		},
		{
			MethodName: "RemoveDParentRPC",
			Handler:    _Koorde_RemoveDParentRPC_Handler,
		},
		{
			MethodName: "InitBroadCastRPC",
			Handler:    _Koorde_InitBroadCastRPC_Handler,
		},
		{
			MethodName: "DGetBlocks",
			Handler:    _Koorde_DGetBlocks_Handler,
		},
		{
			MethodName: "DJoin",
			Handler:    _Koorde_DJoin_Handler,
		},
		{
			MethodName: "DSetSuccessor",
			Handler:    _Koorde_DSetSuccessor_Handler,
		},
		{
			MethodName: "DSetD",
			Handler:    _Koorde_DSetD_Handler,
		},
		{
			MethodName: "DGetID",
			Handler:    _Koorde_DGetID_Handler,
		},
		{
			MethodName: "DGetPointers",
			Handler:    _Koorde_DGetPointers_Handler,
		},
		{
			MethodName: "DLKup",
			Handler:    _Koorde_DLKup_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpc/rpc.proto",
}

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

Functions

func RegisterKoordeServer 

func RegisterKoordeServer(s grpc.ServiceRegistrar, srv KoordeServer)

Types

type Block 

type Block struct {
	PreviousHash      string         `protobuf:"bytes,1,opt,name=PreviousHash,proto3" json:"PreviousHash,omitempty"`
	Slot              int32          `protobuf:"varint,2,opt,name=Slot,proto3" json:"Slot,omitempty"`
	VrfOutput         string         `protobuf:"bytes,3,opt,name=VrfOutput,proto3" json:"VrfOutput,omitempty"`
	VrfProof          string         `protobuf:"bytes,4,opt,name=VrfProof,proto3" json:"VrfProof,omitempty"`
	SlotLeader        string         `protobuf:"bytes,5,opt,name=SlotLeader,proto3" json:"SlotLeader,omitempty"`
	Transactions      []*Transaction `protobuf:"bytes,6,rep,name=Transactions,proto3" json:"Transactions,omitempty"`
	Nonce             string         `protobuf:"bytes,7,opt,name=Nonce,proto3" json:"Nonce,omitempty"`
	StakeDistribution []*StackHolder `protobuf:"bytes,8,rep,name=StakeDistribution,proto3" json:"StakeDistribution,omitempty"`
	Signature         string         `protobuf:"bytes,10,opt,name=Signature,proto3" json:"Signature,omitempty"`
	// contains filtered or unexported fields
}

func (*Block) Descriptor deprecated 

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

Deprecated: Use Block.ProtoReflect.Descriptor instead.

func (*Block) GetNonce 

func (x *Block) GetNonce() string

func (*Block) GetPreviousHash 

func (x *Block) GetPreviousHash() string

func (*Block) GetSignature 

func (x *Block) GetSignature() string

func (*Block) GetSlot 

func (x *Block) GetSlot() int32

func (*Block) GetSlotLeader 

func (x *Block) GetSlotLeader() string

func (*Block) GetStakeDistribution 

func (x *Block) GetStakeDistribution() []*StackHolder

func (*Block) GetTransactions 

func (x *Block) GetTransactions() []*Transaction

func (*Block) GetVrfOutput 

func (x *Block) GetVrfOutput() string

func (*Block) GetVrfProof 

func (x *Block) GetVrfProof() string

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) ProtoReflect 

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

func (*Block) Reset 

func (x *Block) Reset()

func (*Block) String 

func (x *Block) String() string

type BlocksPacket 

type BlocksPacket struct {
	Block []*Block `protobuf:"bytes,1,rep,name=block,proto3" json:"block,omitempty"`
	// contains filtered or unexported fields
}

func (*BlocksPacket) Descriptor deprecated 

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

Deprecated: Use BlocksPacket.ProtoReflect.Descriptor instead.

func (*BlocksPacket) GetBlock 

func (x *BlocksPacket) GetBlock() []*Block

func (*BlocksPacket) ProtoMessage 

func (*BlocksPacket) ProtoMessage()

func (*BlocksPacket) ProtoReflect 

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

func (*BlocksPacket) Reset 

func (x *BlocksPacket) Reset()

func (*BlocksPacket) String 

func (x *BlocksPacket) String() string

type BootStrapPacket 

type BootStrapPacket struct {
	SrcId string `protobuf:"bytes,1,opt,name=src_id,json=srcId,proto3" json:"src_id,omitempty"`
	SrcIp string `protobuf:"bytes,2,opt,name=src_ip,json=srcIp,proto3" json:"src_ip,omitempty"`
	// contains filtered or unexported fields
}

func (*BootStrapPacket) Descriptor deprecated 

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

Deprecated: Use BootStrapPacket.ProtoReflect.Descriptor instead.

func (*BootStrapPacket) GetSrcId 

func (x *BootStrapPacket) GetSrcId() string

func (*BootStrapPacket) GetSrcIp 

func (x *BootStrapPacket) GetSrcIp() string

func (*BootStrapPacket) ProtoMessage 

func (*BootStrapPacket) ProtoMessage()

func (*BootStrapPacket) ProtoReflect 

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

func (*BootStrapPacket) Reset 

func (x *BootStrapPacket) Reset()

func (*BootStrapPacket) String 

func (x *BootStrapPacket) String() string

type BootStrapReply 

type BootStrapReply struct {
	Successor *PeerPacket `protobuf:"bytes,1,opt,name=Successor,proto3" json:"Successor,omitempty"`
	D         *PeerPacket `protobuf:"bytes,2,opt,name=D,proto3" json:"D,omitempty"`
	// contains filtered or unexported fields
}

func (*BootStrapReply) Descriptor deprecated 

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

Deprecated: Use BootStrapReply.ProtoReflect.Descriptor instead.

func (*BootStrapReply) GetD 

func (x *BootStrapReply) GetD() *PeerPacket

func (*BootStrapReply) GetSuccessor 

func (x *BootStrapReply) GetSuccessor() *PeerPacket

func (*BootStrapReply) ProtoMessage 

func (*BootStrapReply) ProtoMessage()

func (*BootStrapReply) ProtoReflect 

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

func (*BootStrapReply) Reset 

func (x *BootStrapReply) Reset()

func (*BootStrapReply) String 

func (x *BootStrapReply) String() string

type BroadCastPacket 

type BroadCastPacket struct {
	Type  PacketType   `protobuf:"varint,1,opt,name=Type,proto3,enum=rpc.PacketType" json:"Type,omitempty"`
	Block *Block       `protobuf:"bytes,2,opt,name=Block,proto3" json:"Block,omitempty"`
	Trans *Transaction `protobuf:"bytes,3,opt,name=Trans,proto3" json:"Trans,omitempty"`
	Limit string       `protobuf:"bytes,4,opt,name=Limit,proto3" json:"Limit,omitempty"`
	// contains filtered or unexported fields
}

func (*BroadCastPacket) Descriptor deprecated 

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

Deprecated: Use BroadCastPacket.ProtoReflect.Descriptor instead.

func (*BroadCastPacket) GetBlock 

func (x *BroadCastPacket) GetBlock() *Block

func (*BroadCastPacket) GetLimit 

func (x *BroadCastPacket) GetLimit() string

func (*BroadCastPacket) GetTrans 

func (x *BroadCastPacket) GetTrans() *Transaction

func (*BroadCastPacket) GetType 

func (x *BroadCastPacket) GetType() PacketType

func (*BroadCastPacket) ProtoMessage 

func (*BroadCastPacket) ProtoMessage()

func (*BroadCastPacket) ProtoReflect 

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

func (*BroadCastPacket) Reset 

func (x *BroadCastPacket) Reset()

func (*BroadCastPacket) String 

func (x *BroadCastPacket) String() string

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type KoordeClient 

type KoordeClient interface {
	BootStarpRPC(ctx context.Context, in *BootStrapPacket, opts ...grpc.CallOption) (*BootStrapReply, error)
	BroadCastRPC(ctx context.Context, in *BroadCastPacket, opts ...grpc.CallOption) (*Empty, error)
	LookupRPC(ctx context.Context, in *LookupPacket, opts ...grpc.CallOption) (*PeerPacket, error)
	GetSuccessorRPC(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PeerPacket, error)
	GetPredecessorRPC(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PeerPacket, error)
	// UpdatePredecessor takes new pred and returns the old one
	UpdatePredecessorRPC(ctx context.Context, in *PeerPacket, opts ...grpc.CallOption) (*PeerPacket, error)
	// UpdateSuccessor takes new succ and retursn the Dpointer parents that the
	// new node should contact
	UpdateSuccessorRPC(ctx context.Context, in *PeerListPacket, opts ...grpc.CallOption) (*PeerListPacket, error)
	// UpdateDPointer updates the Dpointer with new successor that should handel
	NotifyRPC(ctx context.Context, in *PeerPacket, opts ...grpc.CallOption) (*Empty, error)
	UpdateDPointerRPC(ctx context.Context, in *PeerPacket, opts ...grpc.CallOption) (*Empty, error)
	AddDParentRPC(ctx context.Context, in *PeerPacket, opts ...grpc.CallOption) (*Empty, error)
	RemoveDParentRPC(ctx context.Context, in *PeerPacket, opts ...grpc.CallOption) (*Empty, error)
	// DEBUG RPCS
	InitBroadCastRPC(ctx context.Context, in *BroadCastPacket, opts ...grpc.CallOption) (*Empty, error)
	DGetBlocks(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*BlocksPacket, error)
	DJoin(ctx context.Context, in *PeerPacket, opts ...grpc.CallOption) (*Empty, error)
	DSetSuccessor(ctx context.Context, in *PeerPacket, opts ...grpc.CallOption) (*Empty, error)
	DSetD(ctx context.Context, in *PeerPacket, opts ...grpc.CallOption) (*Empty, error)
	DGetID(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PeerPacket, error)
	DGetPointers(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Pointers, error)
	DLKup(ctx context.Context, in *PeerPacket, opts ...grpc.CallOption) (*PeerPacket, error)
}

KoordeClient is the client API for Koorde 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 NewKoordeClient 

func NewKoordeClient(cc grpc.ClientConnInterface) KoordeClient

type KoordeServer 

type KoordeServer interface {
	BootStarpRPC(context.Context, *BootStrapPacket) (*BootStrapReply, error)
	BroadCastRPC(context.Context, *BroadCastPacket) (*Empty, error)
	LookupRPC(context.Context, *LookupPacket) (*PeerPacket, error)
	GetSuccessorRPC(context.Context, *Empty) (*PeerPacket, error)
	GetPredecessorRPC(context.Context, *Empty) (*PeerPacket, error)
	// UpdatePredecessor takes new pred and returns the old one
	UpdatePredecessorRPC(context.Context, *PeerPacket) (*PeerPacket, error)
	// UpdateSuccessor takes new succ and retursn the Dpointer parents that the
	// new node should contact
	UpdateSuccessorRPC(context.Context, *PeerListPacket) (*PeerListPacket, error)
	// UpdateDPointer updates the Dpointer with new successor that should handel
	NotifyRPC(context.Context, *PeerPacket) (*Empty, error)
	UpdateDPointerRPC(context.Context, *PeerPacket) (*Empty, error)
	AddDParentRPC(context.Context, *PeerPacket) (*Empty, error)
	RemoveDParentRPC(context.Context, *PeerPacket) (*Empty, error)
	// DEBUG RPCS
	InitBroadCastRPC(context.Context, *BroadCastPacket) (*Empty, error)
	DGetBlocks(context.Context, *Empty) (*BlocksPacket, error)
	DJoin(context.Context, *PeerPacket) (*Empty, error)
	DSetSuccessor(context.Context, *PeerPacket) (*Empty, error)
	DSetD(context.Context, *PeerPacket) (*Empty, error)
	DGetID(context.Context, *Empty) (*PeerPacket, error)
	DGetPointers(context.Context, *Empty) (*Pointers, error)
	DLKup(context.Context, *PeerPacket) (*PeerPacket, error)
	// contains filtered or unexported methods
}

KoordeServer is the server API for Koorde service. All implementations must embed UnimplementedKoordeServer for forward compatibility

type LookupPacket 

type LookupPacket struct {
	SrcId  string `protobuf:"bytes,1,opt,name=src_id,json=srcId,proto3" json:"src_id,omitempty"`
	SrcIp  string `protobuf:"bytes,2,opt,name=src_ip,json=srcIp,proto3" json:"src_ip,omitempty"`
	K      string `protobuf:"bytes,3,opt,name=k,proto3" json:"k,omitempty"`
	KShift string `protobuf:"bytes,4,opt,name=kShift,proto3" json:"kShift,omitempty"`
	I      string `protobuf:"bytes,5,opt,name=i,proto3" json:"i,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupPacket) Descriptor deprecated 

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

Deprecated: Use LookupPacket.ProtoReflect.Descriptor instead.

func (*LookupPacket) GetI 

func (x *LookupPacket) GetI() string

func (*LookupPacket) GetK 

func (x *LookupPacket) GetK() string

func (*LookupPacket) GetKShift 

func (x *LookupPacket) GetKShift() string

func (*LookupPacket) GetSrcId 

func (x *LookupPacket) GetSrcId() string

func (*LookupPacket) GetSrcIp 

func (x *LookupPacket) GetSrcIp() string

func (*LookupPacket) ProtoMessage 

func (*LookupPacket) ProtoMessage()

func (*LookupPacket) ProtoReflect 

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

func (*LookupPacket) Reset 

func (x *LookupPacket) Reset()

func (*LookupPacket) String 

func (x *LookupPacket) String() string

type PacketType 

type PacketType int32
const (
	PacketType_TransT PacketType = 0
	PacketType_BlockT PacketType = 1
)

func (PacketType) Descriptor 

func (PacketType) Descriptor() protoreflect.EnumDescriptor

func (PacketType) Enum 

func (x PacketType) Enum() *PacketType

func (PacketType) EnumDescriptor deprecated 

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

Deprecated: Use PacketType.Descriptor instead.

func (PacketType) Number 

func (x PacketType) Number() protoreflect.EnumNumber

func (PacketType) String 

func (x PacketType) String() string

func (PacketType) Type 

func (PacketType) Type() protoreflect.EnumType

type PeerListPacket 

type PeerListPacket struct {
	Peers []*PeerPacket `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

func (*PeerListPacket) Descriptor deprecated 

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

Deprecated: Use PeerListPacket.ProtoReflect.Descriptor instead.

func (*PeerListPacket) GetPeers 

func (x *PeerListPacket) GetPeers() []*PeerPacket

func (*PeerListPacket) ProtoMessage 

func (*PeerListPacket) ProtoMessage()

func (*PeerListPacket) ProtoReflect 

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

func (*PeerListPacket) Reset 

func (x *PeerListPacket) Reset()

func (*PeerListPacket) String 

func (x *PeerListPacket) String() string

type PeerPacket 

type PeerPacket struct {
	SrcId    string   `protobuf:"bytes,1,opt,name=src_id,json=srcId,proto3" json:"src_id,omitempty"`
	SrcIp    string   `protobuf:"bytes,2,opt,name=src_ip,json=srcIp,proto3" json:"src_ip,omitempty"`
	Start    string   `protobuf:"bytes,3,opt,name=start,proto3" json:"start,omitempty"`
	Interval []string `protobuf:"bytes,4,rep,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*PeerPacket) Descriptor deprecated 

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

Deprecated: Use PeerPacket.ProtoReflect.Descriptor instead.

func (*PeerPacket) GetInterval 

func (x *PeerPacket) GetInterval() []string

func (*PeerPacket) GetSrcId 

func (x *PeerPacket) GetSrcId() string

func (*PeerPacket) GetSrcIp 

func (x *PeerPacket) GetSrcIp() string

func (*PeerPacket) GetStart 

func (x *PeerPacket) GetStart() string

func (*PeerPacket) ProtoMessage 

func (*PeerPacket) ProtoMessage()

func (*PeerPacket) ProtoReflect 

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

func (*PeerPacket) Reset 

func (x *PeerPacket) Reset()

func (*PeerPacket) String 

func (x *PeerPacket) String() string

type Pointers 

type Pointers struct {
	Succ string `protobuf:"bytes,1,opt,name=succ,proto3" json:"succ,omitempty"`
	D    string `protobuf:"bytes,2,opt,name=d,proto3" json:"d,omitempty"`
	// contains filtered or unexported fields
}

DEBUG MSGs

func (*Pointers) Descriptor deprecated 

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

Deprecated: Use Pointers.ProtoReflect.Descriptor instead.

func (*Pointers) GetD 

func (x *Pointers) GetD() string

func (*Pointers) GetSucc 

func (x *Pointers) GetSucc() string

func (*Pointers) ProtoMessage 

func (*Pointers) ProtoMessage()

func (*Pointers) ProtoReflect 

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

func (*Pointers) Reset 

func (x *Pointers) Reset()

func (*Pointers) String 

func (x *Pointers) String() string

type StackHolder 

type StackHolder struct {
	PublickKey string  `protobuf:"bytes,1,opt,name=PublickKey,proto3" json:"PublickKey,omitempty"`
	Stack      float64 `protobuf:"fixed64,2,opt,name=Stack,proto3" json:"Stack,omitempty"`
	// contains filtered or unexported fields
}

func (*StackHolder) Descriptor deprecated 

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

Deprecated: Use StackHolder.ProtoReflect.Descriptor instead.

func (*StackHolder) GetPublickKey 

func (x *StackHolder) GetPublickKey() string

func (*StackHolder) GetStack 

func (x *StackHolder) GetStack() float64

func (*StackHolder) ProtoMessage 

func (*StackHolder) ProtoMessage()

func (*StackHolder) ProtoReflect 

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

func (*StackHolder) Reset 

func (x *StackHolder) Reset()

func (*StackHolder) String 

func (x *StackHolder) String() string

type Transaction 

type Transaction struct {
	Nonce           uint64 `protobuf:"varint,1,opt,name=Nonce,proto3" json:"Nonce,omitempty"`
	From            string `protobuf:"bytes,2,opt,name=From,proto3" json:"From,omitempty"`
	To              string `protobuf:"bytes,3,opt,name=To,proto3" json:"To,omitempty"`
	Amount          uint64 `protobuf:"varint,4,opt,name=Amount,proto3" json:"Amount,omitempty"`
	Timestamp       string `protobuf:"bytes,5,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	ContractCode    []byte `protobuf:"bytes,6,opt,name=ContractCode,proto3" json:"ContractCode,omitempty"`
	GasPrice        uint64 `protobuf:"varint,7,opt,name=GasPrice,proto3" json:"GasPrice,omitempty"`
	GasLimit        uint64 `protobuf:"varint,8,opt,name=GasLimit,proto3" json:"GasLimit,omitempty"`
	ContractAddress string `protobuf:"bytes,9,opt,name=ContractAddress,proto3" json:"ContractAddress,omitempty"`
	Signature       string `protobuf:"bytes,10,opt,name=Signature,proto3" json:"Signature,omitempty"`
	// contains filtered or unexported fields
}

func (*Transaction) Descriptor deprecated 

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

Deprecated: Use Transaction.ProtoReflect.Descriptor instead.

func (*Transaction) GetAmount 

func (x *Transaction) GetAmount() uint64

func (*Transaction) GetContractAddress 

func (x *Transaction) GetContractAddress() string

func (*Transaction) GetContractCode 

func (x *Transaction) GetContractCode() []byte

func (*Transaction) GetFrom 

func (x *Transaction) GetFrom() string

func (*Transaction) GetGasLimit 

func (x *Transaction) GetGasLimit() uint64

func (*Transaction) GetGasPrice 

func (x *Transaction) GetGasPrice() uint64

func (*Transaction) GetNonce 

func (x *Transaction) GetNonce() uint64

func (*Transaction) GetSignature 

func (x *Transaction) GetSignature() string

func (*Transaction) GetTimestamp 

func (x *Transaction) GetTimestamp() string

func (*Transaction) GetTo 

func (x *Transaction) GetTo() string

func (*Transaction) ProtoMessage 

func (*Transaction) ProtoMessage()

func (*Transaction) ProtoReflect 

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

func (*Transaction) Reset 

func (x *Transaction) Reset()

func (*Transaction) String 

func (x *Transaction) String() string

type UnimplementedKoordeServer 

type UnimplementedKoordeServer struct {
}

UnimplementedKoordeServer must be embedded to have forward compatible implementations.

func (UnimplementedKoordeServer) AddDParentRPC 

func (UnimplementedKoordeServer) AddDParentRPC(context.Context, *PeerPacket) (*Empty, error)

func (UnimplementedKoordeServer) BootStarpRPC 

func (UnimplementedKoordeServer) BootStarpRPC(context.Context, *BootStrapPacket) (*BootStrapReply, error)

func (UnimplementedKoordeServer) BroadCastRPC 

func (UnimplementedKoordeServer) BroadCastRPC(context.Context, *BroadCastPacket) (*Empty, error)

func (UnimplementedKoordeServer) DGetBlocks 

func (UnimplementedKoordeServer) DGetBlocks(context.Context, *Empty) (*BlocksPacket, error)

func (UnimplementedKoordeServer) DGetID 

func (UnimplementedKoordeServer) DGetID(context.Context, *Empty) (*PeerPacket, error)

func (UnimplementedKoordeServer) DGetPointers 

func (UnimplementedKoordeServer) DGetPointers(context.Context, *Empty) (*Pointers, error)

func (UnimplementedKoordeServer) DJoin 

func (UnimplementedKoordeServer) DJoin(context.Context, *PeerPacket) (*Empty, error)

func (UnimplementedKoordeServer) DLKup 

func (UnimplementedKoordeServer) DLKup(context.Context, *PeerPacket) (*PeerPacket, error)

func (UnimplementedKoordeServer) DSetD 

func (UnimplementedKoordeServer) DSetD(context.Context, *PeerPacket) (*Empty, error)

func (UnimplementedKoordeServer) DSetSuccessor 

func (UnimplementedKoordeServer) DSetSuccessor(context.Context, *PeerPacket) (*Empty, error)

func (UnimplementedKoordeServer) GetPredecessorRPC 

func (UnimplementedKoordeServer) GetPredecessorRPC(context.Context, *Empty) (*PeerPacket, error)

func (UnimplementedKoordeServer) GetSuccessorRPC 

func (UnimplementedKoordeServer) GetSuccessorRPC(context.Context, *Empty) (*PeerPacket, error)

func (UnimplementedKoordeServer) InitBroadCastRPC 

func (UnimplementedKoordeServer) InitBroadCastRPC(context.Context, *BroadCastPacket) (*Empty, error)

func (UnimplementedKoordeServer) LookupRPC 

func (UnimplementedKoordeServer) LookupRPC(context.Context, *LookupPacket) (*PeerPacket, error)

func (UnimplementedKoordeServer) NotifyRPC 

func (UnimplementedKoordeServer) NotifyRPC(context.Context, *PeerPacket) (*Empty, error)

func (UnimplementedKoordeServer) RemoveDParentRPC 

func (UnimplementedKoordeServer) RemoveDParentRPC(context.Context, *PeerPacket) (*Empty, error)

func (UnimplementedKoordeServer) UpdateDPointerRPC 

func (UnimplementedKoordeServer) UpdateDPointerRPC(context.Context, *PeerPacket) (*Empty, error)

func (UnimplementedKoordeServer) UpdatePredecessorRPC 

func (UnimplementedKoordeServer) UpdatePredecessorRPC(context.Context, *PeerPacket) (*PeerPacket, error)

func (UnimplementedKoordeServer) UpdateSuccessorRPC 

func (UnimplementedKoordeServer) UpdateSuccessorRPC(context.Context, *PeerListPacket) (*PeerListPacket, error)

type UnsafeKoordeServer 

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

UnsafeKoordeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KoordeServer 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.