channel

Documentation

Index

• type Consumer
  • func NewConsumer(inbox chan requestWithHeaders, outbox chan *jetflow.Response, ...) *Consumer
  • func (w *Consumer) Start(ctx context.Context)
• type Publisher
  • func NewPublisher() (*Publisher, chan requestWithHeaders, chan *jetflow.Response)
  • func (d *Publisher) Publish(ctx context.Context, call *jetflow.Request) (chan *jetflow.Response, error)

Types

type Consumer

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

func NewConsumer

func NewConsumer(inbox chan requestWithHeaders, outbox chan *jetflow.Response, handler jetflow.RequestHandler) *Consumer

func (*Consumer) Start

func (w *Consumer) Start(ctx context.Context)

type Publisher

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

func NewPublisher

func NewPublisher() (*Publisher, chan requestWithHeaders, chan *jetflow.Response)

func (*Publisher) Publish

func (d *Publisher) Publish(ctx context.Context, call *jetflow.Request) (chan *jetflow.Response, error)