pmtp

package
v0.0.0-...-ecb2b82 Latest Latest
Warning

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

 Go to latest Published: May 7, 2026 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func EncodeCode 

func EncodeCode(b buffer.Buffer, v Code) (int, error)

func EncodeConnectCompression 

func EncodeConnectCompression(b buffer.Buffer, v ConnectCompression) (int, error)

func EncodeVersion 

func EncodeVersion(b buffer.Buffer, v Version) (int, error)

Types

type Batch 

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

func GetBatch 

func GetBatch(b []byte) Batch

func GetBatchErr 

func GetBatchErr(b []byte) (_ Batch, size int, err error)

func NewBatch 

func NewBatch(msg baseproto.Message) Batch

func ParseBatch 

func ParseBatch(b []byte) (_ Batch, size int, err error)

func (Batch) Clone 

func (m Batch) Clone() Batch

func (Batch) CloneToArena 

func (m Batch) CloneToArena(a alloc.Arena) Batch

func (Batch) CloneToBuffer 

func (m Batch) CloneToBuffer(b buffer.Buffer) Batch

func (Batch) HasList 

func (m Batch) HasList() bool

func (Batch) IsEmpty 

func (m Batch) IsEmpty() bool

func (Batch) List 

func (m Batch) List() baseproto.TypedList[Message]

func (Batch) Unwrap 

func (m Batch) Unwrap() baseproto.Message

type BatchBuilder 

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

func NewBatchBuilder 

func NewBatchBuilder(buf alloc.Buffer) BatchBuilder

func (BatchBuilder) Build 

func (b BatchBuilder) Build() (Message, error)

func (BatchBuilder) Close 

func (b BatchBuilder) Close(id bin.Bin128, data []byte) (BatchBuilder, error)

func (BatchBuilder) Data 

func (b BatchBuilder) Data(id bin.Bin128, data []byte) (BatchBuilder, error)

func (BatchBuilder) Open 

func (b BatchBuilder) Open(id bin.Bin128, data []byte, window int32) (BatchBuilder, error)

type BatchWriter 

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

func NewBatchWriter 

func NewBatchWriter() BatchWriter

func NewBatchWriterBuffer 

func NewBatchWriterBuffer(b buffer.Buffer) BatchWriter

func NewBatchWriterTo 

func NewBatchWriterTo(w baseproto.MessageWriter) BatchWriter

func (BatchWriter) Build 

func (w BatchWriter) Build() (_ Batch, err error)

func (BatchWriter) End 

func (w BatchWriter) End() error

func (BatchWriter) List 

func (w BatchWriter) List() baseproto.MessageListWriter[MessageWriter]

func (BatchWriter) Merge 

func (w BatchWriter) Merge(msg Batch) error

func (BatchWriter) Unwrap 

func (w BatchWriter) Unwrap() baseproto.MessageWriter

type ChannelClose 

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

func GetChannelClose 

func GetChannelClose(b []byte) ChannelClose

func GetChannelCloseErr 

func GetChannelCloseErr(b []byte) (_ ChannelClose, size int, err error)

func NewChannelClose 

func NewChannelClose(msg baseproto.Message) ChannelClose

func ParseChannelClose 

func ParseChannelClose(b []byte) (_ ChannelClose, size int, err error)

func (ChannelClose) Clone 

func (m ChannelClose) Clone() ChannelClose

func (ChannelClose) CloneToArena 

func (m ChannelClose) CloneToArena(a alloc.Arena) ChannelClose

func (ChannelClose) CloneToBuffer 

func (m ChannelClose) CloneToBuffer(b buffer.Buffer) ChannelClose

func (ChannelClose) Data 

func (m ChannelClose) Data() baseproto.Bytes

func (ChannelClose) HasData 

func (m ChannelClose) HasData() bool

func (ChannelClose) HasId 

func (m ChannelClose) HasId() bool

func (ChannelClose) Id 

func (m ChannelClose) Id() bin.Bin128

func (ChannelClose) IsEmpty 

func (m ChannelClose) IsEmpty() bool

func (ChannelClose) Unwrap 

func (m ChannelClose) Unwrap() baseproto.Message

type ChannelCloseWriter 

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

func NewChannelCloseWriter 

func NewChannelCloseWriter() ChannelCloseWriter

func NewChannelCloseWriterBuffer 

func NewChannelCloseWriterBuffer(b buffer.Buffer) ChannelCloseWriter

func NewChannelCloseWriterTo 

func NewChannelCloseWriterTo(w baseproto.MessageWriter) ChannelCloseWriter

func (ChannelCloseWriter) Build 

func (w ChannelCloseWriter) Build() (_ ChannelClose, err error)

func (ChannelCloseWriter) Data 

func (w ChannelCloseWriter) Data(v []byte)

func (ChannelCloseWriter) End 

func (w ChannelCloseWriter) End() error

func (ChannelCloseWriter) Id 

func (w ChannelCloseWriter) Id(v bin.Bin128)

func (ChannelCloseWriter) Merge 

func (w ChannelCloseWriter) Merge(msg ChannelClose) error

func (ChannelCloseWriter) Unwrap 

func (w ChannelCloseWriter) Unwrap() baseproto.MessageWriter

type ChannelData 

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

func GetChannelData 

func GetChannelData(b []byte) ChannelData

func GetChannelDataErr 

func GetChannelDataErr(b []byte) (_ ChannelData, size int, err error)

func NewChannelData 

func NewChannelData(msg baseproto.Message) ChannelData

func ParseChannelData 

func ParseChannelData(b []byte) (_ ChannelData, size int, err error)

func (ChannelData) Clone 

func (m ChannelData) Clone() ChannelData

func (ChannelData) CloneToArena 

func (m ChannelData) CloneToArena(a alloc.Arena) ChannelData

func (ChannelData) CloneToBuffer 

func (m ChannelData) CloneToBuffer(b buffer.Buffer) ChannelData

func (ChannelData) Data 

func (m ChannelData) Data() baseproto.Bytes

func (ChannelData) HasData 

func (m ChannelData) HasData() bool

func (ChannelData) HasId 

func (m ChannelData) HasId() bool

func (ChannelData) Id 

func (m ChannelData) Id() bin.Bin128

func (ChannelData) IsEmpty 

func (m ChannelData) IsEmpty() bool

func (ChannelData) Unwrap 

func (m ChannelData) Unwrap() baseproto.Message

type ChannelDataWriter 

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

func NewChannelDataWriter 

func NewChannelDataWriter() ChannelDataWriter

func NewChannelDataWriterBuffer 

func NewChannelDataWriterBuffer(b buffer.Buffer) ChannelDataWriter

func NewChannelDataWriterTo 

func NewChannelDataWriterTo(w baseproto.MessageWriter) ChannelDataWriter

func (ChannelDataWriter) Build 

func (w ChannelDataWriter) Build() (_ ChannelData, err error)

func (ChannelDataWriter) Data 

func (w ChannelDataWriter) Data(v []byte)

func (ChannelDataWriter) End 

func (w ChannelDataWriter) End() error

func (ChannelDataWriter) Id 

func (w ChannelDataWriter) Id(v bin.Bin128)

func (ChannelDataWriter) Merge 

func (w ChannelDataWriter) Merge(msg ChannelData) error

func (ChannelDataWriter) Unwrap 

func (w ChannelDataWriter) Unwrap() baseproto.MessageWriter

type ChannelOpen 

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

func GetChannelOpen 

func GetChannelOpen(b []byte) ChannelOpen

func GetChannelOpenErr 

func GetChannelOpenErr(b []byte) (_ ChannelOpen, size int, err error)

func NewChannelOpen 

func NewChannelOpen(msg baseproto.Message) ChannelOpen

func ParseChannelOpen 

func ParseChannelOpen(b []byte) (_ ChannelOpen, size int, err error)

func (ChannelOpen) Clone 

func (m ChannelOpen) Clone() ChannelOpen

func (ChannelOpen) CloneToArena 

func (m ChannelOpen) CloneToArena(a alloc.Arena) ChannelOpen

func (ChannelOpen) CloneToBuffer 

func (m ChannelOpen) CloneToBuffer(b buffer.Buffer) ChannelOpen

func (ChannelOpen) Data 

func (m ChannelOpen) Data() baseproto.Bytes

func (ChannelOpen) HasData 

func (m ChannelOpen) HasData() bool

func (ChannelOpen) HasId 

func (m ChannelOpen) HasId() bool

func (ChannelOpen) HasWindow 

func (m ChannelOpen) HasWindow() bool

func (ChannelOpen) Id 

func (m ChannelOpen) Id() bin.Bin128

func (ChannelOpen) IsEmpty 

func (m ChannelOpen) IsEmpty() bool

func (ChannelOpen) Unwrap 

func (m ChannelOpen) Unwrap() baseproto.Message

func (ChannelOpen) Window 

func (m ChannelOpen) Window() int32

type ChannelOpenWriter 

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

func NewChannelOpenWriter 

func NewChannelOpenWriter() ChannelOpenWriter

func NewChannelOpenWriterBuffer 

func NewChannelOpenWriterBuffer(b buffer.Buffer) ChannelOpenWriter

func NewChannelOpenWriterTo 

func NewChannelOpenWriterTo(w baseproto.MessageWriter) ChannelOpenWriter

func (ChannelOpenWriter) Build 

func (w ChannelOpenWriter) Build() (_ ChannelOpen, err error)

func (ChannelOpenWriter) Data 

func (w ChannelOpenWriter) Data(v []byte)

func (ChannelOpenWriter) End 

func (w ChannelOpenWriter) End() error

func (ChannelOpenWriter) Id 

func (w ChannelOpenWriter) Id(v bin.Bin128)

func (ChannelOpenWriter) Merge 

func (w ChannelOpenWriter) Merge(msg ChannelOpen) error

func (ChannelOpenWriter) Unwrap 

func (w ChannelOpenWriter) Unwrap() baseproto.MessageWriter

func (ChannelOpenWriter) Window 

func (w ChannelOpenWriter) Window(v int32)

type ChannelWindow 

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

func GetChannelWindow 

func GetChannelWindow(b []byte) ChannelWindow

func GetChannelWindowErr 

func GetChannelWindowErr(b []byte) (_ ChannelWindow, size int, err error)

func NewChannelWindow 

func NewChannelWindow(msg baseproto.Message) ChannelWindow

func ParseChannelWindow 

func ParseChannelWindow(b []byte) (_ ChannelWindow, size int, err error)

func (ChannelWindow) Clone 

func (m ChannelWindow) Clone() ChannelWindow

func (ChannelWindow) CloneToArena 

func (m ChannelWindow) CloneToArena(a alloc.Arena) ChannelWindow

func (ChannelWindow) CloneToBuffer 

func (m ChannelWindow) CloneToBuffer(b buffer.Buffer) ChannelWindow

func (ChannelWindow) Delta 

func (m ChannelWindow) Delta() int32

func (ChannelWindow) HasDelta 

func (m ChannelWindow) HasDelta() bool

func (ChannelWindow) HasId 

func (m ChannelWindow) HasId() bool

func (ChannelWindow) Id 

func (m ChannelWindow) Id() bin.Bin128

func (ChannelWindow) IsEmpty 

func (m ChannelWindow) IsEmpty() bool

func (ChannelWindow) Unwrap 

func (m ChannelWindow) Unwrap() baseproto.Message

type ChannelWindowWriter 

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

func NewChannelWindowWriter 

func NewChannelWindowWriter() ChannelWindowWriter

func NewChannelWindowWriterBuffer 

func NewChannelWindowWriterBuffer(b buffer.Buffer) ChannelWindowWriter

func NewChannelWindowWriterTo 

func NewChannelWindowWriterTo(w baseproto.MessageWriter) ChannelWindowWriter

func (ChannelWindowWriter) Build 

func (w ChannelWindowWriter) Build() (_ ChannelWindow, err error)

func (ChannelWindowWriter) Delta 

func (w ChannelWindowWriter) Delta(v int32)

func (ChannelWindowWriter) End 

func (w ChannelWindowWriter) End() error

func (ChannelWindowWriter) Id 

func (w ChannelWindowWriter) Id(v bin.Bin128)

func (ChannelWindowWriter) Merge 

func (w ChannelWindowWriter) Merge(msg ChannelWindow) error

func (ChannelWindowWriter) Unwrap 

func (w ChannelWindowWriter) Unwrap() baseproto.MessageWriter

type Code 

type Code int32
const (
	Code_Undefined       Code = 0
	Code_ConnectRequest  Code = 1
	Code_ConnectResponse Code = 2
	Code_Batch           Code = 3
	Code_ChannelOpen     Code = 10
	Code_ChannelClose    Code = 11
	Code_ChannelData     Code = 12
	Code_ChannelWindow   Code = 13
)

func DecodeCode 

func DecodeCode(b []byte) (v Code, size int, err error)

func GetCode 

func GetCode(b []byte) Code

func (Code) String 

func (e Code) String() string

type ConnectCompression 

type ConnectCompression int32
const (
	ConnectCompression_None ConnectCompression = 0
	ConnectCompression_Lz4  ConnectCompression = 1
)

func DecodeConnectCompression 

func DecodeConnectCompression(b []byte) (v ConnectCompression, size int, err error)

func GetConnectCompression 

func GetConnectCompression(b []byte) ConnectCompression

func (ConnectCompression) String 

func (e ConnectCompression) String() string

type ConnectInput 

type ConnectInput struct {
	Versions     []Version
	Compressions []ConnectCompression
}

func NewConnectInput 

func NewConnectInput() ConnectInput

func (ConnectInput) Build 

func (in ConnectInput) Build() (Message, error)

func (ConnectInput) WithCompression 

func (in ConnectInput) WithCompression(enabled bool) ConnectInput

func (ConnectInput) WithCompressionLZ4 

func (in ConnectInput) WithCompressionLZ4() ConnectInput

type ConnectRequest 

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

func GetConnectRequest 

func GetConnectRequest(b []byte) ConnectRequest

func GetConnectRequestErr 

func GetConnectRequestErr(b []byte) (_ ConnectRequest, size int, err error)

func NewConnectRequest 

func NewConnectRequest(msg baseproto.Message) ConnectRequest

func ParseConnectRequest 

func ParseConnectRequest(b []byte) (_ ConnectRequest, size int, err error)

func (ConnectRequest) Clone 

func (m ConnectRequest) Clone() ConnectRequest

func (ConnectRequest) CloneToArena 

func (m ConnectRequest) CloneToArena(a alloc.Arena) ConnectRequest

func (ConnectRequest) CloneToBuffer 

func (m ConnectRequest) CloneToBuffer(b buffer.Buffer) ConnectRequest

func (ConnectRequest) Compression 

func (m ConnectRequest) Compression() baseproto.TypedList[ConnectCompression]

func (ConnectRequest) HasCompression 

func (m ConnectRequest) HasCompression() bool

func (ConnectRequest) HasVersions 

func (m ConnectRequest) HasVersions() bool

func (ConnectRequest) IsEmpty 

func (m ConnectRequest) IsEmpty() bool

func (ConnectRequest) Unwrap 

func (m ConnectRequest) Unwrap() baseproto.Message

func (ConnectRequest) Versions 

func (m ConnectRequest) Versions() baseproto.TypedList[Version]

type ConnectRequestWriter 

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

func NewConnectRequestWriter 

func NewConnectRequestWriter() ConnectRequestWriter

func NewConnectRequestWriterBuffer 

func NewConnectRequestWriterBuffer(b buffer.Buffer) ConnectRequestWriter

func NewConnectRequestWriterTo 

func NewConnectRequestWriterTo(w baseproto.MessageWriter) ConnectRequestWriter

func (ConnectRequestWriter) Build 

func (w ConnectRequestWriter) Build() (_ ConnectRequest, err error)

func (ConnectRequestWriter) Compression 

func (w ConnectRequestWriter) Compression() baseproto.ValueListWriter[ConnectCompression]

func (ConnectRequestWriter) End 

func (w ConnectRequestWriter) End() error

func (ConnectRequestWriter) Merge 

func (w ConnectRequestWriter) Merge(msg ConnectRequest) error

func (ConnectRequestWriter) Unwrap 

func (w ConnectRequestWriter) Unwrap() baseproto.MessageWriter

func (ConnectRequestWriter) Versions 

func (w ConnectRequestWriter) Versions() baseproto.ValueListWriter[Version]

type ConnectResponse 

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

func GetConnectResponse 

func GetConnectResponse(b []byte) ConnectResponse

func GetConnectResponseErr 

func GetConnectResponseErr(b []byte) (_ ConnectResponse, size int, err error)

func NewConnectResponse 

func NewConnectResponse(msg baseproto.Message) ConnectResponse

func ParseConnectResponse 

func ParseConnectResponse(b []byte) (_ ConnectResponse, size int, err error)

func (ConnectResponse) Clone 

func (m ConnectResponse) Clone() ConnectResponse

func (ConnectResponse) CloneToArena 

func (m ConnectResponse) CloneToArena(a alloc.Arena) ConnectResponse

func (ConnectResponse) CloneToBuffer 

func (m ConnectResponse) CloneToBuffer(b buffer.Buffer) ConnectResponse

func (ConnectResponse) Compression 

func (m ConnectResponse) Compression() ConnectCompression

func (ConnectResponse) Error 

func (m ConnectResponse) Error() baseproto.String

func (ConnectResponse) HasCompression 

func (m ConnectResponse) HasCompression() bool

func (ConnectResponse) HasError 

func (m ConnectResponse) HasError() bool

func (ConnectResponse) HasOk 

func (m ConnectResponse) HasOk() bool

func (ConnectResponse) HasVersion 

func (m ConnectResponse) HasVersion() bool

func (ConnectResponse) IsEmpty 

func (m ConnectResponse) IsEmpty() bool

func (ConnectResponse) Ok 

func (m ConnectResponse) Ok() bool

func (ConnectResponse) Unwrap 

func (m ConnectResponse) Unwrap() baseproto.Message

func (ConnectResponse) Version 

func (m ConnectResponse) Version() Version

type ConnectResponseWriter 

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

func NewConnectResponseWriter 

func NewConnectResponseWriter() ConnectResponseWriter

func NewConnectResponseWriterBuffer 

func NewConnectResponseWriterBuffer(b buffer.Buffer) ConnectResponseWriter

func NewConnectResponseWriterTo 

func NewConnectResponseWriterTo(w baseproto.MessageWriter) ConnectResponseWriter

func (ConnectResponseWriter) Build 

func (w ConnectResponseWriter) Build() (_ ConnectResponse, err error)

func (ConnectResponseWriter) Compression 

func (w ConnectResponseWriter) Compression(v ConnectCompression)

func (ConnectResponseWriter) End 

func (w ConnectResponseWriter) End() error

func (ConnectResponseWriter) Error 

func (w ConnectResponseWriter) Error(v string)

func (ConnectResponseWriter) Merge 

func (w ConnectResponseWriter) Merge(msg ConnectResponse) error

func (ConnectResponseWriter) Ok 

func (w ConnectResponseWriter) Ok(v bool)

func (ConnectResponseWriter) Unwrap 

func (w ConnectResponseWriter) Unwrap() baseproto.MessageWriter

func (ConnectResponseWriter) Version 

func (w ConnectResponseWriter) Version(v Version)

type Message 

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

func BuildChannelClose 

func BuildChannelClose(w MessageWriter, id bin.Bin128, data []byte) (Message, error)

func BuildChannelData 

func BuildChannelData(w MessageWriter, id bin.Bin128, data []byte) (Message, error)

func BuildChannelMessage 

func BuildChannelMessage(buf alloc.Buffer, input MessageInput) (Message, error)

func BuildChannelOpen 

func BuildChannelOpen(w MessageWriter, id bin.Bin128, data []byte, window int32) (Message, error)

func BuildChannelWindow 

func BuildChannelWindow(w MessageWriter, id bin.Bin128, delta int32) (Message, error)

func BuildConnectError 

func BuildConnectError(errorMessage string) (Message, error)

func BuildConnectRequest 

func BuildConnectRequest(input ConnectInput) (Message, error)

func BuildConnectResponse 

func BuildConnectResponse(version Version, comp ConnectCompression) (Message, error)

func GetMessage 

func GetMessage(b []byte) Message

func GetMessageErr 

func GetMessageErr(b []byte) (_ Message, size int, err error)

func NewMessage 

func NewMessage(msg baseproto.Message) Message

func ParseMessage 

func ParseMessage(b []byte) (_ Message, size int, err error)

func (Message) Batch 

func (m Message) Batch() Batch

func (Message) ChannelClose 

func (m Message) ChannelClose() ChannelClose

func (Message) ChannelData 

func (m Message) ChannelData() ChannelData

func (Message) ChannelOpen 

func (m Message) ChannelOpen() ChannelOpen

func (Message) ChannelWindow 

func (m Message) ChannelWindow() ChannelWindow

func (Message) Clone 

func (m Message) Clone() Message

func (Message) CloneToArena 

func (m Message) CloneToArena(a alloc.Arena) Message

func (Message) CloneToBuffer 

func (m Message) CloneToBuffer(b buffer.Buffer) Message

func (Message) Code 

func (m Message) Code() Code

func (Message) ConnectRequest 

func (m Message) ConnectRequest() ConnectRequest

func (Message) ConnectResponse 

func (m Message) ConnectResponse() ConnectResponse

func (Message) HasBatch 

func (m Message) HasBatch() bool

func (Message) HasChannelClose 

func (m Message) HasChannelClose() bool

func (Message) HasChannelData 

func (m Message) HasChannelData() bool

func (Message) HasChannelOpen 

func (m Message) HasChannelOpen() bool

func (Message) HasChannelWindow 

func (m Message) HasChannelWindow() bool

func (Message) HasCode 

func (m Message) HasCode() bool

func (Message) HasConnectRequest 

func (m Message) HasConnectRequest() bool

func (Message) HasConnectResponse 

func (m Message) HasConnectResponse() bool

func (Message) IsEmpty 

func (m Message) IsEmpty() bool

func (Message) Unwrap 

func (m Message) Unwrap() baseproto.Message

type MessageInput 

type MessageInput struct {
	Id     bin.Bin128
	Data   []byte
	Window int32

	Open  bool
	Close bool
}

type MessageWriter 

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

func NewMessageWriter 

func NewMessageWriter() MessageWriter

func NewMessageWriterBuffer 

func NewMessageWriterBuffer(b buffer.Buffer) MessageWriter

func NewMessageWriterTo 

func NewMessageWriterTo(w baseproto.MessageWriter) MessageWriter

func (MessageWriter) Batch 

func (w MessageWriter) Batch() BatchWriter

func (MessageWriter) Build 

func (w MessageWriter) Build() (_ Message, err error)

func (MessageWriter) ChannelClose 

func (w MessageWriter) ChannelClose() ChannelCloseWriter

func (MessageWriter) ChannelData 

func (w MessageWriter) ChannelData() ChannelDataWriter

func (MessageWriter) ChannelOpen 

func (w MessageWriter) ChannelOpen() ChannelOpenWriter

func (MessageWriter) ChannelWindow 

func (w MessageWriter) ChannelWindow() ChannelWindowWriter

func (MessageWriter) Code 

func (w MessageWriter) Code(v Code)

func (MessageWriter) ConnectRequest 

func (w MessageWriter) ConnectRequest() ConnectRequestWriter

func (MessageWriter) ConnectResponse 

func (w MessageWriter) ConnectResponse() ConnectResponseWriter

func (MessageWriter) CopyBatch 

func (w MessageWriter) CopyBatch(v Batch) error

func (MessageWriter) CopyChannelClose 

func (w MessageWriter) CopyChannelClose(v ChannelClose) error

func (MessageWriter) CopyChannelData 

func (w MessageWriter) CopyChannelData(v ChannelData) error

func (MessageWriter) CopyChannelOpen 

func (w MessageWriter) CopyChannelOpen(v ChannelOpen) error

func (MessageWriter) CopyChannelWindow 

func (w MessageWriter) CopyChannelWindow(v ChannelWindow) error

func (MessageWriter) CopyConnectRequest 

func (w MessageWriter) CopyConnectRequest(v ConnectRequest) error

func (MessageWriter) CopyConnectResponse 

func (w MessageWriter) CopyConnectResponse(v ConnectResponse) error

func (MessageWriter) End 

func (w MessageWriter) End() error

func (MessageWriter) Merge 

func (w MessageWriter) Merge(msg Message) error

func (MessageWriter) Unwrap 

func (w MessageWriter) Unwrap() baseproto.MessageWriter

type Version 

type Version int32
const (
	Version_Undefined Version = 0
	Version_Version10 Version = 10
)

func DecodeVersion 

func DecodeVersion(b []byte) (v Version, size int, err error)

func GetVersion 

func GetVersion(b []byte) Version

func (Version) String 

func (e Version) String() string

Source Files

View all Source files

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.