metadata

Documentation

Overview

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

Index

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

Constants

const RsocketRpcVersion = uint16(1)

RsocketRpcVersion rsocket-rpc version

Types

type Metadata

type Metadata struct {
	V  string            `json:"version"`
	S  string            `json:"service"`
	M  string            `json:"method"`
	T  string            `json:"trace"`
	A  string            `json:"address"`
	P  []byte            `json:"payload"`
	Md map[string]string `json:"meta"`
}

func DecodeMetadata

func DecodeMetadata(payload []byte) (*Metadata, error)

func EncodeMetadata

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

func MallocMetadata

func MallocMetadata() *Metadata

func (*Metadata) Address

func (m *Metadata) Address() string

func (*Metadata) GetMeta

func (m *Metadata) GetMeta(key string) string

func (*Metadata) Method

func (m *Metadata) Method() string

func (*Metadata) Payload

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

func (*Metadata) Service

func (m *Metadata) Service() string

func (*Metadata) SetMeta

func (m *Metadata) SetMeta(key, value string)

func (*Metadata) SetMethod

func (m *Metadata) SetMethod(method string)

func (*Metadata) String

func (m *Metadata) String() string

func (*Metadata) Tracing

func (m *Metadata) Tracing() string

func (*Metadata) Version

func (m *Metadata) Version() string

func (*Metadata) VersionUint16

func (m *Metadata) VersionUint16() uint16