transport

Documentation

Index

• type Cmd
• type Extractor
• type Fake
  • func (t *Fake) Request(ctx context.Context, send, recv interface{}) error
  • func (t *Fake) Serve(ctx context.Context, h Handler) error
• type Handler
  • func Handle(f func(context.Context, Extractor) (interface{}, error)) Handler
• type LoopTransport
  • func (s *LoopTransport) Request(ctx context.Context, send, recv interface{}) error
  • func (s *LoopTransport) Serve(ctx context.Context, h Handler) error
• type Looper
• type Message
  • func NewMessage(cmd Cmd, obj interface{}) (*Message, error)
  • func (m *Message) Extract(obj interface{}) error
  • func (m *Message) GetData(obj interface{}) error
  • func (m *Message) SetData(obj interface{}) error
• type Session
  • func NewSession() *Session
  • func (s *Session) Add(id int) <-chan *Message
  • func (s *Session) Pick(id int) chan<- *Message
• type Transport
  • func NewLoopTransport(loop Looper) Transport

Types

type Cmd

type Cmd int

const (
	CmdRequest Cmd = iota
	CmdResponse
	CmdError
)

type Extractor

type Extractor interface {
	Extract(obj interface{}) error
}

type Fake

type Fake struct{}

Fake transport helps while developing or for mocking if you don't want to implement all Transport interface methods

func (*Fake) Request

func (t *Fake) Request(ctx context.Context, send, recv interface{}) error

func (*Fake) Serve

func (t *Fake) Serve(ctx context.Context, h Handler) error

type Handler

type Handler interface {
	Handle(context.Context, Extractor) (interface{}, error)
}

func Handle

func Handle(f func(context.Context, Extractor) (interface{}, error)) Handler

type LoopTransport

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

func (*LoopTransport) Request

func (s *LoopTransport) Request(ctx context.Context, send, recv interface{}) error

func (*LoopTransport) Serve

func (s *LoopTransport) Serve(ctx context.Context, h Handler) error

type Looper

type Looper interface {
	Loop(ctx context.Context, in chan<- *Message, out <-chan *Message) <-chan error
}

type Message

type Message struct {
	Id   int              `json:"id"`
	Cmd  Cmd              `json:"cmd"`
	Data *json.RawMessage `json:"data"`
}

func NewMessage

func NewMessage(cmd Cmd, obj interface{}) (*Message, error)

func (*Message) Extract

func (m *Message) Extract(obj interface{}) error

func (*Message) GetData

func (m *Message) GetData(obj interface{}) error

func (*Message) SetData

func (m *Message) SetData(obj interface{}) error

type Session

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

func NewSession

func NewSession() *Session

func (*Session) Add

func (s *Session) Add(id int) <-chan *Message

func (*Session) Pick

func (s *Session) Pick(id int) chan<- *Message

type Transport

type Transport interface {
	Serve(ctx context.Context, h Handler) error
	Request(ctx context.Context, send, recv interface{}) error
}

Transport interface

func NewLoopTransport

func NewLoopTransport(loop Looper) Transport