module

package

v0.0.0-...-78a0d84 Latest Latest Go to latest Published: Aug 27, 2021 License: MIT Imports: 13 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/lightning-go/lightning

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type Decoder
- func NewDecoder(r io.Reader, order binary.ByteOrder) *Decoder
- func (decoder *Decoder) Clean()
- func (decoder *Decoder) DecodeData(buf []byte) (n int, err error)
- func (decoder *Decoder) DecodeDataFull(buf []byte) (n int, err error)
- func (decoder *Decoder) DecodeInt32() (int32, error)
- func (decoder *Decoder) DecodeInt32Tiny() (int32, error)
- func (decoder *Decoder) DecodeInt8() (int8, error)
- func (decoder *Decoder) DecodeInt8Tiny() (int8, error)
- func (decoder *Decoder) DecodeUInt32() (uint32, error)
- func (decoder *Decoder) DecodeUInt32Tiny() (uint32, error)
- func (decoder *Decoder) DecodeUInt64() (uint64, error)
- func (decoder *Decoder) DecodeUInt64Tiny() (uint64, error)
type Encoder
- func NewEncode(w io.Writer, order binary.ByteOrder) *Encoder
- func (encoder *Encoder) Clean()
- func (encoder *Encoder) EncodeData(data []byte) (err error)
- func (encoder *Encoder) EncodeInt32(data int32) (err error)
- func (encoder *Encoder) EncodeInt32Tiny(data int32) (err error)
- func (encoder *Encoder) EncodeInt8(data int8) (err error)
- func (encoder *Encoder) EncodeInt8Tiny(data int8) (err error)
- func (encoder *Encoder) EncodeUInt32(data uint32) (err error)
- func (encoder *Encoder) EncodeUInt32Tiny(data uint32) (err error)
- func (encoder *Encoder) EncodeUInt64(data uint64) (err error)
- func (encoder *Encoder) EncodeUInt64Tiny(data uint64) (err error)
- func (encoder *Encoder) Flush() error
type HeadCodec
- func NewHeadCodec() *HeadCodec
- func (hc *HeadCodec) Init(conn defs.IConnection) bool
- func (hc *HeadCodec) Read() (defs.IPacket, error)
- func (hc *HeadCodec) Write(packet defs.IPacket) error
type IOModule
- func NewIOModule(conn defs.IConnection) *IOModule
- func (ioModule *IOModule) Close()
- func (ioModule *IOModule) Codec(codec defs.ICodec) bool
- func (ioModule *IOModule) OnConnectionLost()
- func (ioModule *IOModule) UpdateCodec(codec defs.ICodec)
- func (ioModule *IOModule) Write(packet defs.IPacket)
- func (ioModule *IOModule) WriteAwait(packet defs.IPacket) (response defs.IPacket, err error)
type RpcCall
type StreamCodec
- func NewStreamCodec() *StreamCodec
- func (sc *StreamCodec) Init(conn defs.IConnection) bool
- func (sc *StreamCodec) Read() (defs.IPacket, error)
- func (sc *StreamCodec) Write(packet defs.IPacket) error
type WSCodec
- func NewWSCodec() *WSCodec
- func (wsCodec *WSCodec) Init(conn defs.IConnection) bool
- func (wsCodec *WSCodec) Read() (defs.IPacket, error)
- func (wsCodec *WSCodec) Write(packet defs.IPacket) error

Constants ¶

View Source

const (
	DefaultBufferSize = 8 * 1024
)

Variables ¶

View Source

var (
	ErrConnClosed    = errors.New("conn closed")
	ErrReadBuffNil   = errors.New("read buff is nil")
	ErrCodecWriteNil = errors.New("codec write is nil")
	ErrCodecReadNil  = errors.New("codec read is nil")
)

Functions ¶

This section is empty.

Types ¶

type Decoder ¶

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

func NewDecoder ¶

func NewDecoder(r io.Reader, order binary.ByteOrder) *Decoder

func (*Decoder) Clean ¶

func (decoder *Decoder) Clean()

func (*Decoder) DecodeData ¶

func (decoder *Decoder) DecodeData(buf []byte) (n int, err error)

func (*Decoder) DecodeDataFull ¶

func (decoder *Decoder) DecodeDataFull(buf []byte) (n int, err error)

func (*Decoder) DecodeInt32 ¶

func (decoder *Decoder) DecodeInt32() (int32, error)

func (*Decoder) DecodeInt32Tiny ¶

func (decoder *Decoder) DecodeInt32Tiny() (int32, error)

func (*Decoder) DecodeInt8 ¶

func (decoder *Decoder) DecodeInt8() (int8, error)

func (*Decoder) DecodeInt8Tiny ¶

func (decoder *Decoder) DecodeInt8Tiny() (int8, error)

func (*Decoder) DecodeUInt32 ¶

func (decoder *Decoder) DecodeUInt32() (uint32, error)

func (*Decoder) DecodeUInt32Tiny ¶

func (decoder *Decoder) DecodeUInt32Tiny() (uint32, error)

func (*Decoder) DecodeUInt64 ¶

func (decoder *Decoder) DecodeUInt64() (uint64, error)

func (*Decoder) DecodeUInt64Tiny ¶

func (decoder *Decoder) DecodeUInt64Tiny() (uint64, error)

type Encoder ¶

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

func NewEncode ¶

func NewEncode(w io.Writer, order binary.ByteOrder) *Encoder

func (*Encoder) Clean ¶

func (encoder *Encoder) Clean()

func (*Encoder) EncodeData ¶

func (encoder *Encoder) EncodeData(data []byte) (err error)

func (*Encoder) EncodeInt32 ¶

func (encoder *Encoder) EncodeInt32(data int32) (err error)

func (*Encoder) EncodeInt32Tiny ¶

func (encoder *Encoder) EncodeInt32Tiny(data int32) (err error)

func (*Encoder) EncodeInt8 ¶

func (encoder *Encoder) EncodeInt8(data int8) (err error)

func (*Encoder) EncodeInt8Tiny ¶

func (encoder *Encoder) EncodeInt8Tiny(data int8) (err error)

func (*Encoder) EncodeUInt32 ¶

func (encoder *Encoder) EncodeUInt32(data uint32) (err error)

func (*Encoder) EncodeUInt32Tiny ¶

func (encoder *Encoder) EncodeUInt32Tiny(data uint32) (err error)

func (*Encoder) EncodeUInt64 ¶

func (encoder *Encoder) EncodeUInt64(data uint64) (err error)

func (*Encoder) EncodeUInt64Tiny ¶

func (encoder *Encoder) EncodeUInt64Tiny(data uint64) (err error)

func (*Encoder) Flush ¶

func (encoder *Encoder) Flush() error

type HeadCodec ¶

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

func NewHeadCodec ¶

func NewHeadCodec() *HeadCodec

func (*HeadCodec) Init ¶

func (hc *HeadCodec) Init(conn defs.IConnection) bool

func (*HeadCodec) Read ¶

func (hc *HeadCodec) Read() (defs.IPacket, error)

func (*HeadCodec) Write ¶

func (hc *HeadCodec) Write(packet defs.IPacket) error

type IOModule ¶

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

func NewIOModule ¶

func NewIOModule(conn defs.IConnection) *IOModule

func (*IOModule) Close ¶

func (ioModule *IOModule) Close()

func (*IOModule) Codec ¶

func (ioModule *IOModule) Codec(codec defs.ICodec) bool

func (*IOModule) OnConnectionLost ¶

func (ioModule *IOModule) OnConnectionLost()

func (*IOModule) UpdateCodec ¶

func (ioModule *IOModule) UpdateCodec(codec defs.ICodec)

func (*IOModule) Write ¶

func (ioModule *IOModule) Write(packet defs.IPacket)

func (*IOModule) WriteAwait ¶

func (ioModule *IOModule) WriteAwait(packet defs.IPacket) (response defs.IPacket, err error)

type RpcCall ¶

type RpcCall struct {
	Done chan *RpcCall
	// contains filtered or unexported fields
}

type StreamCodec ¶

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

func NewStreamCodec ¶

func NewStreamCodec() *StreamCodec

func (*StreamCodec) Init ¶

func (sc *StreamCodec) Init(conn defs.IConnection) bool

func (*StreamCodec) Read ¶

func (sc *StreamCodec) Read() (defs.IPacket, error)

func (*StreamCodec) Write ¶

func (sc *StreamCodec) Write(packet defs.IPacket) error

type WSCodec ¶

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

func NewWSCodec ¶

func NewWSCodec() *WSCodec

func (*WSCodec) Init ¶

func (wsCodec *WSCodec) Init(conn defs.IConnection) bool

func (*WSCodec) Read ¶

func (wsCodec *WSCodec) Read() (defs.IPacket, error)

func (*WSCodec) Write ¶

func (wsCodec *WSCodec) Write(packet defs.IPacket) error

Source Files ¶

View all Source files

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