container

package

v0.0.0-...-93c743e Latest Latest Go to latest Published: Jul 24, 2023 License: MIT Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/chang144/gotalk

Links

Open Source Insights

README ¶

托管Server
维护服务的依赖关系
处理消息上下行

容器中管理的主要对象：

him.Server
map[string]ClientMap

Documentation ¶

Index ¶

Constants
func EnableMonitor(listen string) error
func Forward(serviceName string, packet *pkt.LogicPkt) error
func HashCode(key string) int
func Init(srv him.Server, deps ...string) error
func Push(server string, p *pkt.LogicPkt) error
func SetDialer(dialer him.Dialer)
func SetSelector(selector Selector)
func SetServiceNaming(nm naming.Naming)
func Start() error
type ClientMap
- func NewClientMap(num int) ClientMap
type ClientMapImpl
type Container
- func Default() *Container
type HashSelector
- func (h *HashSelector) Lookup(header *pkt.Header, servers []him.Service) string
type Selector

Constants ¶

View Source

const (
	StateYoung = "young"
	StateAdult = "adult"
)

新/旧服务

View Source

const (
	KeyServiceState = "service_state"
)

Variables ¶

This section is empty.

Functions ¶

func EnableMonitor ¶

func EnableMonitor(listen string) error

func Forward ¶

func Forward(serviceName string, packet *pkt.LogicPkt) error

Forward 消息上行主要用于下游服务（长连网关）发送消息到上游服务（如LoginServer）

func HashCode ¶

func HashCode(key string) int

func Init ¶

func Init(srv him.Server, deps ...string) error

Init 初始化服务，由上层传入依赖服务

func Push ¶

func Push(server string, p *pkt.LogicPkt) error

Push a message to gateway 逻辑服务-消息下行

func SetDialer ¶

func SetDialer(dialer him.Dialer)

SetDialer set tcp dialer

func SetSelector ¶

func SetSelector(selector Selector)

SetSelector set a default selector 用于上层业务注册一个自定义的服务路由器

func SetServiceNaming ¶

func SetServiceNaming(nm naming.Naming)

SetServiceNaming set service naming

func Start ¶

func Start() error

Start 启动容器 step1: 服务注册 step2：启动Server step3：监听依赖服务 step4：系统退出

Types ¶

type ClientMap ¶

type ClientMap interface {
	Add(client him.Client)
	Remove(clientId string)
	Get(clientId string) (client him.Client, ok bool)

	Services(kvs ...string) []him.Service
}

func NewClientMap ¶

func NewClientMap(num int) ClientMap

type ClientMapImpl ¶

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

func (*ClientMapImpl) Add ¶

func (ch *ClientMapImpl) Add(client him.Client)

func (*ClientMapImpl) Get ¶

func (ch *ClientMapImpl) Get(clientId string) (client him.Client, ok bool)

func (*ClientMapImpl) Remove ¶

func (ch *ClientMapImpl) Remove(clientId string)

func (*ClientMapImpl) Services ¶

func (ch *ClientMapImpl) Services(kvs ...string) []him.Service

Services 返回服务列表 TODO: 优化kvs传参

type Container ¶

type Container struct {
	sync.RWMutex

	Naming naming.Naming
	Srv    him.Server
	// contains filtered or unexported fields
}

func Default ¶

func Default() *Container

type HashSelector ¶

type HashSelector struct {
}

HashSelector 哈希选择器

func (*HashSelector) Lookup ¶

func (h *HashSelector) Lookup(header *pkt.Header, servers []him.Service) string

Lookup TODO：目前的选择器是伪哈希，当service的数量不变时，固定可用，当service数量发生变化时，会导致service的哈希取值发生变化

type Selector ¶

type Selector interface {
	Lookup(*pkt.Header, []him.Service) string
}

Selector is used to select a Service

Source Files ¶

View all Source files

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