transports

Documentation

Index

• func BindRemoteTransportServer(topic string, pubsub remote.PubSub, transp api.TransportHandler) error
• func NewDefaultTransport(endpoint string, user, pass, rawPem []byte) (transp api.TransportHandler, err error)
• func NewRemoteTransportClient(rrchan remote.RequestReplyChannel) (transp api.Transport)
• type SimpleMemoryCacheHandler
  • func NewSimpleMemoryCacheHandler() *SimpleMemoryCacheHandler
  • func (smch *SimpleMemoryCacheHandler) Handle(info api.RequestCommandInfo, th api.TransportHandler, req *api.Request) (res api.Response)

Functions

func BindRemoteTransportServer

func BindRemoteTransportServer(topic string, pubsub remote.PubSub, transp api.TransportHandler) error

func NewDefaultTransport

func NewDefaultTransport(endpoint string, user, pass, rawPem []byte) (transp api.TransportHandler, err error)

func NewRemoteTransportClient

func NewRemoteTransportClient(rrchan remote.RequestReplyChannel) (transp api.Transport)

Types

type SimpleMemoryCacheHandler

type SimpleMemoryCacheHandler struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewSimpleMemoryCacheHandler

func NewSimpleMemoryCacheHandler() *SimpleMemoryCacheHandler

func (*SimpleMemoryCacheHandler) Handle

func (smch *SimpleMemoryCacheHandler) Handle(info api.RequestCommandInfo, th api.TransportHandler, req *api.Request) (res api.Response)

Implements TransportCacheHandler func(RequestCommandInfo, TransportHandler, *Request) (Response)