metadata

Documentation

Overview

Package metadata for websocket or socket from rsocket-rpc-go Metadata

Index

• Constants
• type Metadata
  • func DecodeMetadata(b []byte) *Metadata
  • func EncodeMetadata(service, method, tracing string, meta map[string]string) (*Metadata, error)
  • func MallocMetadata() *Metadata
  • func (p *Metadata) Address() string
  • func (p *Metadata) Method() string
  • func (p *Metadata) Payload() []byte
  • func (p *Metadata) Service() string
  • func (p *Metadata) SetMethod(method string)
  • func (p *Metadata) String() string
  • func (p *Metadata) Tracing() string
  • func (p *Metadata) Version() string
  • func (p *Metadata) VersionUint16() uint16

Constants

const RsocketRpcVersion = uint16(1)

RsocketRpcVersion rsocket-rpc version

Types

type Metadata

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

func DecodeMetadata

func DecodeMetadata(b []byte) *Metadata

func EncodeMetadata

func EncodeMetadata(service, method, tracing string, meta map[string]string) (*Metadata, error)

func MallocMetadata

func MallocMetadata() *Metadata

func (*Metadata) Address

func (p *Metadata) Address() string

func (*Metadata) Method

func (p *Metadata) Method() string

func (*Metadata) Payload

func (p *Metadata) Payload() []byte

func (*Metadata) Service

func (p *Metadata) Service() string

func (*Metadata) SetMethod

func (p *Metadata) SetMethod(method string)

func (*Metadata) String

func (p *Metadata) String() string

func (*Metadata) Tracing

func (p *Metadata) Tracing() string

func (*Metadata) Version

func (p *Metadata) Version() string

func (*Metadata) VersionUint16

func (p *Metadata) VersionUint16() uint16