jetstream

Documentation

Index

• Constants
• type Consumer
  • func NewConsumer(ctx context.Context, id int, jetstream jetstream.JetStream, ...) *Consumer
• type Publisher
  • func NewPublisher(ctx context.Context, jetstream jetstream.JetStream, consumerAmount int) *Publisher
  • func (d *Publisher) Publish(ctx context.Context, call *jetflow.Request) (chan *jetflow.Response, error)

Constants

const (
	STREAM_NAME_CLIENT   = "CLIENT"
	STREAM_NAME_OPERATOR = "OPERATOR"
)

Types

type Consumer

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

func NewConsumer

func NewConsumer(
	ctx context.Context,
	id int,
	jetstream jetstream.JetStream,
	handler jetflow.RequestHandler,
) *Consumer

type Publisher

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

func NewPublisher

func NewPublisher(ctx context.Context, jetstream jetstream.JetStream, consumerAmount int) *Publisher

func (*Publisher) Publish

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