Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ShipperKafka ¶
type ShipperKafka struct {
NotifService service.Notification
}
func NewShipperKafka ¶
func NewShipperKafka(ns service.Notification) *ShipperKafka
func (*ShipperKafka) ProcessMessage ¶
func (s *ShipperKafka) ProcessMessage(ctx context.Context, msg kafka.Message)
Click to show internal directories.
Click to hide internal directories.