gosr

README

gosr

a simple frame of send and receive on conn for golang

Documentation

Index

• type Client
  • func NewClient(codec Codec, timeout time.Duration) Client
• type Codec
• type Error
  • func Errof(format string, args ...interface{}) Error
• type Message

Types

type Client

type Client interface {
	Call(req interface{}) (resp interface{}, err error)
	AsyncCall(req interface{}) (resp <-chan interface{}, err error)
	io.Closer
	IsClosed() bool
	Err() error
	SetErr(err error)
	GetCodec() Codec
}

Client ...

func NewClient

func NewClient(codec Codec, timeout time.Duration) Client

NewClient ...

type Codec

type Codec interface {
	BuildMessage(data interface{}) (Message, error)
	SendMessage(Message) error
	RecvMessage() (Message, error)
	Close() error
}

Codec ...

type Error

type Error error

Error ...

var (
	// ErrorTimeOut ...
	ErrorTimeOut Error = fmt.Errorf("[gosr] timeout")
	// ErrorClosed ...
	ErrorClosed Error = fmt.Errorf("[gosr] closed")
)

func Errof

func Errof(format string, args ...interface{}) Error

Errof ...

type Message

type Message interface {
	Seq() interface{}
	Data() interface{}
}

Message ...