domain

Documentation

Index

• Constants
• func Init()
• func InitDomainBook(domains []string, eventInterval int) error
• func InitDomainConf() ([]string, error)
• type Domain
  • func NewDomain(name string) *Domain
  • func (d *Domain) DelNode(ID string)
  • func (d *Domain) GetName() string
  • func (d *Domain) GetNode(ID string) (*model.Node, error)
  • func (d *Domain) GetNodes() []*model.Node
  • func (d *Domain) GetVersion() int
  • func (d *Domain) Register(node *model.Node) error
  • func (d *Domain) SetVersion(version int)
• type DomainBook
  • func NewDomainBook() *DomainBook
  • func (d *DomainBook) AddDomain(domainName string)
  • func (d *DomainBook) DeleteDomain(domainName string)
  • func (d *DomainBook) GetDomain(domainName string) (*Domain, error)
  • func (d *DomainBook) GetDomains() []*Domain
  • func (d *DomainBook) GetDomainsInfo() []Domain
  • func (d *DomainBook) Monitor(interval time.Duration, expire int64)
  • func (d *DomainBook) Reload(domainName string, version int, domainConf *conf.ConfManager) error
• type DomainConf
  • func (d *DomainConf) Debug()
  • func (d *DomainConf) DeleteKey(event operate.Event) error
  • func (d *DomainConf) GetDomain(domainName string) (*conf.ConfManager, error)
  • func (d *DomainConf) GetDomainNames() []string
  • func (d *DomainConf) Reload(domainName string) error
  • func (d *DomainConf) UpdateDomain(event operate.Event) error
  • func (d *DomainConf) UpdateKey(event operate.Event) error

Constants

const (
	DefaultDomainConfPath = "/tmp/gokeeper/init/"
)

Functions

func Init

func Init()

func InitDomainBook

func InitDomainBook(domains []string, eventInterval int) error

func InitDomainConf

func InitDomainConf() ([]string, error)

Types

type Domain

type Domain struct {
	Name    string `json:"name"`
	Version int    `json:"version"` //int type，兼容client老版本

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewDomain

func NewDomain(name string) *Domain

func (*Domain) DelNode

func (d *Domain) DelNode(ID string)

func (*Domain) GetName

func (d *Domain) GetName() string

func (*Domain) GetNode

func (d *Domain) GetNode(ID string) (*model.Node, error)

func (*Domain) GetNodes

func (d *Domain) GetNodes() []*model.Node

func (*Domain) GetVersion

func (d *Domain) GetVersion() int

func (*Domain) Register

func (d *Domain) Register(node *model.Node) error

func (*Domain) SetVersion

func (d *Domain) SetVersion(version int)

type DomainBook

type DomainBook struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

var (
	DomainBooks *DomainBook
)

func NewDomainBook

func NewDomainBook() *DomainBook

func (*DomainBook) AddDomain

func (d *DomainBook) AddDomain(domainName string)

func (*DomainBook) DeleteDomain

func (d *DomainBook) DeleteDomain(domainName string)

func (*DomainBook) GetDomain

func (d *DomainBook) GetDomain(domainName string) (*Domain, error)

func (*DomainBook) GetDomains

func (d *DomainBook) GetDomains() []*Domain

func (*DomainBook) GetDomainsInfo

func (d *DomainBook) GetDomainsInfo() []Domain

func (*DomainBook) Monitor

func (d *DomainBook) Monitor(interval time.Duration, expire int64)

func (*DomainBook) Reload

func (d *DomainBook) Reload(domainName string, version int, domainConf *conf.ConfManager) error

type DomainConf

type DomainConf struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

var (
	DomainConfs *DomainConf
)

func (*DomainConf) Debug

func (d *DomainConf) Debug()

func (*DomainConf) DeleteKey

func (d *DomainConf) DeleteKey(event operate.Event) error

func (*DomainConf) GetDomain

func (d *DomainConf) GetDomain(domainName string) (*conf.ConfManager, error)

func (*DomainConf) GetDomainNames

func (d *DomainConf) GetDomainNames() []string

func (*DomainConf) Reload

func (d *DomainConf) Reload(domainName string) error

func (*DomainConf) UpdateDomain

func (d *DomainConf) UpdateDomain(event operate.Event) error

func (*DomainConf) UpdateKey

func (d *DomainConf) UpdateKey(event operate.Event) error