transports

Documentation

Index

• type Transport
  • func NewHTTPTransport(port int64, registry rpc.Registry) Transport
  • func NewWSTransport(port int64, registry rpc.Registry) Transport
• type TransportManager
  • func NewTransportManager(concurrency int) *TransportManager
  • func (tm *TransportManager) AddHTTPServer(port int64)
  • func (tm *TransportManager) AddWSServer(port int64)
  • func (tm *TransportManager) Caller() rpc.RegistryCallable
  • func (tm *TransportManager) OnMissing(...)
  • func (tm *TransportManager) Register(namespace string, service interface{})
  • func (tm *TransportManager) RegisterHealthCheck(hc rpc.HealthCheck)
  • func (tm *TransportManager) RegisterHeightFeed(ch interface{})
  • func (tm *TransportManager) RegisterMiddleware(item rpc.Middleware)
  • func (tm *TransportManager) Run(hcport int64) error
  • func (tm *TransportManager) SetBlockWaitDuration(d time.Duration)
  • func (tm *TransportManager) Stop()

Types

type Transport

type Transport interface {
	Start(chan error) error
	Stop() error
}

func NewHTTPTransport

func NewHTTPTransport(port int64, registry rpc.Registry) Transport

func NewWSTransport

func NewWSTransport(port int64, registry rpc.Registry) Transport

type TransportManager

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

func NewTransportManager

func NewTransportManager(concurrency int) *TransportManager

func (*TransportManager) AddHTTPServer

func (tm *TransportManager) AddHTTPServer(port int64)

func (*TransportManager) AddWSServer

func (tm *TransportManager) AddWSServer(port int64)

func (*TransportManager) Caller

func (tm *TransportManager) Caller() rpc.RegistryCallable

func (*TransportManager) OnMissing

func (tm *TransportManager) OnMissing(fn func(*rpc.CallContext, string, []json.RawMessage) (interface{}, *rpc.RPCError, *rpc.CallMetadata))

func (*TransportManager) Register

func (tm *TransportManager) Register(namespace string, service interface{})

func (*TransportManager) RegisterHealthCheck

func (tm *TransportManager) RegisterHealthCheck(hc rpc.HealthCheck)

func (*TransportManager) RegisterHeightFeed

func (tm *TransportManager) RegisterHeightFeed(ch interface{})

func (*TransportManager) RegisterMiddleware

func (tm *TransportManager) RegisterMiddleware(item rpc.Middleware)

func (*TransportManager) Run

func (tm *TransportManager) Run(hcport int64) error

func (*TransportManager) SetBlockWaitDuration

func (tm *TransportManager) SetBlockWaitDuration(d time.Duration)

func (*TransportManager) Stop

func (tm *TransportManager) Stop()