messaging

README

rsocket-messaging-go

Provides messaging feature for RSocket.

Documentation

Index

• func RegisterCodec(mimeType string, marshal func(interface{}) ([]byte, error), ...) error
• type RequestBuilder
  • func Builder() *RequestBuilder
  • func (b *RequestBuilder) Build(ctx context.Context) (requester spi.Requester, err error)
  • func (b *RequestBuilder) ConnectTCP(host string, port int, opts ...rsocket.TransportOpts) *RequestBuilder
  • func (b *RequestBuilder) DataMimeType(mimeType string) *RequestBuilder
  • func (b *RequestBuilder) SetupData(data interface{}) *RequestBuilder
  • func (b *RequestBuilder) SetupMetadata(metadata interface{}, mimeType string) *RequestBuilder
  • func (b *RequestBuilder) SetupRoute(route string, args ...interface{}) *RequestBuilder
• type RouteContext
  • func (c RouteContext) Variable(name string) (string, bool)
  • func (c RouteContext) VariableOrCompute(name string, compute func() string) string
  • func (c RouteContext) VariableOrDefault(name string, defaultValue string) string
• type RouteHandler
• type Router
  • func NewRouter() *Router
  • func (r *Router) Fire(path string) error
  • func (r *Router) Route(path string, handler RouteHandler) (err error)

Functions

func RegisterCodec

func RegisterCodec(mimeType string, marshal func(interface{}) ([]byte, error), unmarshal func([]byte, interface{}) error) error

Types

type RequestBuilder

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

func Builder

func Builder() *RequestBuilder

func (*RequestBuilder) Build

func (b *RequestBuilder) Build(ctx context.Context) (requester spi.Requester, err error)

func (*RequestBuilder) ConnectTCP

func (b *RequestBuilder) ConnectTCP(host string, port int, opts ...rsocket.TransportOpts) *RequestBuilder

func (*RequestBuilder) DataMimeType

func (b *RequestBuilder) DataMimeType(mimeType string) *RequestBuilder

func (*RequestBuilder) SetupData

func (b *RequestBuilder) SetupData(data interface{}) *RequestBuilder

func (*RequestBuilder) SetupMetadata

func (b *RequestBuilder) SetupMetadata(metadata interface{}, mimeType string) *RequestBuilder

func (*RequestBuilder) SetupRoute

func (b *RequestBuilder) SetupRoute(route string, args ...interface{}) *RequestBuilder

type RouteContext

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

func (RouteContext) Variable

func (c RouteContext) Variable(name string) (string, bool)

func (RouteContext) VariableOrCompute

func (c RouteContext) VariableOrCompute(name string, compute func() string) string

func (RouteContext) VariableOrDefault

func (c RouteContext) VariableOrDefault(name string, defaultValue string) string

type RouteHandler

type RouteHandler = func(*RouteContext) error

type Router

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

func NewRouter

func NewRouter() *Router

func (*Router) Fire

func (r *Router) Fire(path string) error

func (*Router) Route

func (r *Router) Route(path string, handler RouteHandler) (err error)