exampleproto

package

v0.0.0-...-0cb89a8 Latest Latest Go to latest Published: Jun 30, 2024 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func Negotiator(min, max int) sockerball.Negotiator

type CompressingCodec struct{}

func (p CompressingCodec) Decode(in []byte, mapper sockerball.Mapper, decData *sockerball.ProtoData) (env sockerball.Envelope, rerr error)

func (p CompressingCodec) Encode(env sockerball.Envelope, into []byte, encData *sockerball.ProtoData) (extended []byte, rerr error)

type JSONEnvelope struct {
	ID      sockerball.MessageID
	ReplyTo sockerball.MessageID
	Kind    int
	Message json.RawMessage
}

type Mapper struct{}

func (m Mapper) Message(kind int) (sockerball.Message, error)

func (m Mapper) MessageKind(msg sockerball.Message) (int, error)

type OK struct{}

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

func (p Proto) Codec() sockerball.Codec

func (p Proto) Mapper() sockerball.Mapper

func (p Proto) MessageLimit() int

func (p Proto) ProtocolName() string

func (p Proto) Version() int

type ServerHandler struct{}

func (h ServerHandler) HandleRequest(ctx context.Context, in sockerball.IncomingRequest) (rs sockerball.Message, rerr error)

type SimpleCodec struct{}

func (p SimpleCodec) Decode(in []byte, mapper sockerball.Mapper, decdata *sockerball.ProtoData) (env sockerball.Envelope, rerr error)

func (p SimpleCodec) Encode(env sockerball.Envelope, into []byte, encdata *sockerball.ProtoData) (extended []byte, rerr error)

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

func (sp *Spammer) Dialer(neg sockerball.Negotiator) sockerball.Dialer

func (sp *Spammer) Flags(fs *cmdy.FlagSet)

func (sp *Spammer) Spam(ctx cmdy.Context, handler sockerball.Handler, clientCb spammerClientCb) error

type TestCommand struct{}

type TestRequest struct {
	Foo string
}

type TestResponse struct {
	Bar string
}