serve

package

v0.0.0-...-917d9ad Latest Latest Go to latest Published: Jan 31, 2024 License: Apache-2.0 Imports: 21 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/yamakiller/velcro-go

Links

Open Source Insights

Documentation ¶

Index ¶

func EnablePoolClientInfo(enable bool)
func EnablePoolMessageEnvelope(enable bool)
func FreeCtxWithServantClientInfo(ctx context.Context) context.Context
func NewCtxWithServantClientInfo(ctx context.Context, si *ServantClientInfo) context.Context
func PoolEnabledClientInfo() bool
func PoolEnabledMessageEnvelope() bool
func UnwrapEnvelopeMessage(message interface{}) interface{}
func UnwrapEnvelopeSender(message interface{}) (*network.ClientID, bool)
func UnwrapEnvelopeSequenceId(message interface{}) (int32, bool)
type MessageEnvelope
- func NewMessageEnvelopePool(seqId int32, clientId *network.ClientID, message interface{}) *MessageEnvelope
- func (me *MessageEnvelope) Recycle()
type Servant
- func New(options ...ServantConfigOption) *Servant
- func (s *Servant) FindAddrRouter(addr string) *router.Router
- func (s *Servant) FindRouter(message proto.Message) *router.Router
- func (s *Servant) Start() error
- func (s *Servant) Stop() error
type ServantClientActor
type ServantClientConn
- func (c *ServantClientConn) Accept(ctx network.Context)
- func (c *ServantClientConn) Closed(ctx network.Context)
- func (c *ServantClientConn) Ping(ctx network.Context)
- func (c *ServantClientConn) Recvice(ctx network.Context)
- func (c *ServantClientConn) Register(key, evt interface{})
type ServantClientInfo
- func GetServantClientInfo(ctx context.Context) *ServantClientInfo
- func NewClientInfo(ctx network.Context, message interface{}) *ServantClientInfo
- func (s *ServantClientInfo) Message() interface{}
- func (s *ServantClientInfo) Recycle()
- func (s *ServantClientInfo) Sender() *network.ClientID
- func (s *ServantClientInfo) SeqId() int32
type ServantConfig
type ServantConfigOption
- func WithKleepalive(kleepalive int32) ServantConfigOption
- func WithLAddr(laddr string) ServantConfigOption
- func WithMetricsProvider(provider metric.MeterProvider) ServantConfigOption
- func WithName(name string) ServantConfigOption
- func WithProducerActor(f func(*ServantClientConn) ServantClientActor) ServantConfigOption
- func WithRoute(router *router.RouterConfig) ServantConfigOption
- func WithVAddr(vaddr string) ServantConfigOption

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func EnablePoolClientInfo ¶

func EnablePoolClientInfo(enable bool)

func EnablePoolMessageEnvelope ¶

func EnablePoolMessageEnvelope(enable bool)

func FreeCtxWithServantClientInfo ¶

func FreeCtxWithServantClientInfo(ctx context.Context) context.Context

func NewCtxWithServantClientInfo ¶

func NewCtxWithServantClientInfo(ctx context.Context, si *ServantClientInfo) context.Context

func PoolEnabledClientInfo ¶

func PoolEnabledClientInfo() bool

PoolEnabled returns true if pool is enabled.

func PoolEnabledMessageEnvelope ¶

func PoolEnabledMessageEnvelope() bool

func UnwrapEnvelopeMessage ¶

func UnwrapEnvelopeMessage(message interface{}) interface{}

func UnwrapEnvelopeSender ¶

func UnwrapEnvelopeSender(message interface{}) (*network.ClientID, bool)

func UnwrapEnvelopeSequenceId ¶

func UnwrapEnvelopeSequenceId(message interface{}) (int32, bool)

Types ¶

type MessageEnvelope ¶

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

func NewMessageEnvelopePool ¶

func NewMessageEnvelopePool(seqId int32, clientId *network.ClientID, message interface{}) *MessageEnvelope

func (*MessageEnvelope) Recycle ¶

func (me *MessageEnvelope) Recycle()

type Servant ¶

type Servant struct {
	System *network.NetworkSystem
	Config *ServantConfig
	// contains filtered or unexported fields
}

func New ¶

func New(options ...ServantConfigOption) *Servant

func (*Servant) FindAddrRouter ¶

func (s *Servant) FindAddrRouter(addr string) *router.Router

func (*Servant) FindRouter ¶

func (s *Servant) FindRouter(message proto.Message) *router.Router

FindRouter 查询路由

func (*Servant) Start ¶

func (s *Servant) Start() error

func (*Servant) Stop ¶

func (s *Servant) Stop() error

type ServantClientActor ¶

type ServantClientActor interface {
	Closed(context.Context)
}

type ServantClientConn ¶

type ServantClientConn struct {
	Servant *Servant
	// contains filtered or unexported fields
}

func (*ServantClientConn) Accept ¶

func (c *ServantClientConn) Accept(ctx network.Context)

func (*ServantClientConn) Closed ¶

func (c *ServantClientConn) Closed(ctx network.Context)

func (*ServantClientConn) Ping ¶

func (c *ServantClientConn) Ping(ctx network.Context)

Ping 客户端主动请求, 这里不处理

func (*ServantClientConn) Recvice ¶

func (c *ServantClientConn) Recvice(ctx network.Context)

Recvice 接收到的数据

func (*ServantClientConn) Register ¶

func (c *ServantClientConn) Register(key, evt interface{})

Register 注册方法映射

type ServantClientInfo ¶

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

func GetServantClientInfo ¶

func GetServantClientInfo(ctx context.Context) *ServantClientInfo

func NewClientInfo ¶

func NewClientInfo(ctx network.Context, message interface{}) *ServantClientInfo

func (*ServantClientInfo) Message ¶

func (s *ServantClientInfo) Message() interface{}

func (*ServantClientInfo) Recycle ¶

func (s *ServantClientInfo) Recycle()

func (*ServantClientInfo) Sender ¶

func (s *ServantClientInfo) Sender() *network.ClientID

func (*ServantClientInfo) SeqId ¶

func (s *ServantClientInfo) SeqId() int32

type ServantConfig ¶

type ServantConfig struct {
	MetricsProvider metric.MeterProvider
	Producer        func(*ServantClientConn) ServantClientActor
	Name            string
	LAddr           string
	VAddr           string
	Kleepalive      int32
	Router          *router.RouterConfig
}

type ServantConfigOption ¶

type ServantConfigOption func(config *ServantConfig)

func WithKleepalive ¶

func WithKleepalive(kleepalive int32) ServantConfigOption

WithKleepalive 设置心跳时间

func WithLAddr ¶

func WithLAddr(laddr string) ServantConfigOption

WithLAddr 设置本服务的监听地址

func WithMetricsProvider ¶

func WithMetricsProvider(provider metric.MeterProvider) ServantConfigOption

WithMetricsProvider ...

func WithName ¶

func WithName(name string) ServantConfigOption

WithName 设置服务名称

func WithProducerActor ¶

func WithProducerActor(f func(*ServantClientConn) ServantClientActor) ServantConfigOption

WithProducerActor actor 创建器

func WithRoute ¶

func WithRoute(router *router.RouterConfig) ServantConfigOption

WithRoute 设置路由配置

func WithVAddr ¶

func WithVAddr(vaddr string) ServantConfigOption

WithVAddr 设置本服务的虚地址

Source Files ¶

View all Source files

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