eventbus

type EventBus interface {
	Init()

	// async send msg
	Publish([]byte)

	PublishEvent(*proto.PaasEvent)

	// blocking receive msg when received
	Receive() (interface{}, error)

	Close()
}

type EventBusConsumer interface {
	// poll one msg from local cache queue or from broker
	Receive() (interface{}, error)

	// close consumer
	Close()
}

type EventBusProducer interface {
	// sync send msg
	Send([]byte) error

	// async send msg
	SendAsync([]byte)

	// close producer
	Close()
}

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

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

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