cherryCluster

package
v1.1.7 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2021 License: MIT Imports: 17 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	GrpcOptions = []grpc.DialOption{grpc.WithInsecure()}
)

Functions

func GetDiscovery added in v1.1.5 

func GetDiscovery(name string) facade.IDiscovery

func RegisterDiscovery added in v1.1.5 

func RegisterDiscovery(discovery facade.IDiscovery)

Types

type Component added in v1.1.1 

type Component struct {
	facade.Component
	// contains filtered or unexported fields
}

func NewComponent added in v1.1.5 

func NewComponent() *Component

func (*Component) CloseSession added in v1.1.5 

func (c *Component) CloseSession(_ context.Context, sessionId *cherryProto.SessionId) (*cherryProto.Response, error)

func (*Component) Discovery added in v1.1.5 

func (c *Component) Discovery() facade.IDiscovery

func (*Component) Forward added in v1.1.5 

func (c *Component) Forward(_ context.Context, msg *cherryProto.Message) (*cherryProto.Response, error)

func (*Component) Init added in v1.1.5 

func (c *Component) Init()

func (*Component) Name added in v1.1.5 

func (c *Component) Name() string

func (*Component) NewMember added in v1.1.5 

func (c *Component) NewMember(_ context.Context, newMember *cherryProto.Member) (*cherryProto.Response, error)

func (*Component) OnAddMember added in v1.1.5 

func (c *Component) OnAddMember(listener facade.MemberListener)

func (*Component) OnAfterInit added in v1.1.6 

func (c *Component) OnAfterInit()

func (*Component) OnCloseSession added in v1.1.5 

func (c *Component) OnCloseSession(func(sid facade.SID))

func (*Component) OnForward added in v1.1.5 

func (c *Component) OnForward(fn func(msg *cherryProto.Message))

func (*Component) OnRemoveMember added in v1.1.5 

func (c *Component) OnRemoveMember(listener facade.MemberListener)

func (*Component) OnStop added in v1.1.5 

func (c *Component) OnStop()

func (*Component) RemoveMember added in v1.1.5 

func (c *Component) RemoveMember(_ context.Context, node *cherryProto.NodeId) (*cherryProto.Response, error)

func (*Component) SendCloseSession added in v1.1.5 

func (c *Component) SendCloseSession(sid facade.SID)

func (*Component) SendSysMessage added in v1.1.5 

func (c *Component) SendSysMessage(session *cherrySession.Session, msg *cherryMessage.Message)

func (*Component) SendUserMessage added in v1.1.5 

func (c *Component) SendUserMessage(session *cherrySession.Session, msg *cherryMessage.Message)

type DiscoveryDefault added in v1.1.6 

type DiscoveryDefault struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

DiscoveryDefault 默认方式，读取profile文件

该类型发现服务仅用于开发测试使用，直接读取profile.json->node配置

func (*DiscoveryDefault) AddMember added in v1.1.6 

func (n *DiscoveryDefault) AddMember(member facade.IMember)

func (*DiscoveryDefault) GetMember added in v1.1.6 

func (n *DiscoveryDefault) GetMember(nodeId string) (facade.IMember, bool)

func (*DiscoveryDefault) GetType added in v1.1.6 

func (n *DiscoveryDefault) GetType(nodeId string) (nodeType string, err error)

func (*DiscoveryDefault) Init added in v1.1.6 

func (n *DiscoveryDefault) Init(_ facade.IApplication, _ jsoniter.Any, _ ...interface{})

func (*DiscoveryDefault) List added in v1.1.6 

func (n *DiscoveryDefault) List() []facade.IMember

func (*DiscoveryDefault) Name added in v1.1.6 

func (n *DiscoveryDefault) Name() string

func (*DiscoveryDefault) OnAddMember added in v1.1.6 

func (n *DiscoveryDefault) OnAddMember(listener facade.MemberListener)

func (*DiscoveryDefault) OnRemoveMember added in v1.1.6 

func (n *DiscoveryDefault) OnRemoveMember(listener facade.MemberListener)

func (*DiscoveryDefault) OnStop added in v1.1.6 

func (n *DiscoveryDefault) OnStop()

func (*DiscoveryDefault) RemoveMember added in v1.1.6 

func (n *DiscoveryDefault) RemoveMember(nodeId string)

type DiscoveryETCD added in v1.1.5 

type DiscoveryETCD struct {
}

DiscoveryETCD etcd方式发现服务

type DiscoveryMaster added in v1.1.5 

type DiscoveryMaster struct {
	DiscoveryDefault
	facade.IApplication
	// contains filtered or unexported fields
}

DiscoveryMaster master节点模式(master为单点)

func (*DiscoveryMaster) AddMember added in v1.1.5 

func (m *DiscoveryMaster) AddMember(member facade.IMember)

func (*DiscoveryMaster) Init added in v1.1.5 

func (m *DiscoveryMaster) Init(app facade.IApplication, config jsoniter.Any, params ...interface{})

func (*DiscoveryMaster) Name added in v1.1.5 

func (m *DiscoveryMaster) Name() string

func (*DiscoveryMaster) OnStop added in v1.1.5 

func (m *DiscoveryMaster) OnStop()

func (*DiscoveryMaster) Register added in v1.1.5 

func (m *DiscoveryMaster) Register(ctx context.Context, newMember *cherryProto.Member) (*cherryProto.MemberList, error)

func (*DiscoveryMaster) RemoveMember added in v1.1.5 

func (m *DiscoveryMaster) RemoveMember(nodeId string)

func (*DiscoveryMaster) Unregister added in v1.1.5 

func (m *DiscoveryMaster) Unregister(ctx context.Context, nodeId *cherryProto.NodeId) (*cherryProto.Response, error)

type IBindStorage added in v1.1.6 

type IBindStorage interface {
	GetFrontendID(uid cherryFacade.UID, nodeType string) (string, error)
	Binding(uid cherryFacade.UID) error
}

IBindStorage 绑定存储，用于存储UID对应的前端节点id

type IComponent added in v1.1.6 

type IComponent interface {
	SendUserMessage(session *cherrySession.Session, msg *cherryMessage.Message)
	SendSysMessage(session *cherrySession.Session, msg *cherryMessage.Message)
	SendCloseSession(sid facade.SID)
	OnCloseSession(func(sid facade.SID))
	OnForward(func(msg *cherryProto.Message))
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.