runtime

type JSONEncoder struct{}

type MessageBrokerConsumer interface {
	Handle(ctx context.Context, handler MessageHandler) error
}

type MessageBrokerProducer interface {
	Write(ctx context.Context, msg []byte) error
}

type MessageEncoder interface {
	Encode(x interface{}) ([]byte, error)
	Decode(data []byte, x interface{}) error
}

type MessageHandler func(ctx context.Context, msg []byte) error

type ProtobufEncoder struct{}