broker

type Consumer ¶

type Consumer interface {
	Consume(ctx context.Context, msg *acv1.CloudEvent, stream *connect.ServerStream[acv1.ConsumeResponse]) error
}

func NewConsumer(consumerRegistrationChan chan register) Consumer

type Controller ¶

type Controller interface {
	Consumer
	Producer
}

func NewController(logger chassis.Logger) Controller

type Producer ¶

type Producer interface {
	Produce(ctx context.Context, inputStream *connect.BidiStream[acv1.ProduceRequest, acv1.ProduceResponse]) error
}

func NewProducer(produceChan chan *acv1.CloudEvent) Producer

type Rpc ¶

type Rpc interface {
	chassis.RPCRegistrar
	acConnect.ConsumerHandler
	acConnect.ProducerHandler
}

Given the producer, and consumer will have to share the same in memory data structure to send message to consumers when received from a producer. It's worth keeping the rpc services defined seperatly but implement using the same handler layer

func NewRPC(logger chassis.Logger, controller Controller) Rpc