encoding

package
v1.10.0 Latest Latest
Warning

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

Go to latest
Published: Aug 28, 2020 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Version = byte(0)
)

Variables

View Source
var (
	ErrInvalidLengthAddons        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAddons          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAddons = fmt.Errorf("proto: unexpected end of group")
)

Functions

func DecodeBodyAddons

func DecodeBodyAddons(reader io.Reader, request *protocol.RequestHeader, addons *Addons) buf.Reader

DecodeBodyAddons returns a Reader from which caller can fetch decrypted body.

func DecodeResponseHeader

func DecodeResponseHeader(reader io.Reader, request *protocol.RequestHeader, responseAddons *Addons) error

DecodeResponseHeader decodes and returns (if successful) a ResponseHeader from an input stream.

func EncodeBodyAddons

func EncodeBodyAddons(writer io.Writer, request *protocol.RequestHeader, addons *Addons) buf.Writer

EncodeBodyAddons returns a Writer that auto-encrypt content written by caller.

func EncodeHeaderAddons

func EncodeHeaderAddons(buffer *buf.Buffer, addons *Addons) error

func EncodeRequestHeader

func EncodeRequestHeader(writer io.Writer, request *protocol.RequestHeader, requestAddons *Addons) error

EncodeRequestHeader writes encoded request header into the given writer.

func EncodeResponseHeader

func EncodeResponseHeader(writer io.Writer, request *protocol.RequestHeader, responseAddons *Addons) error

EncodeResponseHeader writes encoded response header into the given writer.

Types

type Addons

type Addons struct {
	Scheduler            string   `protobuf:"bytes,1,opt,name=Scheduler,proto3" json:"Scheduler,omitempty"`
	SchedulerV           []byte   `protobuf:"bytes,2,opt,name=SchedulerV,proto3" json:"SchedulerV,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func DecodeHeaderAddons

func DecodeHeaderAddons(buffer *buf.Buffer, reader io.Reader) (*Addons, error)

func DecodeRequestHeader

func DecodeRequestHeader(reader io.Reader, validator *vless.Validator) (*protocol.RequestHeader, *Addons, error, *buf.Buffer)

DecodeRequestHeader decodes and returns (if successful) a RequestHeader from an input stream.

func (*Addons) Descriptor

func (*Addons) Descriptor() ([]byte, []int)

func (*Addons) GetScheduler

func (m *Addons) GetScheduler() string

func (*Addons) GetSchedulerV

func (m *Addons) GetSchedulerV() []byte

func (*Addons) Marshal

func (m *Addons) Marshal() (dAtA []byte, err error)

func (*Addons) MarshalTo

func (m *Addons) MarshalTo(dAtA []byte) (int, error)

func (*Addons) MarshalToSizedBuffer

func (m *Addons) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Addons) ProtoMessage

func (*Addons) ProtoMessage()

func (*Addons) Reset

func (m *Addons) Reset()

func (*Addons) Size

func (m *Addons) Size() (n int)

func (*Addons) String

func (m *Addons) String() string

func (*Addons) Unmarshal

func (m *Addons) Unmarshal(dAtA []byte) error

func (*Addons) XXX_DiscardUnknown

func (m *Addons) XXX_DiscardUnknown()

func (*Addons) XXX_Marshal

func (m *Addons) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Addons) XXX_Merge

func (m *Addons) XXX_Merge(src proto.Message)

func (*Addons) XXX_Size

func (m *Addons) XXX_Size() int

func (*Addons) XXX_Unmarshal

func (m *Addons) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

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