internal

Documentation

Index

• func LoadCodec(mimeType string) (enc FnMarshal, dec FnUnmarshal, ok bool)
• func MarshalWithMimeType(v interface{}, mimeType string) (raw []byte, err error)
• func MkString(format string, args ...interface{}) (str string, err error)
• func NewFluxWithDecoder(origin flux.Flux, dec func([]byte, interface{}) error) spi.Flux
• func NewFluxWithError(err error) spi.Flux
• func NewMonoWithDecoder(origin mono.Mono, decode FnUnmarshal) *extraMono
• func NewMonoWithError(err error) *mustErrorMono
• func NewRequester(socket rsocket.RSocket, dataMimeType string) *requester
• func RegisterCodec(mimeType string, encoder FnMarshal, decoder FnUnmarshal) error
• func SplitPath(data []byte, atEOF bool) (advance int, token []byte, err error)
• func UnmarshalWithMimeType(raw []byte, v interface{}, mimeType string) error
• type FnMarshal
• type FnUnmarshal
• type PathTrie
  • func NewPathTrie() *PathTrie
  • func (p *PathTrie) AddPath(path string, value interface{}) (err error)
  • func (p *PathTrie) Find(path string) (variables *PathVariables, value interface{}, ok bool)
  • func (p *PathTrie) Load(path string) (*TrieNode, bool)
• type PathVariables
  • func (p *PathVariables) Get(name string) (variable string, ok bool)
  • func (p *PathVariables) GetOrCompute(name string, compute func() string) string
  • func (p *PathVariables) GetOrDefault(name string, defaultValue string) string
• type TrieNode
  • func (t *TrieNode) IsLeaf() bool
  • func (t *TrieNode) Name() string
  • func (t *TrieNode) Value() interface{}
• type TrieNodeFlag
• type TrieNodeLeaf

Functions

func LoadCodec

func LoadCodec(mimeType string) (enc FnMarshal, dec FnUnmarshal, ok bool)

func MarshalWithMimeType

func MarshalWithMimeType(v interface{}, mimeType string) (raw []byte, err error)

func MkString

func MkString(format string, args ...interface{}) (str string, err error)

func NewFluxWithDecoder

func NewFluxWithDecoder(origin flux.Flux, dec func([]byte, interface{}) error) spi.Flux

func NewFluxWithError

func NewFluxWithError(err error) spi.Flux

func NewMonoWithDecoder

func NewMonoWithDecoder(origin mono.Mono, decode FnUnmarshal) *extraMono

func NewMonoWithError

func NewMonoWithError(err error) *mustErrorMono

func NewRequester

func NewRequester(socket rsocket.RSocket, dataMimeType string) *requester

func RegisterCodec

func RegisterCodec(mimeType string, encoder FnMarshal, decoder FnUnmarshal) error

func SplitPath

func SplitPath(data []byte, atEOF bool) (advance int, token []byte, err error)

func UnmarshalWithMimeType

func UnmarshalWithMimeType(raw []byte, v interface{}, mimeType string) error

Types

type FnMarshal

type FnMarshal = func(interface{}) ([]byte, error)

type FnUnmarshal

type FnUnmarshal = func([]byte, interface{}) error

type PathTrie

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

func NewPathTrie

func NewPathTrie() *PathTrie

func (*PathTrie) AddPath

func (p *PathTrie) AddPath(path string, value interface{}) (err error)

func (*PathTrie) Find

func (p *PathTrie) Find(path string) (variables *PathVariables, value interface{}, ok bool)

func (*PathTrie) Load

func (p *PathTrie) Load(path string) (*TrieNode, bool)

type PathVariables

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

func (*PathVariables) Get

func (p *PathVariables) Get(name string) (variable string, ok bool)

func (*PathVariables) GetOrCompute

func (p *PathVariables) GetOrCompute(name string, compute func() string) string

func (*PathVariables) GetOrDefault

func (p *PathVariables) GetOrDefault(name string, defaultValue string) string

type TrieNode

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

func (*TrieNode) IsLeaf

func (t *TrieNode) IsLeaf() bool

func (*TrieNode) Name

func (t *TrieNode) Name() string

func (*TrieNode) Value

func (t *TrieNode) Value() interface{}

type TrieNodeFlag

type TrieNodeFlag uint8

type TrieNodeLeaf

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