std

Documentation

Index

• type ConsumeClient
  • func NewConsumer(bindings *runHttp.ServerBindings) (consumer *ConsumeClient, err error)
  • func (c *ConsumeClient) Subscriber(_ context.Context, channelName string, bindings *runHttp.ChannelBindings) (runHttp.Subscriber, error)
• type EnvelopeIn
  • func NewEnvelopeIn(req *http.Request, responseWriter http.ResponseWriter) *EnvelopeIn
  • func (e *EnvelopeIn) Headers() run.Headers
  • func (e *EnvelopeIn) Read(p []byte) (n int, err error)
• type EnvelopeOut
  • func NewEnvelopeOut() *EnvelopeOut
  • func (e *EnvelopeOut) AsStdRecord() *http.Request
  • func (e *EnvelopeOut) Read(p []byte) (n int, err error)
  • func (e *EnvelopeOut) ResetPayload()
  • func (e *EnvelopeOut) SetBindings(bindings runHttp.MessageBindings)
  • func (e *EnvelopeOut) SetContentType(contentType string)
  • func (e *EnvelopeOut) SetHeaders(headers run.Headers)
  • func (e *EnvelopeOut) Write(p []byte) (n int, err error)
• type ImplementationRecord
• type ProduceClient
  • func NewProducer(serverURL string, bindings *runHttp.ServerBindings) (*ProduceClient, error)
  • func (p ProduceClient) Publisher(_ context.Context, channelName string, bindings *runHttp.ChannelBindings) (runHttp.Publisher, error)
• type Publisher
  • func NewPublisher(bindings *runHttp.ChannelBindings, channelURL *url.URL) *Publisher
  • func (p Publisher) Close() error
  • func (p Publisher) Send(ctx context.Context, envelopes ...runHttp.EnvelopeWriter) error
• type Subscriber
  • func NewSubscriber(bindings *runHttp.ChannelBindings) *Subscriber
  • func (s *Subscriber) Close() error
  • func (s *Subscriber) Receive(ctx context.Context, cb func(envelope runHttp.EnvelopeReader)) error

Types

type ConsumeClient

type ConsumeClient struct {
	http.ServeMux
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer(bindings *runHttp.ServerBindings) (consumer *ConsumeClient, err error)

func (*ConsumeClient) Subscriber

func (c *ConsumeClient) Subscriber(_ context.Context, channelName string, bindings *runHttp.ChannelBindings) (runHttp.Subscriber, error)

type EnvelopeIn

type EnvelopeIn struct {
	*http.Request
	ResponseWriter http.ResponseWriter
}

func NewEnvelopeIn

func NewEnvelopeIn(req *http.Request, responseWriter http.ResponseWriter) *EnvelopeIn

func (*EnvelopeIn) Headers

func (e *EnvelopeIn) Headers() run.Headers

func (*EnvelopeIn) Read

func (e *EnvelopeIn) Read(p []byte) (n int, err error)

type EnvelopeOut

type EnvelopeOut struct {
	*http.Request
	// contains filtered or unexported fields
}

func NewEnvelopeOut

func NewEnvelopeOut() *EnvelopeOut

func (*EnvelopeOut) AsStdRecord

func (e *EnvelopeOut) AsStdRecord() *http.Request

func (*EnvelopeOut) Read

func (e *EnvelopeOut) Read(p []byte) (n int, err error)

func (*EnvelopeOut) ResetPayload

func (e *EnvelopeOut) ResetPayload()

func (*EnvelopeOut) SetBindings

func (e *EnvelopeOut) SetBindings(bindings runHttp.MessageBindings)

func (*EnvelopeOut) SetContentType

func (e *EnvelopeOut) SetContentType(contentType string)

func (*EnvelopeOut) SetHeaders

func (e *EnvelopeOut) SetHeaders(headers run.Headers)

func (*EnvelopeOut) Write

func (e *EnvelopeOut) Write(p []byte) (n int, err error)

type ImplementationRecord

type ImplementationRecord interface {
	AsStdRecord() *http.Request
}

type ProduceClient

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

func NewProducer

func NewProducer(serverURL string, bindings *runHttp.ServerBindings) (*ProduceClient, error)

func (ProduceClient) Publisher

func (p ProduceClient) Publisher(_ context.Context, channelName string, bindings *runHttp.ChannelBindings) (runHttp.Publisher, error)

type Publisher

type Publisher struct {
	Client *http.Client
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher(bindings *runHttp.ChannelBindings, channelURL *url.URL) *Publisher

func (Publisher) Close

func (p Publisher) Close() error

func (Publisher) Send

func (p Publisher) Send(ctx context.Context, envelopes ...runHttp.EnvelopeWriter) error

type Subscriber

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

func NewSubscriber

func NewSubscriber(bindings *runHttp.ChannelBindings) *Subscriber

func (*Subscriber) Close

func (s *Subscriber) Close() error

func (*Subscriber) Receive

func (s *Subscriber) Receive(ctx context.Context, cb func(envelope runHttp.EnvelopeReader)) error