producer

Documentation

Index

• Constants
• type OrderStatusModifyEvent
• type OrderStatusModifyEventProducer
  • func NewOrderStatusModifyEventProducer(q mq.MQ) (OrderStatusModifyEventProducer, error)
• type Status
  • func (s Status) ToUint8() uint8

Constants

const (
	OrderStatusModifyEventName = "order_status_modify_events"
)

Types

type OrderStatusModifyEvent

type OrderStatusModifyEvent struct {
	ProcessInstanceId int    `json:"process_instance_id"`
	Status            Status `json:"status"`
}

type OrderStatusModifyEventProducer

type OrderStatusModifyEventProducer interface {
	Produce(ctx context.Context, evt OrderStatusModifyEvent) error
}

func NewOrderStatusModifyEventProducer

func NewOrderStatusModifyEventProducer(q mq.MQ) (OrderStatusModifyEventProducer, error)

type Status

type Status uint8

const (
	// START 等待开始
	START Status = 1
	// PROCESS 流程运行中
	PROCESS Status = 2
	// END 完成
	END Status = 3
	// RETRY 重试
	RETRY Status = 4
)

func (Status) ToUint8

func (s Status) ToUint8() uint8