service_infra

Documentation

Index

• func RegisterServiceInfra(name string, creator infraCreator)
• type ChangedInfo
• type ChangedType
• type IServiceInfra
  • func CreateServiceInfra(name string, data interface{}) IServiceInfra
• type ServiceEventHandle
• type ServiceInfo
  • func MakeServiceInfo(hosts []string) *ServiceInfo

Functions

func RegisterServiceInfra

func RegisterServiceInfra(name string, creator infraCreator)

Types

type ChangedInfo

type ChangedInfo struct {
	Hosts []string
}

ChangedInfo service changed info

type ChangedType

type ChangedType int

ChangedType service info type

const (
	ServiceAdd ChangedType = iota
	ServiceChange
	ServiceDelete
)

type IServiceInfra

type IServiceInfra interface {
	// Start service-infra module, connect to soa center
	Start(srvList []string) error
	// Stop disconnect to soa center, remove all service cache
	Stop() error
	// Tick tick func called by logic goroutine
	Tick()
	//FindServiceAsync will find service asynchronous
	//It will call callback function which added by AddListener
	FindServiceAsync(svsName string)
	// FindService will find service from soa system by name
	FindService(svsName string) (*ServiceInfo, error)
	// RegisterService register service to soa
	RegisterService(svsName string, info *ServiceInfo) error
	// UnRegisterService unregister service
	UnRegisterService(svsName string, info *ServiceInfo) error
	//AddListener will store service changed callback by service name
	AddListener(handle ServiceEventHandle) error
	//DelListener del server event listener
	DelListener() error
	//IsConnected is connected  to soa center
	IsConnected() bool
}

IServiceInfra service finder and register interface

func CreateServiceInfra

func CreateServiceInfra(name string, data interface{}) IServiceInfra

type ServiceEventHandle

type ServiceEventHandle func(svsName string, eventType ChangedType, changeInfo *ChangedInfo, err error)

ServiceEventHandle service changed handler

type ServiceInfo

type ServiceInfo struct {
	Hosts []string // ip:port
}

ServiceInfo service info

func MakeServiceInfo

func MakeServiceInfo(hosts []string) *ServiceInfo

MakeServiceInfo create service info with service list