Documentation ¶
Index ¶
- func ConfigureOPALClient(opalClientConfig *OPALClientConfig) ([]byte, error)
- func InitPostgres(postgresHost string, postgresPort string, postgresDB string, ...) *pgxpool.Pool
- func VerifyJWTTokenAndExtractOPALClientID(tokenString string) (string, error)
- type Config
- type Entry
- type EntryConfig
- type EntryConfigConnectionParams
- type JWTTokenContent
- type OPALClient
- type OPALClientConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConfigureOPALClient ¶
func ConfigureOPALClient(opalClientConfig *OPALClientConfig) ([]byte, error)
func InitPostgres ¶
Types ¶
type Config ¶
type Config struct { AppEnv string Port string ShouldEnableServerTLS string ConfigLoaderCertPath string ConfigLoaderKeyPath string OPALAuthPublicKeyPath string OPALServerHost string OPALServerPort string OPALClientToken string PostgresHost string PostgresPort string PostgresDB string PostgresUser string PostgresPassword string }
type Entry ¶
type Entry struct { URL string `json:"url"` Config EntryConfig `json:"config"` Topics []string `json:"topics"` DstPath string `json:"dst_path"` }
type EntryConfig ¶
type EntryConfig struct { Fetcher string `json:"fetcher"` Query string `json:"query"` ConnectionParams EntryConfigConnectionParams `json:"connection_params"` DictKey string `json:"dict_key"` }
type EntryConfigConnectionParams ¶
type EntryConfigConnectionParams struct {
Password string `json:"password"`
}
type JWTTokenContent ¶
type JWTTokenContent struct {
ID string
}
type OPALClient ¶
type OPALClientConfig ¶
type OPALClientConfig struct {
Entries []Entry `json:"entries"`
}
func FetchOPALClientConfig ¶
func FetchOPALClientConfig(pg *pgxpool.Pool, opalClientID string) (*OPALClientConfig, error)
Click to show internal directories.
Click to hide internal directories.