network

package
v0.0.8 Latest Latest
Warning

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

 Go to latest Published: Jun 20, 2021 License: MIT Imports: 13 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ContextFinish = errors.New("context finished")

Functions

This section is empty.

Types

type CancelFunc 

type CancelFunc func(error)

func WithReasonCancel 

func WithReasonCancel(parent context.Context) (ctx context.Context, cancel CancelFunc)

func WithReasonDeadline 

func WithReasonDeadline(parent context.Context, d time.Time) (context.Context, CancelFunc)

func WithReasonTimeout 

func WithReasonTimeout(parent context.Context, timeout time.Duration) (context.Context, CancelFunc)

type DefaultContext 

type DefaultContext struct {
	context.Context
	// contains filtered or unexported fields
}

func NewDefaultContext 

func NewDefaultContext(ctx context.Context) *DefaultContext

func NewDefaultContextWithTimeout 

func NewDefaultContextWithTimeout(ctx context.Context, transId uint32, timeout time.Duration) *DefaultContext

func (*DefaultContext) Cancel 

func (this *DefaultContext) Cancel(err error)

func (*DefaultContext) Finish 

func (this *DefaultContext) Finish()

func (*DefaultContext) Get 

func (this *DefaultContext) Get(name string) interface{}

func (*DefaultContext) GetCallback 

func (this *DefaultContext) GetCallback() lokas.AsyncCallBack

func (*DefaultContext) GetIdType 

func (this *DefaultContext) GetIdType(key string) util.ID

func (*DefaultContext) GetProcessIdType 

func (this *DefaultContext) GetProcessIdType(key string) util.ProcessId

func (*DefaultContext) GetResp 

func (this *DefaultContext) GetResp() interface{}

func (*DefaultContext) GetString 

func (this *DefaultContext) GetString(key string) string

func (*DefaultContext) GetTransId 

func (this *DefaultContext) GetTransId() uint32

func (*DefaultContext) Set 

func (this *DefaultContext) Set(name string, data interface{})

func (*DefaultContext) SetCallback 

func (this *DefaultContext) SetCallback(cb lokas.AsyncCallBack)

func (*DefaultContext) SetResp 

func (this *DefaultContext) SetResp(data interface{})

type DefaultSession 

type DefaultSession struct {
	util.ID

	Messages chan []byte
	Conn     lokas.IConn

	OnCloseFunc func(conn lokas.IConn)
	OnOpenFunc  func(conn lokas.IConn)
	MsgHandler  func(msg *protocol.BinaryMessage)
	// contains filtered or unexported fields
}

func NewDefaultSession 

func NewDefaultSession(conn lokas.IConn, id util.ID, manager lokas.ISessionManager, opts ...SessionOption) *DefaultSession

func (*DefaultSession) AsyncCall 

func (this *DefaultSession) AsyncCall(actorId util.ID, transId uint32, req protocol.ISerializable, resp protocol.ISerializable) error

func (*DefaultSession) Call 

func (this *DefaultSession) Call(actorId util.ID, transId uint32, req protocol.ISerializable, resp protocol.ISerializable) error

func (*DefaultSession) CloneEntity 

func (this *DefaultSession) CloneEntity() *ecs.Entity

func (*DefaultSession) GetConn 

func (this *DefaultSession) GetConn() lokas.IConn

func (*DefaultSession) GetId 

func (this *DefaultSession) GetId() util.ID

func (*DefaultSession) GetProcess 

func (this *DefaultSession) GetProcess() lokas.IProcess

func (*DefaultSession) HandleMessage 

func (this *DefaultSession) HandleMessage(f func(msg *protocol.BinaryMessage))

func (*DefaultSession) OnClose 

func (this *DefaultSession) OnClose(conn lokas.IConn)

func (*DefaultSession) OnCreate 

func (this *DefaultSession) OnCreate() error

func (*DefaultSession) OnDestroy 

func (this *DefaultSession) OnDestroy() error

func (*DefaultSession) OnMessage 

func (this *DefaultSession) OnMessage(actorId util.ID, transId uint32, msg protocol.ISerializable) error

func (*DefaultSession) OnOpen 

func (this *DefaultSession) OnOpen(conn lokas.IConn)

func (*DefaultSession) OnRecv 

func (this *DefaultSession) OnRecv(conn lokas.IConn, data []byte)

func (*DefaultSession) SendMessage 

func (this *DefaultSession) SendMessage(actorId util.ID, transId uint32, msg protocol.ISerializable) error

func (*DefaultSession) SetId 

func (this *DefaultSession) SetId(id util.ID)

func (*DefaultSession) SetProcess 

func (this *DefaultSession) SetProcess(process lokas.IProcess)

func (*DefaultSession) Start 

func (this *DefaultSession) Start() error

func (*DefaultSession) Stop 

func (this *DefaultSession) Stop() error

func (*DefaultSession) Type 

func (this *DefaultSession) Type() string

func (*DefaultSession) Update 

func (this *DefaultSession) Update(dt time.Duration, now time.Time)

func (*DefaultSession) Write 

func (this *DefaultSession) Write(data []byte) error

type DefaultSessionManager 

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

func NewDefaultSessionManager 

func NewDefaultSessionManager(safeMode bool) *DefaultSessionManager

func (*DefaultSessionManager) AddSession 

func (this *DefaultSessionManager) AddSession(id util.ID, session lokas.ISession)

func (*DefaultSessionManager) Clear 

func (this *DefaultSessionManager) Clear()

func (*DefaultSessionManager) GetRoundSession 

func (this *DefaultSessionManager) GetRoundSession() (lokas.ISession, bool)

func (*DefaultSessionManager) GetSession 

func (this *DefaultSessionManager) GetSession(id util.ID) lokas.ISession

func (*DefaultSessionManager) GetSessionCount 

func (this *DefaultSessionManager) GetSessionCount() int

func (*DefaultSessionManager) Range 

func (this *DefaultSessionManager) Range(f func(id util.ID, session lokas.ISession) bool)

func (*DefaultSessionManager) RemoveSession 

func (this *DefaultSessionManager) RemoveSession(id util.ID)

type SessionOption 

type SessionOption func(*DefaultSession)

func WithCloseFunc 

func WithCloseFunc(closeFunc func(conn lokas.IConn)) SessionOption

func WithMsgHandler 

func WithMsgHandler(msgHandler func(msg *protocol.BinaryMessage)) SessionOption

func WithOpenFunc 

func WithOpenFunc(closeFunc func(conn lokas.IConn)) SessionOption

Source Files

View all Source files

Directories

Path Synopsis
internal
common
hub

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.