wasp

package module
v1.3.8 Latest Latest
Warning

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

Go to latest
Published: Jan 19, 2022 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CtxPeer added in v1.3.0

func CtxPeer(ctx context.Context) *peer

func CtxSubscriber added in v1.3.0

func CtxSubscriber(ctx context.Context) string

func CtxTopic added in v1.3.0

func CtxTopic(ctx context.Context) string

func SetReadTimeout added in v1.3.0

func SetReadTimeout(t time.Duration)

Types

type Generater added in v1.3.0

type Generater interface {
	Seq(context.Context, []byte) (int, error)
}

type TCPConn added in v1.3.0

type TCPConn struct {
	*net.TCPConn
	// contains filtered or unexported fields
}

func (*TCPConn) ConnectTime added in v1.3.0

func (c *TCPConn) ConnectTime() int64

func (*TCPConn) SID added in v1.3.0

func (c *TCPConn) SID() string

func (*TCPConn) Write added in v1.3.0

func (c *TCPConn) Write(b []byte) (int, error)

type Wasp

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

func Default added in v1.3.0

func Default() *Wasp

func (*Wasp) Run added in v1.3.0

func (w *Wasp) Run(addr ...string) error

func (*Wasp) SubConns added in v1.3.0

func (w *Wasp) SubConns(topic string) []*TCPConn

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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