internal

Documentation

Index

• Constants
• type Buffer
  • func NewBuffer[T any](size int) *Buffer[T]
  • func (buffer *Buffer[T]) Empty() bool
  • func (buffer *Buffer[T]) Length() int
  • func (buffer *Buffer[T]) Offer(items ...T)
  • func (buffer *Buffer[T]) Polling(stopCh <-chan struct{}, handler func(item T))
• type Container
  • func NewContainer[Key int | int16 | string, Value any]() *Container[Key, Value]
  • func (c *Container[Key, Value]) Del(key Key)
  • func (c *Container[Key, Value]) Get(key Key) (item Value, exist bool)
  • func (c *Container[Key, Value]) Set(key Key, value Value)
• type Provider
  • func NewSyncPoolProvider[Object any](constructor func() interface{}) Provider[Object]
• type Schema
  • func NewSchema(protocol string, addr string, options acceptor.Options) Schema
  • func (schema Schema) Listen(stopCh <-chan struct{}, handler func(conn net.Conn)) error
  • func (schema Schema) String() string
• type ShardContainer
  • func NewShardContainer[T any](size int, constructor func() T) ShardContainer[T]
  • func (shard ShardContainer[T]) GetShard(num int) T
  • func (shard ShardContainer[T]) Iterator(iterator func(T))
• type SyncPoolProvider
  • func (provider *SyncPoolProvider[Object]) Acquire() Object
  • func (provider *SyncPoolProvider[Object]) Release(obj Object)

Constants

const (
	TCP       = "tcp"
	WEBSOCKET = "ws"
)

Types

type Buffer

type Buffer[T any] struct {
	// contains filtered or unexported fields
}

Buffer represents a buffer of any object

func NewBuffer

func NewBuffer[T any](size int) *Buffer[T]

NewBuffer returns a new buffer with the given size

func (*Buffer[T]) Empty

func (buffer *Buffer[T]) Empty() bool

Empty returns true if the buffer is empty

func (*Buffer[T]) Length

func (buffer *Buffer[T]) Length() int

Length returns the length of buffer

func (*Buffer[T]) Offer

func (buffer *Buffer[T]) Offer(items ...T)

Offer push the active fd to the queue, it will be deposed when buffer is full

func (*Buffer[T]) Polling

func (buffer *Buffer[T]) Polling(stopCh <-chan struct{}, handler func(item T))

Polling poll with callback function

type Container

type Container[Key int | int16 | string, Value any] struct {
	// contains filtered or unexported fields
}

Container represents a safe map

func NewContainer

func NewContainer[Key int | int16 | string, Value any]() *Container[Key, Value]

NewContainer creates a new Container instance

func (*Container[Key, Value]) Del

func (c *Container[Key, Value]) Del(key Key)

Del removes the item from the container

func (*Container[Key, Value]) Get

func (c *Container[Key, Value]) Get(key Key) (item Value, exist bool)

Get returns the value associated

func (*Container[Key, Value]) Set

func (c *Container[Key, Value]) Set(key Key, value Value)

Set sets the value of a key in the container

type Provider

type Provider[Object any] interface {
	Acquire() Object
	Release(obj Object)
}

Provider represents a object provider

func NewSyncPoolProvider

func NewSyncPoolProvider[Object any](constructor func() interface{}) Provider[Object]

type Schema

type Schema struct {
	Protocol string
	Addr     string
	// contains filtered or unexported fields
}

Schema represents a protocol specification

func NewSchema

func NewSchema(protocol string, addr string, options acceptor.Options) Schema

func (Schema) Listen

func (schema Schema) Listen(stopCh <-chan struct{}, handler func(conn net.Conn)) error

Listen run acceptor with handler

func (Schema) String

func (schema Schema) String() string

String returns a string representation of the schema

type ShardContainer

type ShardContainer[T any] []T

func NewShardContainer

func NewShardContainer[T any](size int, constructor func() T) ShardContainer[T]

func (ShardContainer[T]) GetShard

func (shard ShardContainer[T]) GetShard(num int) T

func (ShardContainer[T]) Iterator

func (shard ShardContainer[T]) Iterator(iterator func(T))

type SyncPoolProvider

type SyncPoolProvider[Object any] struct {
	// contains filtered or unexported fields
}

func (*SyncPoolProvider[Object]) Acquire

func (provider *SyncPoolProvider[Object]) Acquire() Object

func (*SyncPoolProvider[Object]) Release

func (provider *SyncPoolProvider[Object]) Release(obj Object)