nebula

Documentation

Index

• Constants
• Variables
• type Agent
  • func NewAgent(agentAddr *nebula.HostAddr) (*Agent, error)
• type AgentManager
  • func NewAgentManager() *AgentManager
  • func (a *AgentManager) Close()
  • func (a *AgentManager) GetAgent(agentAddr *nebula.HostAddr) (*Agent, error)
• type Fn
• type MetaInterface
  • func NewMetaClient(hosts []string, options ...Option) (MetaInterface, error)
• type Option
  • func ClientOptions(nc *v1alpha1.NebulaCluster, opts ...Option) ([]Option, error)
  • func SetClusterTLS(e bool) Option
  • func SetIsMeta(e bool) Option
  • func SetIsStorage(e bool) Option
  • func SetMetaTLS(e bool) Option
  • func SetOptions(options Options) Option
  • func SetStorageTLS(e bool) Option
  • func SetTLSConfig(config *tls.Config) Option
  • func SetTimeout(duration time.Duration) Option
• type Options
• type StorageInterface
  • func NewStorageClient(endpoints []string, options ...Option) (StorageInterface, error)

Constants

const DefaultTimeout = 10 * time.Second

Variables

var (
	ErrNoAvailableMetadEndpoints = errors.New("metadclient: no available hosts")
	ErrJobStatusFailed           = errors.New("job status failed")
)

var ErrNoAvailableStoragedEndpoints = errors.New("storagedclient: no available endpoints")

Types

type Agent

type Agent struct {
	agentclient.Client
}

func NewAgent

func NewAgent(agentAddr *nebula.HostAddr) (*Agent, error)

type AgentManager

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

func NewAgentManager

func NewAgentManager() *AgentManager

func (*AgentManager) Close

func (a *AgentManager) Close()

func (*AgentManager) GetAgent

func (a *AgentManager) GetAgent(agentAddr *nebula.HostAddr) (*Agent, error)

type Fn

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

type MetaInterface

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
	IsLeaderBalanced(spaceName []byte) (bool, 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
}

func NewMetaClient

func NewMetaClient(hosts []string, options ...Option) (MetaInterface, error)

type Option

type Option func(ops *Options)

func ClientOptions

func ClientOptions(nc *v1alpha1.NebulaCluster, opts ...Option) ([]Option, error)

func SetClusterTLS

func SetClusterTLS(e bool) Option

func SetIsMeta

func SetIsMeta(e bool) Option

func SetIsStorage

func SetIsStorage(e bool) Option

func SetMetaTLS

func SetMetaTLS(e bool) Option

func SetOptions

func SetOptions(options Options) Option

func SetStorageTLS

func SetStorageTLS(e bool) Option

func SetTLSConfig

func SetTLSConfig(config *tls.Config) Option

func SetTimeout

func SetTimeout(duration time.Duration) Option

type Options

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

type StorageInterface

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
}

func NewStorageClient

func NewStorageClient(endpoints []string, options ...Option) (StorageInterface, error)