nats

type AppContext struct {
	Conn       *nats.Conn
	Logger     *slog.Logger
	Tracer     trace.Tracer
	Propagator propagation.TextMapPropagator
}

type AppHandler func(ctx context.Context, r micro.Request, h HandlerContext) error

type ClientError interface {
	Error() string
	Code() int
	Body() []byte
	LoggedError() []error
}

type ClientOpt func(*NATSClient)

type HandlerContext struct {
	Logger     *slog.Logger
	Conn       *nats.Conn
	Tracer     trace.Tracer
	Propagator propagation.TextMapPropagator
}

type HandlerWithErrors func(*slog.Logger, micro.Request) error

type NATSClient struct {
	Subject string
	Servers string
	Options []nats.Option
	Conn    *nats.Conn
	JS      nats.JetStreamContext
	NATSGraph
}

type NATSGraph struct {
	ExecutableSchema graphql.ExecutableSchema
	Exec             *executor.Executor
}

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