http

Documentation

Index

• func CreateStatusPing(inChan chan<- *channel.DataChan, resource string)
• func CreateSubscription(inChan chan<- *channel.DataChan, subscriptionID, resource string)
• func DeleteSubscription(inChan chan<- *channel.DataChan, resource string)
• type HTTP
  • func GetHTTPInstance(serviceName string, port int, storePath string, ...) (*HTTP, error)
  • func (h *HTTP) ClientID() uuid.UUID
  • func (h *HTTP) IsReadyToServe(uri *types.URI) bool
  • func (h *HTTP) RegisterPublishers(publisherURL ...*types.URI)
  • func (h *HTTP) SetOnStatusReceiveOverrideFn(fn func(e cloudevents.Event, dataChan *channel.DataChan) error)
  • func (h *HTTP) SetProcessEventFn(fn func(e interface{}) error)
  • func (h *HTTP) Shutdown()
  • func (h *HTTP) Start(wg *sync.WaitGroup)

Functions

func CreateStatusPing

func CreateStatusPing(inChan chan<- *channel.DataChan, resource string)

CreateStatusPing ...

func CreateSubscription

func CreateSubscription(inChan chan<- *channel.DataChan, subscriptionID, resource string)

CreateSubscription ...

func DeleteSubscription

func DeleteSubscription(inChan chan<- *channel.DataChan, resource string)

DeleteSubscription ...

Types

type HTTP

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

HTTP exposes http api methods

func GetHTTPInstance

func GetHTTPInstance(serviceName string, port int, storePath string, dataIn <-chan *channel.DataChan, dataOut chan<- *channel.DataChan,
	closeCh <-chan struct{}, onStatusReceiveOverrideFn func(e cloudevents.Event, dataChan *channel.DataChan) error, processEventFn func(e interface{}) error) (*HTTP, error)

GetHTTPInstance get event instance

func (*HTTP) ClientID

func (h *HTTP) ClientID() uuid.UUID

ClientID return clientID that was set by publisher/subscriber service

func (*HTTP) IsReadyToServe

func (h *HTTP) IsReadyToServe(uri *types.URI) bool

IsReadyToServe ... check if the server is ready

func (*HTTP) RegisterPublishers

func (h *HTTP) RegisterPublishers(publisherURL ...*types.URI)

RegisterPublishers ...

func (*HTTP) SetOnStatusReceiveOverrideFn

func (h *HTTP) SetOnStatusReceiveOverrideFn(fn func(e cloudevents.Event, dataChan *channel.DataChan) error)

SetOnStatusReceiveOverrideFn ...

func (*HTTP) SetProcessEventFn

func (h *HTTP) SetProcessEventFn(fn func(e interface{}) error)

SetProcessEventFn ...

func (*HTTP) Shutdown

func (h *HTTP) Shutdown()

Shutdown ...

func (*HTTP) Start

func (h *HTTP) Start(wg *sync.WaitGroup)

Start start amqp processors