loadbalanced

Documentation

Index

• func New(ctx context.Context, secretInterface corev1.SecretInterface, r NewReq) (source.HasPending, error)
• type NewReq

Functions

func New

func New(ctx context.Context, secretInterface corev1.SecretInterface, r NewReq) (source.HasPending, error)

Types

type NewReq

type NewReq struct {
	Logger       logr.Logger
	PipelineName string
	StepName     string
	SourceName   string
	SourceURN    string
	LeadReplica  bool
	Concurrency  int
	PollPeriod   time.Duration
	Process      source.Process
	RemoveItem   func(item interface{}) error
	ListItems    func() ([]interface{}, error)
}