vpp2papi

package
v0.0.0-...-bf055c7 Latest Latest
Warning

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

 Go to latest Published: Dec 6, 2019 License: GPL-3.0 Imports: 4 Imported by: 0

Documentation

Overview

Package vpp2papi defines the p2p (peer to peer) Thrift API.

Index

Constants

View Source 
const DefaultPort = 8777
View Source 
const PackageCopyright = "Copyright (C)  2015, 2016  Christian Mauduit <ufoot@ufoot.org>" // PackageCopyright set by version.sh

PackageCopyright contains a short copyright notice.

View Source 
const PackageEmail = "ufoot@ufoot.org" // PackageEmail set by version.sh

PackageEmail contains a contact email for the package.

View Source 
const PackageLicense = "GNU GPL v3" // PackageLicense set by version.sh

PackageLicense contains a short license information.

View Source 
const PackageName = "Vapor Toolkit" // PackageName set by version.sh

PackageName contains a readable name of the package, suitable for display.

View Source 
const PackageTarname = "vapor" // PackageTarname set by version.sh

PackageTarname contains a short name of the package, suitable for a filename.

View Source 
const PackageURL = "https://github.com/ufoot/vapor" // PackageURL set by version.sh

PackageURL contains the address of the project homepage.

View Source 
const VersionMajor = 0 // VersionMajor set by version.sh

VersionMajor is the project major version.

View Source 
const VersionMinor = 8 // VersionMinor set by version.sh

VersionMinor is the project minor version.

View Source 
const VersionStamp = "c6a4298" // VersionStamp set by version.sh

VersionStamp is the project stamp, possibly changes for each build.

Variables

View Source 
var GoUnusedProtection__ int

Functions

This section is empty.

Types

type ContextInfo 

type ContextInfo struct {
	SourceHost   *HostInfo `thrift:"SourceHost,1" json:"SourceHost"`
	SourceRing   *RingInfo `thrift:"SourceRing,2" json:"SourceRing"`
	SourceNode   *NodeInfo `thrift:"SourceNode,3" json:"SourceNode"`
	TargetNodeID []byte    `thrift:"TargetNodeID,4" json:"TargetNodeID"`
}

ContextInfo contains static informations about the program calling a fonction, it gives context.

Attributes:

  • SourceHost
  • SourceRing
  • SourceNode
  • TargetNodeID
var GetPredecessorRequest_Context_DEFAULT *ContextInfo
var GetSuccessorsRequest_Context_DEFAULT *ContextInfo
var LookupRequest_Context_DEFAULT *ContextInfo
var SyncRequest_Context_DEFAULT *ContextInfo

func NewContextInfo 

func NewContextInfo() *ContextInfo

func (*ContextInfo) GetSourceHost 

func (p *ContextInfo) GetSourceHost() *HostInfo

func (*ContextInfo) GetSourceNode 

func (p *ContextInfo) GetSourceNode() *NodeInfo

func (*ContextInfo) GetSourceRing 

func (p *ContextInfo) GetSourceRing() *RingInfo

func (*ContextInfo) GetTargetNodeID 

func (p *ContextInfo) GetTargetNodeID() []byte

func (*ContextInfo) IsSetSourceHost 

func (p *ContextInfo) IsSetSourceHost() bool

func (*ContextInfo) IsSetSourceNode 

func (p *ContextInfo) IsSetSourceNode() bool

func (*ContextInfo) IsSetSourceRing 

func (p *ContextInfo) IsSetSourceRing() bool

func (*ContextInfo) Read 

func (p *ContextInfo) Read(iprot thrift.TProtocol) error

func (*ContextInfo) String 

func (p *ContextInfo) String() string

func (*ContextInfo) Write 

func (p *ContextInfo) Write(oprot thrift.TProtocol) error

type GetPredecessorRequest 

type GetPredecessorRequest struct {
	Context *ContextInfo `thrift:"Context,1" json:"Context"`
	Sig     []byte       `thrift:"Sig,2" json:"Sig"`
}

Used to store GetPredecessor requests.

Attributes:

  • Context
  • Sig
var VpP2pApiGetPredecessorArgs_Request_DEFAULT *GetPredecessorRequest

func NewGetPredecessorRequest 

func NewGetPredecessorRequest() *GetPredecessorRequest

func (*GetPredecessorRequest) GetContext 

func (p *GetPredecessorRequest) GetContext() *ContextInfo

func (*GetPredecessorRequest) GetSig 

func (p *GetPredecessorRequest) GetSig() []byte

func (*GetPredecessorRequest) IsSetContext 

func (p *GetPredecessorRequest) IsSetContext() bool

func (*GetPredecessorRequest) Read 

func (p *GetPredecessorRequest) Read(iprot thrift.TProtocol) error

func (*GetPredecessorRequest) String 

func (p *GetPredecessorRequest) String() string

func (*GetPredecessorRequest) Write 

func (p *GetPredecessorRequest) Write(oprot thrift.TProtocol) error

type GetPredecessorResponse 

type GetPredecessorResponse struct {
	PredecessorNode *NodeInfo            `thrift:"PredecessorNode,1" json:"PredecessorNode"`
	HostsRefs       map[string]*HostInfo `thrift:"HostsRefs,2" json:"HostsRefs"`
}

Used to store results when doing GetPredecessor requests.

Attributes:

  • PredecessorNode
  • HostsRefs
var VpP2pApiGetPredecessorResult_Success_DEFAULT *GetPredecessorResponse

func NewGetPredecessorResponse 

func NewGetPredecessorResponse() *GetPredecessorResponse

func (*GetPredecessorResponse) GetHostsRefs 

func (p *GetPredecessorResponse) GetHostsRefs() map[string]*HostInfo

func (*GetPredecessorResponse) GetPredecessorNode 

func (p *GetPredecessorResponse) GetPredecessorNode() *NodeInfo

func (*GetPredecessorResponse) IsSetPredecessorNode 

func (p *GetPredecessorResponse) IsSetPredecessorNode() bool

func (*GetPredecessorResponse) Read 

func (p *GetPredecessorResponse) Read(iprot thrift.TProtocol) error

func (*GetPredecessorResponse) String 

func (p *GetPredecessorResponse) String() string

func (*GetPredecessorResponse) Write 

func (p *GetPredecessorResponse) Write(oprot thrift.TProtocol) error

type GetSuccessorsRequest 

type GetSuccessorsRequest struct {
	Context *ContextInfo `thrift:"Context,1" json:"Context"`
	Sig     []byte       `thrift:"Sig,2" json:"Sig"`
}

Used to store GetSuccessors requests.

Attributes:

  • Context
  • Sig
var VpP2pApiGetSuccessorsArgs_Request_DEFAULT *GetSuccessorsRequest

func NewGetSuccessorsRequest 

func NewGetSuccessorsRequest() *GetSuccessorsRequest

func (*GetSuccessorsRequest) GetContext 

func (p *GetSuccessorsRequest) GetContext() *ContextInfo

func (*GetSuccessorsRequest) GetSig 

func (p *GetSuccessorsRequest) GetSig() []byte

func (*GetSuccessorsRequest) IsSetContext 

func (p *GetSuccessorsRequest) IsSetContext() bool

func (*GetSuccessorsRequest) Read 

func (p *GetSuccessorsRequest) Read(iprot thrift.TProtocol) error

func (*GetSuccessorsRequest) String 

func (p *GetSuccessorsRequest) String() string

func (*GetSuccessorsRequest) Write 

func (p *GetSuccessorsRequest) Write(oprot thrift.TProtocol) error

type GetSuccessorsResponse 

type GetSuccessorsResponse struct {
	SuccessorNodes []*NodeInfo          `thrift:"SuccessorNodes,1" json:"SuccessorNodes"`
	HostsRefs      map[string]*HostInfo `thrift:"HostsRefs,2" json:"HostsRefs"`
}

Used to store results when doing GetSuccessors requests.

Attributes:

  • SuccessorNodes
  • HostsRefs
var VpP2pApiGetSuccessorsResult_Success_DEFAULT *GetSuccessorsResponse

func NewGetSuccessorsResponse 

func NewGetSuccessorsResponse() *GetSuccessorsResponse

func (*GetSuccessorsResponse) GetHostsRefs 

func (p *GetSuccessorsResponse) GetHostsRefs() map[string]*HostInfo

func (*GetSuccessorsResponse) GetSuccessorNodes 

func (p *GetSuccessorsResponse) GetSuccessorNodes() []*NodeInfo

func (*GetSuccessorsResponse) Read 

func (p *GetSuccessorsResponse) Read(iprot thrift.TProtocol) error

func (*GetSuccessorsResponse) String 

func (p *GetSuccessorsResponse) String() string

func (*GetSuccessorsResponse) Write 

func (p *GetSuccessorsResponse) Write(oprot thrift.TProtocol) error

type HostInfo 

type HostInfo struct {
	HostTitle  string `thrift:"HostTitle,1" json:"HostTitle"`
	HostURL    string `thrift:"HostURL,2" json:"HostURL"`
	HostPubKey []byte `thrift:"HostPubKey,3" json:"HostPubKey"`
	HostSig    []byte `thrift:"HostSig,4" json:"HostSig"`
}

HostInfo contains static informations about a host.

Attributes:

  • HostTitle
  • HostURL
  • HostPubKey
  • HostSig
var ContextInfo_SourceHost_DEFAULT *HostInfo
var HostStatus_ThisHostInfo_DEFAULT *HostInfo

func NewHostInfo 

func NewHostInfo() *HostInfo

func (*HostInfo) GetHostPubKey 

func (p *HostInfo) GetHostPubKey() []byte

func (*HostInfo) GetHostSig 

func (p *HostInfo) GetHostSig() []byte

func (*HostInfo) GetHostTitle 

func (p *HostInfo) GetHostTitle() string

func (*HostInfo) GetHostURL 

func (p *HostInfo) GetHostURL() string

func (*HostInfo) Read 

func (p *HostInfo) Read(iprot thrift.TProtocol) error

func (*HostInfo) String 

func (p *HostInfo) String() string

func (*HostInfo) Write 

func (p *HostInfo) Write(oprot thrift.TProtocol) error

type HostStatus 

type HostStatus struct {
	ThisHostInfo    *HostInfo            `thrift:"ThisHostInfo,1" json:"ThisHostInfo"`
	LocalNodeStatus []*NodeStatus        `thrift:"LocalNodeStatus,2" json:"LocalNodeStatus"`
	RingsRefs       map[string]*RingInfo `thrift:"RingsRefs,3" json:"RingsRefs"`
	HostsRefs       map[string]*HostInfo `thrift:"HostsRefs,4" json:"HostsRefs"`
}

Used to return data when calling status.

Attributes:

  • ThisHostInfo
  • LocalNodeStatus
  • RingsRefs
  • HostsRefs
var VpP2pApiStatusResult_Success_DEFAULT *HostStatus

func NewHostStatus 

func NewHostStatus() *HostStatus

func (*HostStatus) GetHostsRefs 

func (p *HostStatus) GetHostsRefs() map[string]*HostInfo

func (*HostStatus) GetLocalNodeStatus 

func (p *HostStatus) GetLocalNodeStatus() []*NodeStatus

func (*HostStatus) GetRingsRefs 

func (p *HostStatus) GetRingsRefs() map[string]*RingInfo

func (*HostStatus) GetThisHostInfo 

func (p *HostStatus) GetThisHostInfo() *HostInfo

func (*HostStatus) IsSetThisHostInfo 

func (p *HostStatus) IsSetThisHostInfo() bool

func (*HostStatus) Read 

func (p *HostStatus) Read(iprot thrift.TProtocol) error

func (*HostStatus) String 

func (p *HostStatus) String() string

func (*HostStatus) Write 

func (p *HostStatus) Write(oprot thrift.TProtocol) error

type LookupRequest 

type LookupRequest struct {
	Context       *ContextInfo `thrift:"Context,1" json:"Context"`
	Key           []byte       `thrift:"Key,2" json:"Key"`
	KeyShift      []byte       `thrift:"KeyShift,3" json:"KeyShift"`
	ImaginaryNode []byte       `thrift:"ImaginaryNode,4" json:"ImaginaryNode"`
	Sig           []byte       `thrift:"Sig,5" json:"Sig"`
}

Used to store Lookup-like requests.

Attributes:

  • Context
  • Key
  • KeyShift
  • ImaginaryNode
  • Sig
var VpP2pApiLookupArgs_Request_DEFAULT *LookupRequest

func NewLookupRequest 

func NewLookupRequest() *LookupRequest

func (*LookupRequest) GetContext 

func (p *LookupRequest) GetContext() *ContextInfo

func (*LookupRequest) GetImaginaryNode 

func (p *LookupRequest) GetImaginaryNode() []byte

func (*LookupRequest) GetKey 

func (p *LookupRequest) GetKey() []byte

func (*LookupRequest) GetKeyShift 

func (p *LookupRequest) GetKeyShift() []byte

func (*LookupRequest) GetSig 

func (p *LookupRequest) GetSig() []byte

func (*LookupRequest) IsSetContext 

func (p *LookupRequest) IsSetContext() bool

func (*LookupRequest) Read 

func (p *LookupRequest) Read(iprot thrift.TProtocol) error

func (*LookupRequest) String 

func (p *LookupRequest) String() string

func (*LookupRequest) Write 

func (p *LookupRequest) Write(oprot thrift.TProtocol) error

type LookupResponse 

type LookupResponse struct {
	Found     bool                 `thrift:"Found,1" json:"Found"`
	NodesPath []*NodeInfo          `thrift:"NodesPath,2" json:"NodesPath"`
	HostsRefs map[string]*HostInfo `thrift:"HostsRefs,3" json:"HostsRefs"`
}

Used to store results when doing Lookup-like requests.

Attributes:

  • Found
  • NodesPath
  • HostsRefs
var VpP2pApiLookupResult_Success_DEFAULT *LookupResponse

func NewLookupResponse 

func NewLookupResponse() *LookupResponse

func (*LookupResponse) GetFound 

func (p *LookupResponse) GetFound() bool

func (*LookupResponse) GetHostsRefs 

func (p *LookupResponse) GetHostsRefs() map[string]*HostInfo

func (*LookupResponse) GetNodesPath 

func (p *LookupResponse) GetNodesPath() []*NodeInfo

func (*LookupResponse) Read 

func (p *LookupResponse) Read(iprot thrift.TProtocol) error

func (*LookupResponse) String 

func (p *LookupResponse) String() string

func (*LookupResponse) Write 

func (p *LookupResponse) Write(oprot thrift.TProtocol) error

type NodeInfo 

type NodeInfo struct {
	NodeID     []byte `thrift:"NodeID,1" json:"NodeID"`
	RingID     []byte `thrift:"RingID,2" json:"RingID"`
	HostPubKey []byte `thrift:"HostPubKey,3" json:"HostPubKey"`
	NodeSig    []byte `thrift:"NodeSig,4" json:"NodeSig"`
}

NodeInfo contains static informations about a node.

Attributes:

  • NodeID
  • RingID
  • HostPubKey
  • NodeSig
var ContextInfo_SourceNode_DEFAULT *NodeInfo
var GetPredecessorResponse_PredecessorNode_DEFAULT *NodeInfo
var NodePeers_D_DEFAULT *NodeInfo
var NodeStatus_Info_DEFAULT *NodeInfo
var NodeStatus_Predecessor_DEFAULT *NodeInfo
var SyncResponse_PredecessorNode_DEFAULT *NodeInfo

func NewNodeInfo 

func NewNodeInfo() *NodeInfo

func (*NodeInfo) GetHostPubKey 

func (p *NodeInfo) GetHostPubKey() []byte

func (*NodeInfo) GetNodeID 

func (p *NodeInfo) GetNodeID() []byte

func (*NodeInfo) GetNodeSig 

func (p *NodeInfo) GetNodeSig() []byte

func (*NodeInfo) GetRingID 

func (p *NodeInfo) GetRingID() []byte

func (*NodeInfo) Read 

func (p *NodeInfo) Read(iprot thrift.TProtocol) error

func (*NodeInfo) String 

func (p *NodeInfo) String() string

func (*NodeInfo) Write 

func (p *NodeInfo) Write(oprot thrift.TProtocol) error

type NodePeers 

type NodePeers struct {
	Successors []*NodeInfo `thrift:"Successors,1" json:"Successors"`
	D          *NodeInfo   `thrift:"D,2" json:"D"`
}

NodePeers contains informations about node peers, those it should contact.

Attributes:

  • Successors
  • D
var NodeStatus_Peers_DEFAULT *NodePeers

func NewNodePeers 

func NewNodePeers() *NodePeers

func (*NodePeers) GetD 

func (p *NodePeers) GetD() *NodeInfo

func (*NodePeers) GetSuccessors 

func (p *NodePeers) GetSuccessors() []*NodeInfo

func (*NodePeers) IsSetD 

func (p *NodePeers) IsSetD() bool

func (*NodePeers) Read 

func (p *NodePeers) Read(iprot thrift.TProtocol) error

func (*NodePeers) String 

func (p *NodePeers) String() string

func (*NodePeers) Write 

func (p *NodePeers) Write(oprot thrift.TProtocol) error

type NodeStatus 

type NodeStatus struct {
	Info        *NodeInfo  `thrift:"Info,1" json:"Info"`
	Peers       *NodePeers `thrift:"Peers,2" json:"Peers"`
	Predecessor *NodeInfo  `thrift:"Predecessor,3" json:"Predecessor"`
}

NodeStatus contains details about a node.

Attributes:

  • Info
  • Peers
  • Predecessor

func NewNodeStatus 

func NewNodeStatus() *NodeStatus

func (*NodeStatus) GetInfo 

func (p *NodeStatus) GetInfo() *NodeInfo

func (*NodeStatus) GetPeers 

func (p *NodeStatus) GetPeers() *NodePeers

func (*NodeStatus) GetPredecessor 

func (p *NodeStatus) GetPredecessor() *NodeInfo

func (*NodeStatus) IsSetInfo 

func (p *NodeStatus) IsSetInfo() bool

func (*NodeStatus) IsSetPeers 

func (p *NodeStatus) IsSetPeers() bool

func (*NodeStatus) IsSetPredecessor 

func (p *NodeStatus) IsSetPredecessor() bool

func (*NodeStatus) Read 

func (p *NodeStatus) Read(iprot thrift.TProtocol) error

func (*NodeStatus) String 

func (p *NodeStatus) String() string

func (*NodeStatus) Write 

func (p *NodeStatus) Write(oprot thrift.TProtocol) error

type RingConfig 

type RingConfig struct {
	BruijnM           int32 `thrift:"BruijnM,1" json:"BruijnM"`
	BruijnN           int32 `thrift:"BruijnN,2" json:"BruijnN"`
	NbCopy            int32 `thrift:"NbCopy,3" json:"NbCopy"`
	NbStep            int32 `thrift:"NbStep,4" json:"NbStep"`
	CallTimeout       int32 `thrift:"CallTimeout,5" json:"CallTimeout"`
	SyncDelay         int32 `thrift:"SyncDelay,6" json:"SyncDelay"`
	DisconnectTimeout int32 `thrift:"DisconnectTimeout,7" json:"DisconnectTimeout"`
	DataLifetime      int32 `thrift:"DataLifetime,8" json:"DataLifetime"`
}

RingConfig contains functional parameters of a ring.

Attributes:

  • BruijnM
  • BruijnN
  • NbCopy
  • NbStep
  • CallTimeout
  • SyncDelay
  • DisconnectTimeout
  • DataLifetime
var RingInfo_Config_DEFAULT *RingConfig

func NewRingConfig 

func NewRingConfig() *RingConfig

func (*RingConfig) GetBruijnM 

func (p *RingConfig) GetBruijnM() int32

func (*RingConfig) GetBruijnN 

func (p *RingConfig) GetBruijnN() int32

func (*RingConfig) GetCallTimeout 

func (p *RingConfig) GetCallTimeout() int32

func (*RingConfig) GetDataLifetime 

func (p *RingConfig) GetDataLifetime() int32

func (*RingConfig) GetDisconnectTimeout 

func (p *RingConfig) GetDisconnectTimeout() int32

func (*RingConfig) GetNbCopy 

func (p *RingConfig) GetNbCopy() int32

func (*RingConfig) GetNbStep 

func (p *RingConfig) GetNbStep() int32

func (*RingConfig) GetSyncDelay 

func (p *RingConfig) GetSyncDelay() int32

func (*RingConfig) Read 

func (p *RingConfig) Read(iprot thrift.TProtocol) error

func (*RingConfig) String 

func (p *RingConfig) String() string

func (*RingConfig) Write 

func (p *RingConfig) Write(oprot thrift.TProtocol) error

type RingInfo 

type RingInfo struct {
	RingID          []byte      `thrift:"RingID,1" json:"RingID"`
	RingTitle       string      `thrift:"RingTitle,2" json:"RingTitle"`
	RingDescription string      `thrift:"RingDescription,3" json:"RingDescription"`
	AppID           []byte      `thrift:"AppID,4" json:"AppID"`
	Config          *RingConfig `thrift:"Config,5" json:"Config"`
	HasPassword     bool        `thrift:"HasPassword,6" json:"HasPassword"`
	HostPubKey      []byte      `thrift:"HostPubKey,7" json:"HostPubKey"`
	RingSig         []byte      `thrift:"RingSig,8" json:"RingSig"`
}

RingInfo contains static informations about a ring.

Attributes:

  • RingID
  • RingTitle
  • RingDescription
  • AppID
  • Config
  • HasPassword
  • HostPubKey
  • RingSig
var ContextInfo_SourceRing_DEFAULT *RingInfo

func NewRingInfo 

func NewRingInfo() *RingInfo

func (*RingInfo) GetAppID 

func (p *RingInfo) GetAppID() []byte

func (*RingInfo) GetConfig 

func (p *RingInfo) GetConfig() *RingConfig

func (*RingInfo) GetHasPassword 

func (p *RingInfo) GetHasPassword() bool

func (*RingInfo) GetHostPubKey 

func (p *RingInfo) GetHostPubKey() []byte

func (*RingInfo) GetRingDescription 

func (p *RingInfo) GetRingDescription() string

func (*RingInfo) GetRingID 

func (p *RingInfo) GetRingID() []byte

func (*RingInfo) GetRingSig 

func (p *RingInfo) GetRingSig() []byte

func (*RingInfo) GetRingTitle 

func (p *RingInfo) GetRingTitle() string

func (*RingInfo) IsSetConfig 

func (p *RingInfo) IsSetConfig() bool

func (*RingInfo) Read 

func (p *RingInfo) Read(iprot thrift.TProtocol) error

func (*RingInfo) String 

func (p *RingInfo) String() string

func (*RingInfo) Write 

func (p *RingInfo) Write(oprot thrift.TProtocol) error

type SyncRequest 

type SyncRequest struct {
	Context       *ContextInfo `thrift:"Context,1" json:"Context"`
	KeyShift      []byte       `thrift:"KeyShift,2" json:"KeyShift"`
	ImaginaryNode []byte       `thrift:"ImaginaryNode,3" json:"ImaginaryNode"`
	Sig           []byte       `thrift:"Sig,4" json:"Sig"`
}

Used to store Sync requests.

Attributes:

  • Context
  • KeyShift
  • ImaginaryNode
  • Sig
var VpP2pApiSyncArgs_Request_DEFAULT *SyncRequest

func NewSyncRequest 

func NewSyncRequest() *SyncRequest

func (*SyncRequest) GetContext 

func (p *SyncRequest) GetContext() *ContextInfo

func (*SyncRequest) GetImaginaryNode 

func (p *SyncRequest) GetImaginaryNode() []byte

func (*SyncRequest) GetKeyShift 

func (p *SyncRequest) GetKeyShift() []byte

func (*SyncRequest) GetSig 

func (p *SyncRequest) GetSig() []byte

func (*SyncRequest) IsSetContext 

func (p *SyncRequest) IsSetContext() bool

func (*SyncRequest) Read 

func (p *SyncRequest) Read(iprot thrift.TProtocol) error

func (*SyncRequest) String 

func (p *SyncRequest) String() string

func (*SyncRequest) Write 

func (p *SyncRequest) Write(oprot thrift.TProtocol) error

type SyncResponse 

type SyncResponse struct {
	Found           bool                 `thrift:"Found,1" json:"Found"`
	NodesPath       []*NodeInfo          `thrift:"NodesPath,2" json:"NodesPath"`
	SuccessorNodes  []*NodeInfo          `thrift:"SuccessorNodes,3" json:"SuccessorNodes"`
	PredecessorNode *NodeInfo            `thrift:"PredecessorNode,4" json:"PredecessorNode"`
	HostsRefs       map[string]*HostInfo `thrift:"HostsRefs,5" json:"HostsRefs"`
}

Used to store results when doing Sync requests.

Attributes:

  • Found
  • NodesPath
  • SuccessorNodes
  • PredecessorNode
  • HostsRefs
var VpP2pApiSyncResult_Success_DEFAULT *SyncResponse

func NewSyncResponse 

func NewSyncResponse() *SyncResponse

func (*SyncResponse) GetFound 

func (p *SyncResponse) GetFound() bool

func (*SyncResponse) GetHostsRefs 

func (p *SyncResponse) GetHostsRefs() map[string]*HostInfo

func (*SyncResponse) GetNodesPath 

func (p *SyncResponse) GetNodesPath() []*NodeInfo

func (*SyncResponse) GetPredecessorNode 

func (p *SyncResponse) GetPredecessorNode() *NodeInfo

func (*SyncResponse) GetSuccessorNodes 

func (p *SyncResponse) GetSuccessorNodes() []*NodeInfo

func (*SyncResponse) IsSetPredecessorNode 

func (p *SyncResponse) IsSetPredecessorNode() bool

func (*SyncResponse) Read 

func (p *SyncResponse) Read(iprot thrift.TProtocol) error

func (*SyncResponse) String 

func (p *SyncResponse) String() string

func (*SyncResponse) Write 

func (p *SyncResponse) Write(oprot thrift.TProtocol) error

type VpP2pApi 

type VpP2pApi interface {
	vpcommonapi.VpCommonApi

	Status() (r *HostStatus, err error)
	// Parameters:
	//  - Request
	Lookup(request *LookupRequest) (r *LookupResponse, err error)
	// Parameters:
	//  - Request
	GetSuccessors(request *GetSuccessorsRequest) (r *GetSuccessorsResponse, err error)
	// Parameters:
	//  - Request
	GetPredecessor(request *GetPredecessorRequest) (r *GetPredecessorResponse, err error)
	// Parameters:
	//  - Request
	Sync(request *SyncRequest) (r *SyncResponse, err error)
}

type VpP2pApiClient 

type VpP2pApiClient struct {
	*vpcommonapi.VpCommonApiClient
}

VpP2pApi is used to communicate between 2 Vapor nodes in peer-to-peer mode.

func NewVpP2pApiClientFactory 

func NewVpP2pApiClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *VpP2pApiClient

func NewVpP2pApiClientProtocol 

func NewVpP2pApiClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *VpP2pApiClient

func (*VpP2pApiClient) GetPredecessor 

func (p *VpP2pApiClient) GetPredecessor(request *GetPredecessorRequest) (r *GetPredecessorResponse, err error)

Parameters:

  • Request

func (*VpP2pApiClient) GetSuccessors 

func (p *VpP2pApiClient) GetSuccessors(request *GetSuccessorsRequest) (r *GetSuccessorsResponse, err error)

Parameters:

  • Request

func (*VpP2pApiClient) Lookup 

func (p *VpP2pApiClient) Lookup(request *LookupRequest) (r *LookupResponse, err error)

Parameters:

  • Request

func (*VpP2pApiClient) Status 

func (p *VpP2pApiClient) Status() (r *HostStatus, err error)

func (*VpP2pApiClient) Sync 

func (p *VpP2pApiClient) Sync(request *SyncRequest) (r *SyncResponse, err error)

Parameters:

  • Request

type VpP2pApiGetPredecessorArgs 

type VpP2pApiGetPredecessorArgs struct {
	Request *GetPredecessorRequest `thrift:"request,1" json:"request"`
}

Attributes:

  • Request

func NewVpP2pApiGetPredecessorArgs 

func NewVpP2pApiGetPredecessorArgs() *VpP2pApiGetPredecessorArgs

func (*VpP2pApiGetPredecessorArgs) GetRequest 

func (p *VpP2pApiGetPredecessorArgs) GetRequest() *GetPredecessorRequest

func (*VpP2pApiGetPredecessorArgs) IsSetRequest 

func (p *VpP2pApiGetPredecessorArgs) IsSetRequest() bool

func (*VpP2pApiGetPredecessorArgs) Read 

func (p *VpP2pApiGetPredecessorArgs) Read(iprot thrift.TProtocol) error

func (*VpP2pApiGetPredecessorArgs) String 

func (p *VpP2pApiGetPredecessorArgs) String() string

func (*VpP2pApiGetPredecessorArgs) Write 

func (p *VpP2pApiGetPredecessorArgs) Write(oprot thrift.TProtocol) error

type VpP2pApiGetPredecessorResult 

type VpP2pApiGetPredecessorResult struct {
	Success *GetPredecessorResponse `thrift:"success,0" json:"success,omitempty"`
}

Attributes:

  • Success

func NewVpP2pApiGetPredecessorResult 

func NewVpP2pApiGetPredecessorResult() *VpP2pApiGetPredecessorResult

func (*VpP2pApiGetPredecessorResult) GetSuccess 

func (p *VpP2pApiGetPredecessorResult) GetSuccess() *GetPredecessorResponse

func (*VpP2pApiGetPredecessorResult) IsSetSuccess 

func (p *VpP2pApiGetPredecessorResult) IsSetSuccess() bool

func (*VpP2pApiGetPredecessorResult) Read 

func (p *VpP2pApiGetPredecessorResult) Read(iprot thrift.TProtocol) error

func (*VpP2pApiGetPredecessorResult) String 

func (p *VpP2pApiGetPredecessorResult) String() string

func (*VpP2pApiGetPredecessorResult) Write 

func (p *VpP2pApiGetPredecessorResult) Write(oprot thrift.TProtocol) error

type VpP2pApiGetSuccessorsArgs 

type VpP2pApiGetSuccessorsArgs struct {
	Request *GetSuccessorsRequest `thrift:"request,1" json:"request"`
}

Attributes:

  • Request

func NewVpP2pApiGetSuccessorsArgs 

func NewVpP2pApiGetSuccessorsArgs() *VpP2pApiGetSuccessorsArgs

func (*VpP2pApiGetSuccessorsArgs) GetRequest 

func (p *VpP2pApiGetSuccessorsArgs) GetRequest() *GetSuccessorsRequest

func (*VpP2pApiGetSuccessorsArgs) IsSetRequest 

func (p *VpP2pApiGetSuccessorsArgs) IsSetRequest() bool

func (*VpP2pApiGetSuccessorsArgs) Read 

func (p *VpP2pApiGetSuccessorsArgs) Read(iprot thrift.TProtocol) error

func (*VpP2pApiGetSuccessorsArgs) String 

func (p *VpP2pApiGetSuccessorsArgs) String() string

func (*VpP2pApiGetSuccessorsArgs) Write 

func (p *VpP2pApiGetSuccessorsArgs) Write(oprot thrift.TProtocol) error

type VpP2pApiGetSuccessorsResult 

type VpP2pApiGetSuccessorsResult struct {
	Success *GetSuccessorsResponse `thrift:"success,0" json:"success,omitempty"`
}

Attributes:

  • Success

func NewVpP2pApiGetSuccessorsResult 

func NewVpP2pApiGetSuccessorsResult() *VpP2pApiGetSuccessorsResult

func (*VpP2pApiGetSuccessorsResult) GetSuccess 

func (p *VpP2pApiGetSuccessorsResult) GetSuccess() *GetSuccessorsResponse

func (*VpP2pApiGetSuccessorsResult) IsSetSuccess 

func (p *VpP2pApiGetSuccessorsResult) IsSetSuccess() bool

func (*VpP2pApiGetSuccessorsResult) Read 

func (p *VpP2pApiGetSuccessorsResult) Read(iprot thrift.TProtocol) error

func (*VpP2pApiGetSuccessorsResult) String 

func (p *VpP2pApiGetSuccessorsResult) String() string

func (*VpP2pApiGetSuccessorsResult) Write 

func (p *VpP2pApiGetSuccessorsResult) Write(oprot thrift.TProtocol) error

type VpP2pApiLookupArgs 

type VpP2pApiLookupArgs struct {
	Request *LookupRequest `thrift:"request,1" json:"request"`
}

Attributes:

  • Request

func NewVpP2pApiLookupArgs 

func NewVpP2pApiLookupArgs() *VpP2pApiLookupArgs

func (*VpP2pApiLookupArgs) GetRequest 

func (p *VpP2pApiLookupArgs) GetRequest() *LookupRequest

func (*VpP2pApiLookupArgs) IsSetRequest 

func (p *VpP2pApiLookupArgs) IsSetRequest() bool

func (*VpP2pApiLookupArgs) Read 

func (p *VpP2pApiLookupArgs) Read(iprot thrift.TProtocol) error

func (*VpP2pApiLookupArgs) String 

func (p *VpP2pApiLookupArgs) String() string

func (*VpP2pApiLookupArgs) Write 

func (p *VpP2pApiLookupArgs) Write(oprot thrift.TProtocol) error

type VpP2pApiLookupResult 

type VpP2pApiLookupResult struct {
	Success *LookupResponse `thrift:"success,0" json:"success,omitempty"`
}

Attributes:

  • Success

func NewVpP2pApiLookupResult 

func NewVpP2pApiLookupResult() *VpP2pApiLookupResult

func (*VpP2pApiLookupResult) GetSuccess 

func (p *VpP2pApiLookupResult) GetSuccess() *LookupResponse

func (*VpP2pApiLookupResult) IsSetSuccess 

func (p *VpP2pApiLookupResult) IsSetSuccess() bool

func (*VpP2pApiLookupResult) Read 

func (p *VpP2pApiLookupResult) Read(iprot thrift.TProtocol) error

func (*VpP2pApiLookupResult) String 

func (p *VpP2pApiLookupResult) String() string

func (*VpP2pApiLookupResult) Write 

func (p *VpP2pApiLookupResult) Write(oprot thrift.TProtocol) error

type VpP2pApiProcessor 

type VpP2pApiProcessor struct {
	*vpcommonapi.VpCommonApiProcessor
}

func NewVpP2pApiProcessor 

func NewVpP2pApiProcessor(handler VpP2pApi) *VpP2pApiProcessor

type VpP2pApiStatusArgs 

type VpP2pApiStatusArgs struct {
}

func NewVpP2pApiStatusArgs 

func NewVpP2pApiStatusArgs() *VpP2pApiStatusArgs

func (*VpP2pApiStatusArgs) Read 

func (p *VpP2pApiStatusArgs) Read(iprot thrift.TProtocol) error

func (*VpP2pApiStatusArgs) String 

func (p *VpP2pApiStatusArgs) String() string

func (*VpP2pApiStatusArgs) Write 

func (p *VpP2pApiStatusArgs) Write(oprot thrift.TProtocol) error

type VpP2pApiStatusResult 

type VpP2pApiStatusResult struct {
	Success *HostStatus `thrift:"success,0" json:"success,omitempty"`
}

Attributes:

  • Success

func NewVpP2pApiStatusResult 

func NewVpP2pApiStatusResult() *VpP2pApiStatusResult

func (*VpP2pApiStatusResult) GetSuccess 

func (p *VpP2pApiStatusResult) GetSuccess() *HostStatus

func (*VpP2pApiStatusResult) IsSetSuccess 

func (p *VpP2pApiStatusResult) IsSetSuccess() bool

func (*VpP2pApiStatusResult) Read 

func (p *VpP2pApiStatusResult) Read(iprot thrift.TProtocol) error

func (*VpP2pApiStatusResult) String 

func (p *VpP2pApiStatusResult) String() string

func (*VpP2pApiStatusResult) Write 

func (p *VpP2pApiStatusResult) Write(oprot thrift.TProtocol) error

type VpP2pApiSyncArgs 

type VpP2pApiSyncArgs struct {
	Request *SyncRequest `thrift:"request,1" json:"request"`
}

Attributes:

  • Request

func NewVpP2pApiSyncArgs 

func NewVpP2pApiSyncArgs() *VpP2pApiSyncArgs

func (*VpP2pApiSyncArgs) GetRequest 

func (p *VpP2pApiSyncArgs) GetRequest() *SyncRequest

func (*VpP2pApiSyncArgs) IsSetRequest 

func (p *VpP2pApiSyncArgs) IsSetRequest() bool

func (*VpP2pApiSyncArgs) Read 

func (p *VpP2pApiSyncArgs) Read(iprot thrift.TProtocol) error

func (*VpP2pApiSyncArgs) String 

func (p *VpP2pApiSyncArgs) String() string

func (*VpP2pApiSyncArgs) Write 

func (p *VpP2pApiSyncArgs) Write(oprot thrift.TProtocol) error

type VpP2pApiSyncResult 

type VpP2pApiSyncResult struct {
	Success *SyncResponse `thrift:"success,0" json:"success,omitempty"`
}

Attributes:

  • Success

func NewVpP2pApiSyncResult 

func NewVpP2pApiSyncResult() *VpP2pApiSyncResult

func (*VpP2pApiSyncResult) GetSuccess 

func (p *VpP2pApiSyncResult) GetSuccess() *SyncResponse

func (*VpP2pApiSyncResult) IsSetSuccess 

func (p *VpP2pApiSyncResult) IsSetSuccess() bool

func (*VpP2pApiSyncResult) Read 

func (p *VpP2pApiSyncResult) Read(iprot thrift.TProtocol) error

func (*VpP2pApiSyncResult) String 

func (p *VpP2pApiSyncResult) String() string

func (*VpP2pApiSyncResult) Write 

func (p *VpP2pApiSyncResult) Write(oprot thrift.TProtocol) 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.