channel

Documentation

Index

• type HttpCallbackChannel
  • func NewHttpCallbackChannel(callbackBaseURL string) *HttpCallbackChannel
  • func (p *HttpCallbackChannel) Notify(c context.Context, notifier *notify.Notifier, basePath string, ...) (string, error)
  • func (p *HttpCallbackChannel) OnResponse(reqID uint64, payload string) error
• type PendingRequest

Types

type HttpCallbackChannel

type HttpCallbackChannel struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewHttpCallbackChannel

func NewHttpCallbackChannel(callbackBaseURL string) *HttpCallbackChannel

func (*HttpCallbackChannel) Notify

func (p *HttpCallbackChannel) Notify(c context.Context, notifier *notify.Notifier, basePath string, request *notify.Notification) (string, error)

func (*HttpCallbackChannel) OnResponse

func (p *HttpCallbackChannel) OnResponse(reqID uint64, payload string) error

type PendingRequest

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