sabuhp

package module

Go to main page

Versions in this module

v0

v0.3.1

Jan 23, 2021

Changes in this version

type Message

+ func (m *Message) ReplyTo() *Message

+ func (m *Message) ReplyToWith(params Params, meta Params, payload []byte) *Message

v0.3.0

Jan 10, 2021

v0.2.9

Dec 27, 2020

v0.2.8

Dec 27, 2020

v0.2.7

Dec 27, 2020

v0.2.6

Dec 27, 2020

v0.2.5

Dec 26, 2020

v0.2.4

Dec 26, 2020

v0.2.3

Dec 26, 2020

v0.2.2

Dec 26, 2020

v0.2.1

Dec 25, 2020

v0.2.0

Dec 23, 2020

v0.1.9

Dec 23, 2020

v0.1.8

Dec 23, 2020

v0.1.7

Dec 23, 2020

v0.1.6

Dec 23, 2020

v0.1.5

Dec 22, 2020

Changes in this version

type MessageMeta

+ Path string

v0.1.4

Dec 22, 2020

Changes in this version

+ type CodecTranslator struct

+ Codec Codec

+ Logger Logger

+ func NewCodecTranslator(codec Codec, logger Logger) *CodecTranslator

+ func (r *CodecTranslator) Translate(res http.ResponseWriter, m *Message) error

+ func (r *CodecTranslator) TranslateBytes(res http.ResponseWriter, data []byte, m MessageMeta) error

+ func (r *CodecTranslator) TranslateWriter(res http.ResponseWriter, w io.WriterTo, m MessageMeta) error

+ type MessageMeta struct

+ ContentType string

+ Cookies []Cookie

+ Form url.Values

+ Headers Header

+ MultipartReader *multipart.Reader

+ PostForm url.Values

+ Query url.Values

+ SuggestedStatusCode int

+ type SocketHandler func(b *Message, from Socket) error

+ type Translator interface

+ Translate func(req http.ResponseWriter, message *Message) error

+ TranslateBytes func(req http.ResponseWriter, data []byte, message MessageMeta) error

+ TranslateWriter func(req http.ResponseWriter, w io.WriterTo, meta MessageMeta) error

+ type WrappedCodec interface

+ Decode func(b []byte) (*WrappedPayload, error)

+ Encode func(payload *WrappedPayload) ([]byte, error)

+ type WrappedCodecTransposer struct

+ Codec Codec

+ Logger Logger

+ WrappedCodec WrappedCodec

+ func NewWrappedCodecTransposer(codec Codec, wrappedCodec WrappedCodec, logger Logger) *WrappedCodecTransposer

+ func (r *WrappedCodecTransposer) Transpose(data []byte) (*Message, *WrappedPayload, error)

+ type WrappedPayload struct

+ ContentType string

+ Payload []byte

+ func NewWrappedPayload(contentType string, payload []byte) *WrappedPayload

+ func WrappedMessagePayload(payload []byte) *WrappedPayload

+ type WrappedTransposer interface

+ Transpose func([]byte) (*Message, *WrappedPayload, error)

v0.1.3

Dec 21, 2020

Changes in this version

+ const DONE

+ const MessageContentType

+ const NOTDONE

+ const SUBSCRIBE

+ const TimeFormat

+ const UNSUBSCRIBE

+ var BodyToLargeErr = &requestTooLargeErr

+ func IsTokenRune(r rune) bool

+ func MaxBytesReader(r io.ReadCloser, n int64) io.ReadCloser

+ type BinaryPayload []byte

+ func (b BinaryPayload) Copy() Payload

+ func (b BinaryPayload) Type() PayloadType

+ type Channel interface

+ Close func()

+ Err func() error

+ type Client interface

+ Send func(data []byte, timeout time.Duration) error

+ type Codec interface

+ Decode func(b []byte) (*Message, error)

+ Encode func(msg *Message) ([]byte, error)

+ type CodecTransposer struct

+ Codec Codec

+ Logger Logger

+ MaxBodySize int64

+ func NewCodecTransposer(codec Codec, logger Logger) *CodecTransposer

+ func (r *CodecTransposer) Transpose(req *http.Request, params Params) (*Message, error)

+ type CodecWriter struct

+ Client Client

+ Codec Codec

+ Logger Logger

+ func NewCodecWriter(client Client, codec Codec, logger Logger) *CodecWriter

+ func (c *CodecWriter) Send(msg *Message, timeout time.Duration) error

+ type Conn interface

+ type Cookie struct

+ Domain string

+ Expires time.Time

+ HttpOnly bool

+ MaxAge int

+ Name string

+ Path string

+ Raw string

+ RawExpires string

+ SameSite SameSite

+ Secure bool

+ Unparsed []string

+ Value string

+ func ReadCookies(h Header, filter string) []Cookie

+ func ReadSetCookies(h Header) []Cookie

+ func (c *Cookie) String() string

+ type DeliveryMark int

+ const SendToAll

+ const SendToOne

+ type ErrChannel struct

+ Error error

+ func (n *ErrChannel) Close()

+ func (n *ErrChannel) Err() error

+ type ErrorWaiter interface

+ Wait func() error

+ type Handler interface

+ Handle func(http.ResponseWriter, *http.Request, Params)

+ type HandlerFunc func(http.ResponseWriter, *http.Request, Params)

+ func (h HandlerFunc) Handle(rw http.ResponseWriter, r *http.Request, p Params)

+ type Header map[string][]string

+ func (h Header) Add(k string, v string)

+ func (h Header) Delete(k string)

+ func (h Header) Get(k string) string

+ func (h Header) Set(k string, v string)

+ func (h Header) Values(k string) []string

+ type HeaderModifications func(header http.Header)

+ type HttpMatcher interface

+ Match func(http.ResponseWriter, *http.Request, Params)

+ type HttpResponsePayload struct

+ func (h *HttpResponsePayload) Copy() Payload

+ func (h *HttpResponsePayload) Type() PayloadType

+ type HttpResponseWriterPayload struct

+ func (h *HttpResponseWriterPayload) Copy() Payload

+ func (h *HttpResponseWriterPayload) Type() PayloadType

+ type HttpWrapper func(Handler) Handler

+ type HttpWrappers []HttpWrapper

+ func (w HttpWrappers) For(main Handler) Handler

+ func (w HttpWrappers) ForFunc(mainFunc HandlerFunc) Handler

+ type LogHandler func([]*Message)

+ type Logger interface

+ type Matcher interface

+ Match func(message *Message) bool

+ type Message struct

+ ContentType string

+ Cookies []Cookie

+ Delivery DeliveryMark

+ Form url.Values

+ FromAddr string

+ Headers Header

+ ID nxid.ID

+ LocalPayload Payload

+ Metadata map[string]string

+ MultipartReader *multipart.Reader

+ OverridingTransport Transport

+ Params map[string]string

+ Payload []byte

+ PostForm url.Values

+ Query url.Values

+ Topic string

+ func BasicMsg(topic string, message string, fromAddr string) *Message

+ func NOTOK(message string, fromAddr string) *Message

+ func NewMessage(topic string, fromAddr string, payload []byte) *Message

+ func OK(message string, fromAddr string) *Message

+ func SubscribeMessage(topic string, fromAddr string) *Message

+ func UnsubscribeMessage(topic string, fromAddr string) *Message

+ func (m *Message) Copy() *Message

+ func (m *Message) EncodeObject(encoder npkg.ObjectEncoder)

+ func (m *Message) String() string

+ func (m *Message) WithLocalPayload(lp Payload) *Message

+ func (m *Message) WithMetadata(meta map[string]string) *Message

+ func (m *Message) WithParams(params map[string]string) *Message

+ func (m *Message) WithPayload(lp []byte) *Message

+ type MessageErr interface

+ ShouldAck func() bool

+ func WrapErr(err error, shouldAck bool) MessageErr

+ type MessageHandler func(b []byte, from Socket) error

+ type MessageLog interface

+ CatchUp func(owner nxid.ID, lastId nxid.ID, handler Handler) error

+ Clear func(owner nxid.ID) error

+ Persist func(owner nxid.ID, message *Message) error

+ type MessageRouter interface

+ type NoopChannel struct

+ func (n NoopChannel) Close()

+ func (n NoopChannel) Err() error

+ type Params map[string]string

+ func (h Params) Delete(k string)

+ func (h Params) EncodeObject(encoder npkg.ObjectEncoder)

+ func (h Params) Get(k string) string

+ func (h Params) Set(k string, v string)

+ type Payload interface

+ Copy func() Payload

+ Type func() PayloadType

+ func HttpResponseAsPayload(rw *http.Response) Payload

+ func HttpResponseWriterAsPayload(rw http.ResponseWriter) Payload

+ type PayloadType int

+ const BinaryPayloadType

+ const HTTPRWPayload

+ const TextPayloadType

+ type RetryFunc func(last int) time.Duration

+ type SameSite int

+ const SameSiteDefaultMode

+ const SameSiteLaxMode

+ const SameSiteNoneMode

+ const SameSiteStrictMode

+ type Socket interface

+ ID func() nxid.ID

+ LocalAddr func() net.Addr

+ RemoteAddr func() net.Addr

+ Send func([]byte, time.Duration) error

+ SendWriter func(io.WriterTo, time.Duration) ErrorWaiter

+ Stat func() SocketStat

+ type SocketStat struct

+ Addr net.Addr

+ Handled int64

+ Id string

+ Received int64

+ RemoteAddr net.Addr

+ Sent int64

+ func (g SocketStat) EncodeObject(encoder npkg.ObjectEncoder)

+ type SocketWriterTo struct

+ func NewSocketWriterTo(w io.WriterTo) *SocketWriterTo

+ func (se *SocketWriterTo) Abort(err error)

+ func (se *SocketWriterTo) Wait() error

+ func (se *SocketWriterTo) WriteTo(w io.Writer) (int64, error)

+ type TextPayload string

+ func (b TextPayload) Copy() Payload

+ func (b TextPayload) Type() PayloadType

+ type Transport interface

+ Conn func() Conn

+ Listen func(topic string, handler TransportResponse) Channel

+ SendToAll func(data *Message, timeout time.Duration) error

+ SendToOne func(data *Message, timeout time.Duration) error

+ type TransportResponse interface

+ Handle func(*Message, Transport) MessageErr

+ type TransportResponseFunc func(*Message, Transport) MessageErr

+ func (t TransportResponseFunc) Handle(message *Message, tr Transport) MessageErr

+ type Transposer interface

+ Transpose func(req *http.Request, params Params) (*Message, error)

+ type Wrapper func(response TransportResponse) TransportResponse

+ type Wrappers []Wrapper

+ func Pre(middleware ...Wrapper) Wrappers

+ func (w Wrappers) For(main TransportResponse) TransportResponse

+ func (w Wrappers) ForFunc(mainFunc TransportResponseFunc) TransportResponse

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