client

Documentation

Index

• type Client
  • func New(ctx context.Context, url string, l xlog.Logger, opts ...func(Option)) Client
• type Handler
• type ListenArg
• type Meta
• type Observable
  • func NewObservable(cli ObservableClient) Observable
• type ObservableClient
• type Option
• type PipeFunc
  • func PipeTake(count uint64) PipeFunc
  • func PipeTimeout(t time.Duration) PipeFunc
• type Request
• type Response
• type Subscription

Types

type Client

type Client interface {
	SendEvent(eid event.Id, in interface{})
	ConnectID() string
	Header(key, value string)
	SetHandler(call Handler, eids ...event.Id)
	DelHandler(eids ...event.Id)
	OnClose(cb func(cid string))
	OnOpen(cb func(cid string))
	Close()
	DialAndListen() error
}

func New

func New(ctx context.Context, url string, l xlog.Logger, opts ...func(Option)) Client

type Handler

type Handler func(w Request, r Response, m Meta)

type ListenArg

type ListenArg interface {
	Decode(in interface{}) error
}

type Meta

type Meta interface {
	ConnectID() string
}

type Observable

type Observable interface {
	Subscribe(eid event.Id, in interface{}) Subscription
}

func NewObservable

func NewObservable(cli ObservableClient) Observable

type ObservableClient

type ObservableClient interface {
	OnClose(cb func(cid string))
	SendEvent(eid event.Id, in interface{})
	DelHandler(eids ...event.Id)
	SetHandler(call Handler, eids ...event.Id)
}

type Option

type Option interface {
	Header(key, value string)
}

type PipeFunc

type PipeFunc func(ctx context.Context) context.Context

func PipeTake

func PipeTake(count uint64) PipeFunc

func PipeTimeout

func PipeTimeout(t time.Duration) PipeFunc

type Request

type Request interface {
	Encode(in interface{})
	EncodeEvent(id event.Id, in interface{})
}

type Response

type Response interface {
	EventID() event.Id
	Decode(in interface{}) error
}

type Subscription

type Subscription interface {
	Listen(call func(ListenArg), pipe ...PipeFunc)
	Unsubscribe()
}