etv3

Documentation

Index

• Constants
• func NodeToService(val []byte) *rpc.ClusterInfo
• type MailBox
  • func (m *MailBox) Create(info *rpc.MailBox) bool
  • func (m *MailBox) Delete(Id int64) error
  • func (m *MailBox) DeleteAll() error
  • func (m *MailBox) Get(Id int64) *rpc.MailBox
  • func (m *MailBox) Init(endpoints []string, info *rpc.ClusterInfo)
  • func (m *MailBox) Lease(leaseId int64) error
  • func (m *MailBox) Run()
  • func (m *MailBox) Start()
• type Master
  • func (m *Master) Init(info rpc.IClusterInfo, Endpoints []string)
  • func (m *Master) InitServices()
  • func (m *Master) Run()
  • func (m *Master) Start()
• type STATUS
• type Service
  • func (s *Service) Init(info *rpc.ClusterInfo, endpoints []string)
  • func (s *Service) Run()
  • func (s *Service) SET()
  • func (s *Service) Start()
  • func (s *Service) TTL()
• type Snowflake
  • func (s *Snowflake) Init(endpoints []string)
  • func (s *Snowflake) Key() string
  • func (s *Snowflake) Run()
  • func (s *Snowflake) SET() bool
  • func (s *Snowflake) Start()
  • func (s *Snowflake) TTL()
• type StubMailBox
  • func (s *StubMailBox) Count(stubType rpc.STUB) int64
  • func (s *StubMailBox) Create(info *rpc.StubMailBox) bool
  • func (s *StubMailBox) Get(stubType rpc.STUB, Id int64) *rpc.StubMailBox
  • func (s *StubMailBox) Init(endpoints []string, info *rpc.ClusterInfo)
  • func (s *StubMailBox) Lease(info *rpc.StubMailBox) error
  • func (s *StubMailBox) Run()
  • func (s *StubMailBox) Start()
• type StubMailBoxMap

Constants

const (
	MAILBOX_DIR     = "mailbox/"
	MAILBOX_TL_TIME = 20 * 60
)

const (
	STUB_DIR      = "stub/"
	STUB_TTL_TIME = 30
)

const (
	ETCD_DIR = "server/"
)

Functions

func NodeToService

func NodeToService(val []byte) *rpc.ClusterInfo

Types

type MailBox

type MailBox struct {
	*rpc.ClusterInfo
	// contains filtered or unexported fields
}

publish

func (*MailBox) Create

func (m *MailBox) Create(info *rpc.MailBox) bool

func (*MailBox) Delete

func (m *MailBox) Delete(Id int64) error

func (*MailBox) DeleteAll

func (m *MailBox) DeleteAll() error

func (*MailBox) Get

func (m *MailBox) Get(Id int64) *rpc.MailBox

func (*MailBox) Init

func (m *MailBox) Init(endpoints []string, info *rpc.ClusterInfo)

初始化pub

func (*MailBox) Lease

func (m *MailBox) Lease(leaseId int64) error

func (*MailBox) Run

func (m *MailBox) Run()

subscribe

func (*MailBox) Start

func (m *MailBox) Start()

type Master

type Master struct {
	rpc.IClusterInfo
	// contains filtered or unexported fields
}

监控服务器

func (*Master) Init

func (m *Master) Init(info rpc.IClusterInfo, Endpoints []string)

监控服务器

func (*Master) InitServices

func (m *Master) InitServices()

func (*Master) Run

func (m *Master) Run()

func (*Master) Start

func (m *Master) Start()

type STATUS

type STATUS uint32

const (
	SET STATUS = iota
	TTL STATUS = iota
)

type Service

type Service struct {
	*rpc.ClusterInfo
	// contains filtered or unexported fields
}

注册服务器

func (*Service) Init

func (s *Service) Init(info *rpc.ClusterInfo, endpoints []string)

注册服务器

func (*Service) Run

func (s *Service) Run()

func (*Service) SET

func (s *Service) SET()

func (*Service) Start

func (s *Service) Start()

func (*Service) TTL

func (s *Service) TTL()

type Snowflake

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

func (*Snowflake) Init

func (s *Snowflake) Init(endpoints []string)

uuid生成器

func (*Snowflake) Key

func (s *Snowflake) Key() string

func (*Snowflake) Run

func (s *Snowflake) Run()

func (*Snowflake) SET

func (s *Snowflake) SET() bool

func (*Snowflake) Start

func (s *Snowflake) Start()

func (*Snowflake) TTL

func (s *Snowflake) TTL()

type StubMailBox

type StubMailBox struct {
	*rpc.ClusterInfo
	// contains filtered or unexported fields
}

publish

func (*StubMailBox) Count

func (s *StubMailBox) Count(stubType rpc.STUB) int64

func (*StubMailBox) Create

func (s *StubMailBox) Create(info *rpc.StubMailBox) bool

func (*StubMailBox) Get

func (s *StubMailBox) Get(stubType rpc.STUB, Id int64) *rpc.StubMailBox

func (*StubMailBox) Init

func (s *StubMailBox) Init(endpoints []string, info *rpc.ClusterInfo)

初始化pub

func (*StubMailBox) Lease

func (s *StubMailBox) Lease(info *rpc.StubMailBox) error

func (*StubMailBox) Run

func (s *StubMailBox) Run()

subscribe

func (*StubMailBox) Start

func (s *StubMailBox) Start()

type StubMailBoxMap

type StubMailBoxMap map[int64]*rpc.StubMailBox

publish