interop

package

Go to main page

Versions in this module

v0

v0.5.0

Feb 8, 2023

Changes in this version

type Conn

+ func RpcRequestSource(request Message) Conn

+ type ResponderContextFunc func(ctx context.Context, request Message, response *MessageBuilder)

+ func (f ResponderContextFunc) Respond(ctx context.Context, request Message, response *MessageBuilder)

type RpcMultiServer

+ func (s *RpcMultiServer) Wait()

+ func (s *RpcMultiServer) WaitClean()

+ func (s *RpcMultiServer) WaitCleanContext(ctx context.Context) error

+ func (s *RpcMultiServer) WaitContext(ctx context.Context) error

type RpcServer

+ func (s *RpcServer) WaitClean()

+ func (s *RpcServer) WaitCleanContext(ctx context.Context) error

v0.4.0

Oct 4, 2022

v0.3.3

Oct 29, 2021

v0.3.2

Sep 3, 2021

Changes in this version

type Error

+ const ErrAlreadyClosed

+ type MultiWriter struct

+ func (m *MultiWriter) Subscribe(writer Writer) (unsubscribe func())

+ func (m *MultiWriter) Write(message Message) error

+ type MultiWriterError struct

+ Error error

+ Writer Writer

+ type MultiWriterErrors []MultiWriterError

+ func (m MultiWriterErrors) Error() string

type RpcDispatcher

+ func (d *RpcDispatcher) Respond(request Message, response *MessageBuilder)

+ type RpcMultiServer struct

+ func (s *RpcMultiServer) Run(conn Conn) (err error)

+ func (s *RpcMultiServer) Send(event Message) error

v0.3.1

Aug 19, 2021

v0.3.0

Aug 18, 2021

Changes in this version

+ type ContentType struct

+ Name string

+ func (c *ContentType) Decode(m Message) (interface{}, error)

+ func (c *ContentType) DecodeTo(m Message, t interface{}) error

+ func (c *ContentType) Encode(value interface{}) (Message, error)

+ func (c *ContentType) EncodeTo(builder *MessageBuilder, value interface{}) error

+ type ContentTypes []*ContentType

+ var StdContentTypes ContentTypes

+ func (t *ContentTypes) Register(contentTypeName string, marshaller encoding.Marshaler) (contentType *ContentType)

+ func (t ContentTypes) Decode(message Message) (result interface{}, err error)

+ func (t ContentTypes) DecodeTo(message Message, target interface{}) (err error)

+ func (t ContentTypes) Encode(contentTypeName string, value interface{}) (Message, error)

+ func (t ContentTypes) EncodeTo(contentTypeName string, builder *MessageBuilder, value interface{}) error

+ func (t ContentTypes) FindByName(contentTypeName string) *ContentType

+ func (t ContentTypes) Marshal(contentTypeName string, value interface{}) (b []byte, err error)

+ func (t ContentTypes) Unmarshal(contentTypeName string, b []byte) (result interface{}, err error)

+ func (t ContentTypes) UnmarshalTo(contentTypeName string, b []byte, target interface{}) (err error)

type Error

+ const ErrUnrecognisedType

type MessageBuilder

+ func (b *MessageBuilder) SetContent(contentType *ContentType, content interface{}) error

type RpcClient

+ func (c *RpcClient) CallWithContent(class string, contentType *ContentType, content interface{}) (response Message, err error)

+ func (c *RpcClient) CallWithContentContext(ctx context.Context, class string, contentType *ContentType, ...) (response Message, err error)

v0.2.0

Aug 10, 2021

Changes in this version

+ const ContentTypeBinary

+ const ContentTypeJSON

+ const HeaderDelimiter

+ const MessageClassHeader

+ const MessageContentLengthHeader

+ const MessageContentTypeHeader

+ const MessageErrorHeader

+ const MessageIDHeader

+ func Decode(message Message, target interface{}) error

+ func NewReader(r io.Reader) *reader

+ func NewWriter(w io.Writer) *writer

+ func ReadAllMessages(reader Reader, callback func(message Message) error) (err error)

+ func WriteHeaders(headers []Header, w io.Writer) (n int64, err error)

+ func WriteMessage(message Message, w io.Writer) (n int64, err error)

+ type Conn interface

+ func BuildConn(reader io.Reader, writer io.Writer) Conn

+ func CombineReaderWriter(reader Reader, writer Writer) Conn

+ func NewConn(conn io.ReadWriter) Conn

+ func StdioConn() Conn

+ func Wrap(conn Conn, readInterceptor, writeInterceptor Interceptor) Conn

+ type Error string

+ const ErrEventHasID

+ const ErrNotDecodable

+ const ErrPipeAlreadyClosed

+ func (e Error) Error() string

+ type EventDispatcher struct

+ func (d *EventDispatcher) Dispatch(event Message) (err error)

+ func (d *EventDispatcher) Handle(matcher Matcher, handler Handler)

+ func (d *EventDispatcher) HandleClassName(name string, handler Handler)

+ func (d *EventDispatcher) HandleClassRegexp(pattern *regexp.Regexp, handler Handler)

+ type Handler interface

+ Handle func(event Message) error

+ type HandlerFunc func(event Message) error

+ func (f HandlerFunc) Handle(event Message) error

+ type Header interface

+ Name func() string

+ Value func() string

+ func NewHeader(name, value string) Header

+ func ParseHeader(headerLine []byte) (Header, error)

+ type Headers []Header

+ func (h *Headers) Add(name, value string) *Headers

+ func (h *Headers) Delete(name string) *Headers

+ func (h *Headers) Set(name, value string) *Headers

+ func (h Headers) Get(name string) string

+ func (h Headers) GetAll(name string) (values []string)

+ type Interceptor func(message Message, writer Writer) error

+ type Matcher interface

+ Match func(message Message) bool

+ func MatchClassName(name string) Matcher

+ func MatchClassRegexp(pattern *regexp.Regexp) Matcher

+ type MatcherFunc func(message Message) bool

+ func (f MatcherFunc) Match(message Message) bool

+ type Message interface

+ Body func() []byte

+ GetAllHeaders func() []Header

+ GetHeader func(name string) string

+ GetHeaders func(name string) []string

+ type MessageBuilder struct

+ func DuplicateMessage(message Message) *MessageBuilder

+ func NewRpcMessage(class string) *MessageBuilder

+ func (b *MessageBuilder) AddError(err error) *MessageBuilder

+ func (b *MessageBuilder) AddHeader(name, value string) *MessageBuilder

+ func (b *MessageBuilder) SetBinaryBody(data []byte) *MessageBuilder

+ func (b *MessageBuilder) SetBody(body []byte) *MessageBuilder

+ func (b *MessageBuilder) SetHeader(name, value string) *MessageBuilder

+ func (b *MessageBuilder) SetJSONBody(data interface{}) (err error)

+ func (m *MessageBuilder) Body() []byte

+ func (m *MessageBuilder) GetAllHeaders() []Header

+ func (m *MessageBuilder) GetHeader(name string) string

+ func (m *MessageBuilder) GetHeaders(name string) []string

+ type Pipe struct

+ func NewBufferedPipe(bufferSize int) *Pipe

+ func NewPipe() *Pipe

+ func (p *Pipe) Close() error

+ func (p *Pipe) CloseWithError(err error) error

+ func (p *Pipe) Read() (message Message, err error)

+ func (p *Pipe) Write(message Message) (err error)

+ type Reader interface

+ Read func() (message Message, err error)

+ func NewReadInterceptor(reader Reader, interceptor Interceptor) Reader

+ type Responder interface

+ Respond func(request Message, response *MessageBuilder)

+ type ResponderFunc func(request Message, response *MessageBuilder)

+ func (f ResponderFunc) Respond(request Message, response *MessageBuilder)

+ type RpcClient struct

+ Events *EventDispatcher

+ IDPrefix string

+ Timeout time.Duration

+ func NewRpcClient(conn Conn) (client *RpcClient)

+ func (b *RpcClient) Start()

+ func (b *RpcClient) Wait() error

+ func (c *RpcClient) Call(class string) (response Message, err error)

+ func (c *RpcClient) CallContext(ctx context.Context, class string) (response Message, err error)

+ func (c *RpcClient) CallWithBinary(class string, body []byte) (response Message, err error)

+ func (c *RpcClient) CallWithBinaryContext(ctx context.Context, class string, body []byte) (response Message, err error)

+ func (c *RpcClient) CallWithJSON(class string, body interface{}) (response Message, err error)

+ func (c *RpcClient) CallWithJSONContext(ctx context.Context, class string, body interface{}) (response Message, err error)

+ func (c *RpcClient) Run() (err error)

+ func (c *RpcClient) Send(request Message) (response Message, err error)

+ func (c *RpcClient) SendContext(ctx context.Context, request Message) (response Message, err error)

+ type RpcDispatcher struct

+ func (d *RpcDispatcher) Dispatch(request Message, response *MessageBuilder)

+ func (d *RpcDispatcher) Handle(matcher Matcher, responder Responder)

+ func (d *RpcDispatcher) HandleClassName(name string, responder Responder)

+ func (d *RpcDispatcher) HandleClassRegexp(pattern *regexp.Regexp, responder Responder)

+ type RpcServer struct

+ func NewRpcServer(conn Conn) (server *RpcServer)

+ func (b *RpcServer) Start()

+ func (b *RpcServer) Wait() error

+ func (s *RpcServer) Run() (err error)

+ func (s *RpcServer) Send(event Message) error

+ type Writer interface

+ Write func(message Message) (err error)

+ func NewWriteInterceptor(writer Writer, interceptor Interceptor) Writer

v0.1.0

Dec 3, 2020

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