test

package

Go to main page

Versions in this module

v0

v0.10.2

Nov 7, 2024

Changes in this version

+ const ConnectionContextKey

+ const StreamContextKey

v0.10.1

Nov 5, 2024

v0.10.0

Sep 8, 2024

Changes in this version

type EchoStreamClient

+ func (x *EchoStreamClient) CloseChannel() <-chan struct{}

type EchoStreamServer

+ func (x *EchoStreamServer) CloseChannel() <-chan struct{}

type SearchClient

+ func (x *SearchClient) CloseChannel() <-chan struct{}

type SearchServer

+ func (x *SearchServer) CloseChannel() <-chan struct{}

type Server

+ func (s *Server) ServeConn(conn net.Conn)

+ func (s *Server) SetConcurrency(concurrency uint64)

+ func (s *Server) SetPreWrite(f func()) error

+ func (s *Server) Shutdown() error

+ func (s *Server) Start(addr string) error

+ func (s *Server) StartWithListener(listener net.Listener) error

type UploadClient

+ func (x *UploadClient) CloseChannel() <-chan struct{}

type UploadServer

+ func (x *UploadServer) CloseChannel() <-chan struct{}

v0.9.2

Sep 6, 2024

v0.9.1

Sep 3, 2024

v0.9.0

Sep 3, 2024

v0.8.1

Jul 29, 2024

v0.8.0

Apr 25, 2024

Changes in this version

+ var ErrDecodeNil = errors.New("cannot decode into a nil root struct")

v0.7.2

Dec 10, 2022

v0.7.1

Dec 10, 2022

Changes in this version

+ const Monkey

+ const MyMessage1RUNNING

+ const MyMessage1STARTED

+ const MyMessage1UNKNOWN

+ const MyMessage2STARTED

+ const MyMessage2UNKNOWN

+ const Potato

+ const RequestIMAGES

+ const RequestLOCAL

+ const RequestNEWS

+ const RequestPRODUCTS

+ const RequestUNIVERSAL

+ const RequestVIDEO

+ const RequestWEB

+ var NilDecode = errors.New("cannot decode into a nil root struct")

+ func HasErrorFlag(flags uint8) bool

+ func NewStockPricesPricesMap(size uint32) map[string]float64

+ func NewStockPricesSuperWrapPricesMap(size uint32) map[string]*StockPricesWrapper

+ func NewTestPotatoPricesMap(size uint32) map[string]Test

+ func SetErrorFlag(flags uint8, error bool) uint8

+ type Client struct

+ EchoService *subEchoServiceClient

+ func NewClient(tlsConfig *tls.Config, logger *zerolog.Logger) (*Client, error)

+ func (c *Client) Connect(addr string, streamHandler ...frisbee.NewStreamHandler) error

+ func (c *Client) FromConn(conn net.Conn, streamHandler ...frisbee.NewStreamHandler) error

+ type CloseError struct

+ func NewCloseError(err error) CloseError

+ func (e CloseError) Error() string

+ type Data struct

+ Checker Test

+ Message string

+ func NewData() *Data

+ func (x *Data) Decode(b []byte) error

+ func (x *Data) Encode(b *polyglot.Buffer)

+ func (x *Data) Error(b *polyglot.Buffer, err error)

+ type EchoService interface

+ Echo func(context.Context, *Request) (*Response, error)

+ EchoStream func(srv *EchoStreamServer) error

+ Search func(req *SearchResponse, srv *SearchServer) error

+ Testy func(context.Context, *SearchResponse) (*StockPricesWrapper, error)

+ Upload func(srv *UploadServer) error

+ type EchoStreamClient struct

+ func (x *EchoStreamClient) CloseAndRecv() (*Response, error)

+ func (x *EchoStreamClient) CloseSend() error

+ func (x *EchoStreamClient) Recv() (*Response, error)

+ func (x *EchoStreamClient) Send(m *Request) error

+ type EchoStreamServer struct

+ func (x *EchoStreamServer) CloseAndSend(m *Response) error

+ func (x *EchoStreamServer) CloseSend() error

+ func (x *EchoStreamServer) Recv() (*Request, error)

+ func (x *EchoStreamServer) Send(m *Response) error

+ type MyMessage1 struct

+ func NewMyMessage1() *MyMessage1

+ func (x *MyMessage1) Decode(b []byte) error

+ func (x *MyMessage1) Encode(b *polyglot.Buffer)

+ func (x *MyMessage1) Error(b *polyglot.Buffer, err error)

+ type MyMessage1EnumAllowingAlias uint32

+ type MyMessage2 struct

+ func NewMyMessage2() *MyMessage2

+ func (x *MyMessage2) Decode(b []byte) error

+ func (x *MyMessage2) Encode(b *polyglot.Buffer)

+ func (x *MyMessage2) Error(b *polyglot.Buffer, err error)

+ type MyMessage2EnumNotAllowingAlias uint32

+ type Outer struct

+ A *OuterMiddleAA

+ B *OuterMiddleBB

+ func NewOuter() *Outer

+ func (x *Outer) Decode(b []byte) error

+ func (x *Outer) Encode(b *polyglot.Buffer)

+ func (x *Outer) Error(b *polyglot.Buffer, err error)

+ type OuterMiddleAA struct

+ Inner *OuterMiddleAAInner

+ func NewOuterMiddleAA() *OuterMiddleAA

+ func (x *OuterMiddleAA) Decode(b []byte) error

+ func (x *OuterMiddleAA) Encode(b *polyglot.Buffer)

+ func (x *OuterMiddleAA) Error(b *polyglot.Buffer, err error)

+ type OuterMiddleAAInner struct

+ Booly bool

+ Ival int64

+ func NewOuterMiddleAAInner() *OuterMiddleAAInner

+ func (x *OuterMiddleAAInner) Decode(b []byte) error

+ func (x *OuterMiddleAAInner) Encode(b *polyglot.Buffer)

+ func (x *OuterMiddleAAInner) Error(b *polyglot.Buffer, err error)

+ type OuterMiddleBB struct

+ Inner *OuterMiddleBBInner

+ func NewOuterMiddleBB() *OuterMiddleBB

+ func (x *OuterMiddleBB) Decode(b []byte) error

+ func (x *OuterMiddleBB) Encode(b *polyglot.Buffer)

+ func (x *OuterMiddleBB) Error(b *polyglot.Buffer, err error)

+ type OuterMiddleBBInner struct

+ Booly bool

+ Ival int32

+ func NewOuterMiddleBBInner() *OuterMiddleBBInner

+ func (x *OuterMiddleBBInner) Decode(b []byte) error

+ func (x *OuterMiddleBBInner) Encode(b *polyglot.Buffer)

+ func (x *OuterMiddleBBInner) Error(b *polyglot.Buffer, err error)

+ type RPCStreamOpen struct

+ func (x *RPCStreamOpen) Decode(b []byte) error

+ func (x *RPCStreamOpen) Encode(b *polyglot.Buffer)

+ func (x *RPCStreamOpen) Error(b *polyglot.Buffer, err error)

+ type Request struct

+ Corpus RequestCorpus

+ Message string

+ func NewRequest() *Request

+ func (x *Request) Decode(b []byte) error

+ func (x *Request) Encode(b *polyglot.Buffer)

+ func (x *Request) Error(b *polyglot.Buffer, err error)

+ type RequestCorpus uint32

+ type Response struct

+ Message string

+ Test *Data

+ func NewResponse() *Response

+ func (x *Response) Decode(b []byte) error

+ func (x *Response) Encode(b *polyglot.Buffer)

+ func (x *Response) Error(b *polyglot.Buffer, err error)

+ type Resulting struct

+ Snippets []string

+ Title string

+ Url string

+ func NewResulting() *Resulting

+ func (x *Resulting) Decode(b []byte) error

+ func (x *Resulting) Encode(b *polyglot.Buffer)

+ func (x *Resulting) Error(b *polyglot.Buffer, err error)

+ type SampleMessage struct

+ Name string

+ Potato string

+ func NewSampleMessage() *SampleMessage

+ func (x *SampleMessage) Decode(b []byte) error

+ func (x *SampleMessage) Encode(b *polyglot.Buffer)

+ func (x *SampleMessage) Error(b *polyglot.Buffer, err error)

+ type SearchClient struct

+ func (x *SearchClient) Recv() (*Response, error)

+ type SearchResponse struct

+ Results []*SearchResponseResult

+ Results2 []*SearchResponseResult

+ Snippets []string

+ Snippets2 []string

+ func NewSearchResponse() *SearchResponse

+ func (x *SearchResponse) Decode(b []byte) error

+ func (x *SearchResponse) Encode(b *polyglot.Buffer)

+ func (x *SearchResponse) Error(b *polyglot.Buffer, err error)

+ type SearchResponseResult struct

+ Snippets []string

+ Title string

+ Url string

+ func NewSearchResponseResult() *SearchResponseResult

+ func (x *SearchResponseResult) Decode(b []byte) error

+ func (x *SearchResponseResult) Encode(b *polyglot.Buffer)

+ func (x *SearchResponseResult) Error(b *polyglot.Buffer, err error)

+ type SearchServer struct

+ func (x *SearchServer) CloseAndSend(m *Response) error

+ func (x *SearchServer) CloseSend() error

+ func (x *SearchServer) Send(m *Response) error

+ type Server struct

+ func NewServer(echoService EchoService, tlsConfig *tls.Config, logger *zerolog.Logger) (*Server, error)

+ func (s *Server) SetOnClosed(f func(*frisbee.Async, error)) error

+ type SomeOtherMessage struct

+ Result *SearchResponseResult

+ func NewSomeOtherMessage() *SomeOtherMessage

+ func (x *SomeOtherMessage) Decode(b []byte) error

+ func (x *SomeOtherMessage) Encode(b *polyglot.Buffer)

+ func (x *SomeOtherMessage) Error(b *polyglot.Buffer, err error)

+ type StockPrices struct

+ Prices StockPricesPricesMap

+ func NewStockPrices() *StockPrices

+ func (x *StockPrices) Decode(b []byte) error

+ func (x *StockPrices) Encode(b *polyglot.Buffer)

+ func (x *StockPrices) Error(b *polyglot.Buffer, err error)

+ type StockPricesPricesMap map[string]float64

+ func (x StockPricesPricesMap) Encode(b *polyglot.Buffer)

+ type StockPricesSuperWrap struct

+ Prices StockPricesSuperWrapPricesMap

+ func NewStockPricesSuperWrap() *StockPricesSuperWrap

+ func (x *StockPricesSuperWrap) Decode(b []byte) error

+ func (x *StockPricesSuperWrap) Encode(b *polyglot.Buffer)

+ func (x *StockPricesSuperWrap) Error(b *polyglot.Buffer, err error)

+ type StockPricesSuperWrapPricesMap map[string]*StockPricesWrapper

+ func (x StockPricesSuperWrapPricesMap) Encode(b *polyglot.Buffer)

+ type StockPricesWrapper struct

+ SPrices []*StockPrices

+ func NewStockPricesWrapper() *StockPricesWrapper

+ func (x *StockPricesWrapper) Decode(b []byte) error

+ func (x *StockPricesWrapper) Encode(b *polyglot.Buffer)

+ func (x *StockPricesWrapper) Error(b *polyglot.Buffer, err error)

+ type Test uint32

+ type TestPotato struct

+ Prices TestPotatoPricesMap

+ func NewTestPotato() *TestPotato

+ func (x *TestPotato) Decode(b []byte) error

+ func (x *TestPotato) Encode(b *polyglot.Buffer)

+ func (x *TestPotato) Error(b *polyglot.Buffer, err error)

+ type TestPotatoPricesMap map[string]Test

+ func (x TestPotatoPricesMap) Encode(b *polyglot.Buffer)

+ type UploadClient struct

+ func (x *UploadClient) CloseAndRecv() (*Response, error)

+ func (x *UploadClient) CloseSend() error

+ func (x *UploadClient) Send(m *Data) error

+ type UploadServer struct

+ func (x *UploadServer) CloseAndSend(m *Response) error

+ func (x *UploadServer) CloseSend() error

+ func (x *UploadServer) Recv() (*Data, error)

v0.7.0

Sep 28, 2022

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