queuer

Documentation

Index

• type DiffQueuer
  • func (q *DiffQueuer) Queue(ctx context.Context, diff domain.Diff) error

Types

type DiffQueuer

type DiffQueuer struct {
	Endpoint *url.URL
	Client   *http.Client
}

DiffQueuer is a Queuer implementation which queues graph jobs onto a streaming appliance

func (*DiffQueuer) Queue

func (q *DiffQueuer) Queue(ctx context.Context, diff domain.Diff) error

Queue enqueues a diff job onto a streaming appliance