nats

type AccessCheckNATSRequest struct {
	// Subject is the NATS subject for the request
	Subject string `json:"subject"`
	// Message is the serialized request data
	Message []byte `json:"message"`
	// Timeout is the request timeout duration
	Timeout time.Duration `json:"timeout"`
}

type AccessCheckNATSResponse map[string]string

type Config struct {
	// URL is the NATS server URL
	URL string `json:"url"`
	// Timeout is the request timeout duration
	Timeout time.Duration `json:"timeout"`
	// MaxReconnect is the maximum number of reconnection attempts
	MaxReconnect int `json:"max_reconnect"`
	// ReconnectWait is the time to wait between reconnection attempts
	ReconnectWait time.Duration `json:"reconnect_wait"`
}

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

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

type NATSClientInterface interface {
	CheckAccess(ctx context.Context, request *AccessCheckNATSRequest) (AccessCheckNATSResponse, error)
	ReadTuples(ctx context.Context, request *ReadTuplesNATSRequest) (*ReadTuplesNATSResponse, error)
	Close() error
	IsReady(ctx context.Context) error
}

type ReadTuplesNATSRequest struct {
	User       string        `json:"user"`
	ObjectType string        `json:"object_type"`
	Timeout    time.Duration `json:"-"`
}

type ReadTuplesNATSResponse struct {
	Results []string `json:"results"`
	Error   string   `json:"error,omitempty"`
}