service

Documentation

Index

• func Init()
• type ITopicService
  • func NewTopicService(TopicPrefix string) ITopicService
• type ZkHandleType

Functions

func Init

func Init()

Types

type ITopicService

type ITopicService interface {
	Create(*entity.Topic) (string, error)
	Update(*entity.Topic) error
	GetList() ([]string, error)
	Get(topic string) (entity.TopicZkInfo, error)
	GetIpTopics(ipPortStr string) ([]string, error)
	GetInstanceList(serviceName string) ([]string, error)
	DeleteInstance(serviceName, ip string, port int64) error
	// contains filtered or unexported methods
}

var TopicService ITopicService

func NewTopicService

func NewTopicService(TopicPrefix string) ITopicService

type ZkHandleType

type ZkHandleType int

const (
	ADDNODE ZkHandleType
	REMOVENODE
)