nebula

type Agent struct {
	agentclient.Client
}

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

type Fn func(req interface{}) (interface{}, error)

type MetaInterface interface {
	GetSpace(spaceName []byte) (*meta.SpaceItem, error)
	DropSpace(spaceName []byte) error
	ListSpaces() ([]*meta.IdName, error)
	ListCluster() (*meta.ListClusterInfoResp, error)
	AddHosts(hosts []*nebula.HostAddr) error
	AddHostsIntoZone(hosts []*nebula.HostAddr, zone string) error
	DropHosts(hosts []*nebula.HostAddr) error
	ListHosts(hostType meta.ListHostType) ([]*meta.HostItem, error)
	ListParts(spaceID nebula.GraphSpaceID, partIDs []nebula.PartitionID) ([]*meta.PartItem, error)
	GetSpaceParts() (map[nebula.GraphSpaceID][]*meta.PartItem, error)
	GetSpaceLeaderHosts(space []byte) ([]string, error)
	GetLeaderCount(leaderHost string) (int, error)
	BalanceStatus(jobID int32, spaceID nebula.GraphSpaceID) error
	BalanceLeader(spaceID nebula.GraphSpaceID) error
	BalanceData(spaceID nebula.GraphSpaceID) (int32, error)
	BalanceDataInZone(spaceID nebula.GraphSpaceID) (int32, error)
	RemoveHost(spaceID nebula.GraphSpaceID, hosts []*nebula.HostAddr) (int32, error)
	RemoveHostInZone(spaceID nebula.GraphSpaceID, hosts []*nebula.HostAddr) (int32, error)
	RecoverDataBalanceJob(jobID int32, spaceID nebula.GraphSpaceID) error
	RecoverInZoneBalanceJob(jobID int32, spaceID nebula.GraphSpaceID) error
	RestoreMeta(hosts []*meta.HostPair, files []string) (*meta.RestoreMetaResp, error)
	Disconnect() error
}

type Option func(ops *Options)

type Options struct {
	EnableMetaTLS    bool
	EnableStorageTLS bool
	EnableClusterTLS bool
	IsStorage        bool
	IsMeta           bool
	Timeout          time.Duration
	TLSConfig        *tls.Config
}

type StorageInterface interface {
	TransLeader(spaceID nebula.GraphSpaceID, partID nebula.PartitionID, newLeader *nebula.HostAddr) (error, string)
	RemovePart(spaceID nebula.GraphSpaceID, partID nebula.PartitionID) error
	GetLeaderParts() (map[nebula.GraphSpaceID][]nebula.PartitionID, error)
	Disconnect() error
}