producer

Documentation

Index

• type CloudEventProducer
  • func NewCloudEventProducer(eventMeshHttpClientConfig conf.EventMeshHttpClientConfig) *CloudEventProducer
  • func (c *CloudEventProducer) Publish(event *cloudevents.Event) error
  • func (c *CloudEventProducer) Request(event *cloudevents.Event, timeout time.Duration) (*cloudevents.Event, error)
• type EventMeshHttpProducer
  • func NewEventMeshHttpProducer(eventMeshHttpClientConfig conf.EventMeshHttpClientConfig) *EventMeshHttpProducer
  • func (e *EventMeshHttpProducer) PublishCloudEvent(event *cloudevents.Event) error
  • func (e *EventMeshHttpProducer) PublishEventMeshMessage(message *protocol.EventMeshMessage) error
  • func (e *EventMeshHttpProducer) RequestCloudEvent(event *cloudevents.Event, timeout time.Duration) (*cloudevents.Event, error)
  • func (e *EventMeshHttpProducer) RequestEventMeshMessage(message *protocol.EventMeshMessage, timeout time.Duration) (*protocol.EventMeshMessage, error)
• type EventMeshMessageProducer
  • func NewEventMeshMessageProducer(eventMeshHttpClientConfig conf.EventMeshHttpClientConfig) *EventMeshMessageProducer
  • func (c *EventMeshMessageProducer) Publish(message *protocol.EventMeshMessage) error
  • func (c *EventMeshMessageProducer) Request(message *protocol.EventMeshMessage, timeout time.Duration) (*protocol.EventMeshMessage, error)
• type EventMeshProtocolProducer

Types

type CloudEventProducer

type CloudEventProducer struct {
	*http.AbstractHttpClient
}

func NewCloudEventProducer

func NewCloudEventProducer(eventMeshHttpClientConfig conf.EventMeshHttpClientConfig) *CloudEventProducer

func (*CloudEventProducer) Publish

func (c *CloudEventProducer) Publish(event *cloudevents.Event) error

func (*CloudEventProducer) Request

func (c *CloudEventProducer) Request(event *cloudevents.Event, timeout time.Duration) (*cloudevents.Event, error)

type EventMeshHttpProducer

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

func NewEventMeshHttpProducer

func NewEventMeshHttpProducer(eventMeshHttpClientConfig conf.EventMeshHttpClientConfig) *EventMeshHttpProducer

func (*EventMeshHttpProducer) PublishCloudEvent

func (e *EventMeshHttpProducer) PublishCloudEvent(event *cloudevents.Event) error

func (*EventMeshHttpProducer) PublishEventMeshMessage

func (e *EventMeshHttpProducer) PublishEventMeshMessage(message *protocol.EventMeshMessage) error

func (*EventMeshHttpProducer) RequestCloudEvent

func (e *EventMeshHttpProducer) RequestCloudEvent(event *cloudevents.Event, timeout time.Duration) (*cloudevents.Event, error)

func (*EventMeshHttpProducer) RequestEventMeshMessage

func (e *EventMeshHttpProducer) RequestEventMeshMessage(message *protocol.EventMeshMessage, timeout time.Duration) (*protocol.EventMeshMessage, error)

type EventMeshMessageProducer

type EventMeshMessageProducer struct {
	*http.AbstractHttpClient
}

func NewEventMeshMessageProducer

func NewEventMeshMessageProducer(eventMeshHttpClientConfig conf.EventMeshHttpClientConfig) *EventMeshMessageProducer

func (*EventMeshMessageProducer) Publish

func (c *EventMeshMessageProducer) Publish(message *protocol.EventMeshMessage) error

func (*EventMeshMessageProducer) Request

func (c *EventMeshMessageProducer) Request(message *protocol.EventMeshMessage, timeout time.Duration) (*protocol.EventMeshMessage, error)

type EventMeshProtocolProducer

type EventMeshProtocolProducer interface {

	// PublishCloudEvent publish with CloudEvent protocol
	PublishCloudEvent(event *cloudevents.Event) error
	// RequestCloudEvent request with CloudEvent protocol
	RequestCloudEvent(event *cloudevents.Event, timeout time.Duration) (*cloudevents.Event, error)

	// PublishEventMeshMessage publish with EventMeshMessage protocol
	PublishEventMeshMessage(message *protocol.EventMeshMessage) error
	// RequestEventMeshMessage request with EventMeshMessage protocol
	RequestEventMeshMessage(message *protocol.EventMeshMessage, timeout time.Duration) (*protocol.EventMeshMessage, error)
}