Documentation ¶
Index ¶
- type BusPublisher
- type BusSubscriber
- type EventBus
- func (bus *EventBus) Publish(topic string, args ...interface{})
- func (bus *EventBus) Subscribe(topic string, fn interface{}) error
- func (bus *EventBus) SubscribeSync(topic string, fn interface{}) error
- func (bus *EventBus) SubscribeWith(topic string, key any, distHandler fission.CreateDistributionHandleFunc) error
- func (bus *EventBus) Unsubscribe(topic string, key any) error
- type Eventbus
- type EventbusOption
- type ProxyCreator
- type PubArgs
- type PubReply
- type RPCProxy
- func (p *RPCProxy) Publish(topic string, args ...interface{})
- func (p *RPCProxy) RPCPublish(args *PubArgs, reply *PubReply) error
- func (p *RPCProxy) RPCSubscribe(args *SubArgs, reply *SubReply) error
- func (p *RPCProxy) RPCSubscribeSync(args *SubArgs, reply *SubReply) error
- func (p *RPCProxy) RPCUnsubscribe(args *UnsubArgs, reply *UnsubReply) error
- func (p *RPCProxy) Subscribe(topic string, fn interface{}) error
- func (p *RPCProxy) SubscribeSync(topic string, fn interface{}) error
- func (p *RPCProxy) SubscribeWith(topic string, key any, distHandler fission.CreateDistributionHandleFunc) error
- func (p *RPCProxy) Unsubscribe(topic string, handler interface{}) error
- type SubArgs
- type SubReply
- type UnsubArgs
- type UnsubReply
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BusPublisher ¶
type BusPublisher interface {
Publish(topic string, args ...interface{})
}
type BusSubscriber ¶
type EventBus ¶
type EventBus struct {
// contains filtered or unexported fields
}
func (*EventBus) SubscribeSync ¶
func (*EventBus) SubscribeWith ¶
type Eventbus ¶
type Eventbus interface { BusSubscriber BusPublisher }
func New ¶
func New(opt ...EventbusOption) Eventbus
type EventbusOption ¶
type EventbusOption interface {
// contains filtered or unexported methods
}
func WithProxys ¶
func WithProxys(proxyCreators ...ProxyCreator) EventbusOption
WithProxyCreator returns a EventbusOption that sets the ProxyCreator.
type ProxyCreator ¶
func NewRPCProxyCreator ¶
func NewRPCProxyCreator(rawURL, remoteURL string) ProxyCreator
type RPCProxy ¶
type RPCProxy struct {
// contains filtered or unexported fields
}
func (*RPCProxy) RPCSubscribe ¶
func (*RPCProxy) RPCSubscribeSync ¶
func (*RPCProxy) RPCUnsubscribe ¶
func (p *RPCProxy) RPCUnsubscribe(args *UnsubArgs, reply *UnsubReply) error
func (*RPCProxy) SubscribeSync ¶
func (*RPCProxy) SubscribeWith ¶
func (*RPCProxy) Unsubscribe ¶
type UnsubReply ¶
type UnsubReply struct { }
Click to show internal directories.
Click to hide internal directories.