transactionrequester

package

v0.1.2 Latest Latest Go to latest Published: Feb 24, 2020 License: Apache-2.0, BSD-2-Clause Imports: 5 Imported by: 0

Details

View Source

const (
	DEFAULT_REQUEST_WORKER_COUNT = 1024
	DEFAULT_RETRY_INTERVAL       = 10 * time.Second
)

This section is empty.

This section is empty.

type Events struct {
	SendRequest *events.Event
}

type Option func(*Options)

func RetryInterval(interval time.Duration) Option

func WorkerCount(workerCount int) Option

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

type TransactionRequester struct {
	Events Events
	// contains filtered or unexported fields
}

func New(optionalOptions ...Option) *TransactionRequester

func (requester *TransactionRequester) ScheduleRequest(transactionId transaction.Id)

func (requester *TransactionRequester) StopRequest(transactionId transaction.Id)