app

Documentation

Index

• Variables
• func AddDefaultHandlers(eventBus events.EventBus, iso18626Client client.Iso18626Client, ...)
• func CreateEventBus(eventRepo events.EventRepo) events.EventBus
• func CreateEventRepo(dbPool *pgxpool.Pool) events.EventRepo
• func HandleHealthz(w http.ResponseWriter, r *http.Request)
• func InitDbPool() (*pgxpool.Pool, error)
• func Run(ctx context.Context) error
• func RunDbUp() error
• func StartEventBus(ctx context.Context, eventBus events.EventBus) error
• func StartServer(ctx Context) error
• type Context
  • func Init(ctx context.Context) (Context, error)

Variables

var API_PAGE_SIZE int32 = int32(utils.Must(utils.GetEnvInt("API_PAGE_SIZE", int(api.LIMIT_DEFAULT))))

var BROKER_MODE = utils.GetEnv("BROKER_MODE", "opaque")

var CLIENT_DELAY = utils.GetEnv("CLIENT_DELAY", "0ms")

var ConnectionString = dbutil.GetConnectionString(DB_TYPE, DB_USER, DB_PASSWORD, DB_HOST, DB_PORT, DB_DATABASE, DB_SCHEMA)

var DB_DATABASE = utils.GetEnv("DB_DATABASE", "crosslink")

var DB_EXPLAIN_ANALYZE, _ = utils.GetEnvBool("DB_EXPLAIN_ANALYZE", false)

var DB_HOST = utils.GetEnv("DB_HOST", "localhost")

var DB_MIGRATE, _ = utils.GetEnvBool("DB_MIGRATE", true)

var DB_PASSWORD = utils.GetEnv("DB_PASSWORD", "crosslink")

var DB_PORT = utils.GetEnv("DB_PORT", "25432")

var DB_PROVISION, _ = utils.GetEnvBool("DB_PROVISION", false)

var DB_SCHEMA = utils.GetEnv("DB_SCHEMA", "crosslink_broker")

var DB_TYPE = utils.GetEnv("DB_TYPE", "postgres")

var DB_USER = utils.GetEnv("DB_USER", "crosslink")

var DIRECTORY_ADAPTER = utils.GetEnv("DIRECTORY_ADAPTER", "mock")

var DIRECTORY_API_URL = utils.GetEnv("DIRECTORY_API_URL", "http://localhost:8081/directory/entries")

var ENABLE_JSON_LOG = utils.GetEnv("ENABLE_JSON_LOG", "false")

var HOLDINGS_ADAPTER = utils.GetEnv("HOLDINGS_ADAPTER", "mock")

var HOLDINGS_ISXN_LOOKUP, _ = utils.GetEnvBool("HOLDINGS_ISXN_LOOKUP", false)

var HOLDINGS_SRU_URL = common.GetEnvWithDeprecated("HOLDINGS_SRU_URL", "SRU_URL", "http://localhost:8081/sru")

var HTTP_PORT = utils.Must(utils.GetEnvInt("HTTP_PORT", 8081))

var LOG_LEVEL = utils.GetEnv("LOG_LEVEL", "INFO")

var MAX_MESSAGE_SIZE, _ = utils.GetEnvAny("MAX_MESSAGE_SIZE", int(100*1024), func(val string) (int, error) {
	v, err := humanize.ParseBytes(val)
	if err != nil && v > uint64(math.MaxInt) {
		appCtx.Logger().Error("MAX_MESSAGE_SIZE value is too large, using default")
		return 0, fmt.Errorf("value %s is too large", val)
	}
	return int(v), err
})

var MigrationsFolder = "file://migrations"

var SHUTDOWN_DELAY, _ = utils.GetEnvAny("SHUTDOWN_DELAY", time.Duration(15*float64(time.Second)), func(val string) (time.Duration, error) {
	d, err := time.ParseDuration(val)
	if err != nil {
		return 0, fmt.Errorf("invalid SHUTDOWN_DELAY value: %s", val)
	}
	return d, nil
})

var ServeMux *http.ServeMux

var TENANT_TO_SYMBOL = os.Getenv("TENANT_TO_SYMBOL")

Functions

func AddDefaultHandlers

func AddDefaultHandlers(eventBus events.EventBus, iso18626Client client.Iso18626Client,
	supplierLocator service.SupplierLocator, workflowManager service.WorkflowManager, iso18626Handler handler.Iso18626Handler,
	prActionService prservice.PatronRequestActionService, prApiHandler prapi.PatronRequestApiHandler, sseBroker *api.SseBroker)

func CreateEventBus

func CreateEventBus(eventRepo events.EventRepo) events.EventBus

func CreateEventRepo

func CreateEventRepo(dbPool *pgxpool.Pool) events.EventRepo

func HandleHealthz

func HandleHealthz(w http.ResponseWriter, r *http.Request)

func InitDbPool

func InitDbPool() (*pgxpool.Pool, error)

func Run

func Run(ctx context.Context) error

func RunDbUp

func RunDbUp() error

func StartEventBus

func StartEventBus(ctx context.Context, eventBus events.EventBus) error

func StartServer

func StartServer(ctx Context) error

Types

type Context

type Context struct {
	EventBus       events.EventBus
	IllRepo        ill_db.IllRepo
	EventRepo      events.EventRepo
	DirAdapter     adapter.DirectoryLookupAdapter
	PrRepo         pr_db.PrRepo
	TenantResolver *tenant.TenantResolver
	ApiHandler     api.ApiHandler
	PrApiHandler   prapi.PatronRequestApiHandler
	SseBroker      *api.SseBroker
	PsApiHandler   psapi.PullSlipApiHandler
}

func Init

func Init(ctx context.Context) (Context, error)