service

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 24, 2020 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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
)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL