eventbusclient

type Config struct {
	Host         string `envconfig:"EVENTBUS_HOST" required:"true"`
	Port         string `envconfig:"EVENTBUS_PORT" required:"true"`
	Username     string `envconfig:"EVENTBUS_USERNAME" required:"true"`
	Password     string `envconfig:"EVENTBUS_PASSWORD" required:"true"`
	PrefectCount int    `envconfig:"EVENTBUS_PREFECT_COUNT" required:"false" default:"50"`
}

type Header struct {
	Timestamp   time.Time `json:"timestamp" validate:"required"`
	Publisher   string    `json:"publisher" validate:"required"`
	EventName   string    `json:"eventName" validate:"required"`
	TraceId     string    `json:"traceId"`
	UserId      string    `json:"userId"`
	XRetryCount int16     `json:"xRetryCount,omitempty"`
}

type Message struct {
	Id         string
	Exchange   string
	RoutingKey string
	Header     Header
	Payload    Payload `validate:"required,dive"`
	Status     string
	Error      error
}

type Payload struct {
	EntityId string      `json:"entityId"`
	Data     interface{} `json:"data" validate:"required"`
}

type RetryErrorType interface {
	IsRetryErrorType() bool
	Error() string
}