Versions in this module Expand all Collapse all v0 v0.0.1 Jun 3, 2022 Changes in this version + const MsgPolicyAttempts + const MsgPolicyFailure + const MsgPolicyIgnore + const MsgPolicyNormal + const MsgPolicyRetryInfinite + func ConsumeWorkerOption(worker int) func(r *Railgun) + func NewMessage(ctx context.Context, traceName string, data []byte) (m *message) + type Config struct + QuotaID string + type CronDoFunc func(ctx context.Context) MsgPolicy + type CronInputer struct + func NewCronInputer(cfg *CronInputerConfig) *CronInputer + type CronInputerConfig struct + Spec string + type CronProcessor struct + func NewCronProcessor(config *CronProcessorConfig, do CronDoFunc, opts ...func(*CronProcessor)) (res *CronProcessor) + type CronProcessorConfig struct + Attempts int + Parallel bool + type CronUniqConfig struct + type Inputer interface + type ManualInputer struct + func NewManualInputer(cfg *ManualInputerConfig) *ManualInputer + func (*ManualInputer) AwesomeRailgun() + func (d *ManualInputer) Add(ctx context.Context, data []byte) (err error) + type ManualInputerConfig struct + Buffer int + type Message interface + Payload func() []byte + Raw func() interface{} + type MsgPolicy int + func (m MsgPolicy) String() string + type PrivateMessage interface + Ack func(err error) + Context func() context.Context + type Railgun struct + func NewRailGun(name string, cfg *Config, ipt Inputer, processor processor, ...) *Railgun + func (r *Railgun) Close() + func (r *Railgun) Start()
Go to main page