route

Documentation

Index

• type JobSender
  • func (s *JobSender) Send(job *tx.Job)
• type Responder
  • func NewResponder(encoder encoding.Encoder) Responder
• type Sender
  • func NewSender(invoker fab.Invoker, responder Responder, recovery bool) (Sender, error)

Types

type JobSender

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

func (*JobSender) Send

func (s *JobSender) Send(job *tx.Job)

type Responder

type Responder interface {
	JobSuccess(job *tx.Job, fabresp *channel.Response)
	JobFailure(job *tx.Job, err error)
}

func NewResponder

func NewResponder(encoder encoding.Encoder) Responder

type Sender

type Sender interface {
	Send(job *tx.Job)
}

func NewSender

func NewSender(invoker fab.Invoker, responder Responder, recovery bool) (Sender, error)