railgun

type Config struct {
	// quota 限流资源id 数据源获取到数据后，卡在发送到下游处理之前的限制
	QuotaID string
}

type CronDoFunc func(ctx context.Context) MsgPolicy

type CronInputer struct {
	*ManualInputer
	// contains filtered or unexported fields
}

type CronInputerConfig struct {
	/*
			doc: https://github.com/robfig/cron/blob/v1/doc.go

			Field name   | Mandatory? | Allowed values  | Allowed special characters
			----------   | ---------- | --------------  | --------------------------
			Seconds      | Yes        | 0-59            | * / , -
			Minutes      | Yes        | 0-59            | * / , -
			Hours        | Yes        | 0-23            | * / , -
			Day of month | Yes        | 1-31            | * / , - ?
			Month        | Yes        | 1-12 or JAN-DEC | * / , -
			Day of week  | Yes        | 0-6 or SUN-SAT  | * / , - ?

			Entry                  | Description                                | Equivalent To
			-----                  | -----------                                | -------------
			@yearly (or @annually) | Run once a year, midnight, Jan. 1st        | 0 0 0 1 1 *
			@monthly               | Run once a month, midnight, first of month | 0 0 0 1 * *
			@weekly                | Run once a week, midnight between Sat/Sun  | 0 0 0 * * 0
			@daily (or @midnight)  | Run once a day, midnight                   | 0 0 0 * * *
			@hourly                | Run once an hour, beginning of hour        | 0 0 * * * *

		   example:
			@every 5m
			@every 1h30m
	*/
	Spec string
}

type CronProcessor struct {
	// contains filtered or unexported fields
}

type CronProcessorConfig struct {
	// 上次事件没处理结束的话 是否可以并发执行
	Parallel bool
	// 重试次数
	Attempts int
}

type CronUniqConfig struct {
}

type Inputer interface {
}

type ManualInputer struct {
	// contains filtered or unexported fields
}

type ManualInputerConfig struct {
	Buffer int
}

type Message interface {
	Payload() []byte
	Raw() interface{}
}

type MsgPolicy int

type PrivateMessage interface {
	Message
	Ack(err error)
	Context() context.Context
}

type Railgun struct {
	// contains filtered or unexported fields
}