cherryCluster

package
v1.1.5 Latest Latest
Warning

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

 Go to latest Published: Jul 24, 2021 License: MIT Imports: 16 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, session *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) 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(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)

SendCloseSession move to handlerComponent

func (*Component) SendSysMessage added in v1.1.5 

func (c *Component) SendSysMessage(nodeId string, msg *cherryProto.Message)

func (*Component) SendUserMessage added in v1.1.5 

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

type DiscoveryETCD added in v1.1.5 

type DiscoveryETCD struct {
}

type DiscoveryFile added in v1.1.5 

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

DiscoveryFile 读取文件配置模式

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

func (*DiscoveryFile) AddMember added in v1.1.5 

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

func (*DiscoveryFile) GetMember added in v1.1.5 

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

func (*DiscoveryFile) GetType added in v1.1.5 

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

func (*DiscoveryFile) Init added in v1.1.5 

func (n *DiscoveryFile) Init(_ facade.IApplication, _ *grpc.Server, _ jsoniter.Any)

func (*DiscoveryFile) List added in v1.1.5 

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

func (*DiscoveryFile) Name added in v1.1.5 

func (n *DiscoveryFile) Name() string

func (*DiscoveryFile) OnAddMember added in v1.1.5 

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

func (*DiscoveryFile) OnRemoveMember added in v1.1.5 

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

func (*DiscoveryFile) OnStop added in v1.1.5 

func (n *DiscoveryFile) OnStop()

func (*DiscoveryFile) RemoveMember added in v1.1.5 

func (n *DiscoveryFile) RemoveMember(nodeId string)

type DiscoveryMaster added in v1.1.5 

type DiscoveryMaster struct {
	DiscoveryFile
	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, rpcServer *grpc.Server, discoveryConfig jsoniter.Any)

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)

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.