Documentation
¶
Index ¶
- Constants
- Variables
- func FileExists(filename string) bool
- func FindExec(name string) string
- func FuncNow(dbType DBType) string
- func GetConnectString(pluginContext *types.PluginContext) (string, error)
- func GetContextAppId(ctx context.Context) types.AppId
- func GetContextGroups(ctx context.Context) []string
- func GetContextRequestId(ctx context.Context) string
- func GetContextUserId(ctx context.Context) string
- func GetContextValue(ctx context.Context, key types.ContextKey) string
- func GetDefaultConfigs() (*types.GlobalConfig, *types.ClientConfig, *types.ServerConfig, error)
- func GetFuncMap() template.FuncMap
- func GetRequestGroups(thread *starlark.Thread) []string
- func GetRequestUrl(r *http.Request) string
- func GetRequestUserId(thread *starlark.Thread) string
- func GetThreadLocalKey(thread *starlark.Thread, key string) string
- func InsertIgnorePrefix(dbType DBType) string
- func InsertIgnoreSuffix(dbType DBType) string
- func IsGit(url string) bool
- func KillGroup(process *os.Process) error
- func LoadClientConfig(contents string, config *types.ClientConfig) error
- func LoadGlobalConfig(contents string, config *types.GlobalConfig) error
- func LoadProperties(filename string) (map[string]string, error)
- func LoadServerConfig(contents string, config *types.ServerConfig) error
- func MapDataType(dbType DBType, dataType string) string
- func MapServerHost(host string) string
- func NewClientConfigEmbedded() (*types.ClientConfig, error)
- func NewServerConfigEmbedded() (*types.ServerConfig, error)
- func PostgresRebind(q string) string
- func RebindQuery(dbType DBType, q string) string
- func SQLItePragmas(db *sql.DB) error
- func SetProcessGroup(cmd *exec.Cmd)
- type DBType
- type HttpClient
- type SecretManager
- type Transport
Constants ¶
const ( ApplicationJson = "application/json" OpenRunServiceLocation = "openrun" )
const (
DB_CONNECTION_CONFIG = "db_connection"
)
const DEFAULT_CONFIG = "openrun.default.toml"
const Scheme = "http+unix"
Scheme is the URL scheme used for HTTP over UNIX domain sockets.
Variables ¶
var ( DB_SQLITE_POSTGRES = []DBType{DB_TYPE_SQLITE, DB_TYPE_POSTGRES} DB_SQLITE = []DBType{DB_TYPE_SQLITE} DRIVER_MAP = map[DBType]string{ DB_TYPE_SQLITE: "sqlite", DB_TYPE_POSTGRES: "pgx", } )
Functions ¶
func FileExists ¶
func FindExec ¶
FindExec looks for the executable in the system PATH and returns its full path. If not found, it checks common Homebrew locations for the executable.
func GetConnectString ¶
func GetConnectString(pluginContext *types.PluginContext) (string, error)
func GetContextGroups ¶ added in v0.15.0
func GetContextRequestId ¶
func GetContextUserId ¶
func GetContextValue ¶
func GetContextValue(ctx context.Context, key types.ContextKey) string
func GetDefaultConfigs ¶
func GetDefaultConfigs() (*types.GlobalConfig, *types.ClientConfig, *types.ServerConfig, error)
func GetFuncMap ¶
GetFuncMap returns a template.FuncMap that includes all the sprig functions except for env and expandenv.
func GetRequestGroups ¶ added in v0.15.0
func GetRequestUrl ¶ added in v0.15.3
func GetRequestUserId ¶
func InsertIgnorePrefix ¶
func InsertIgnoreSuffix ¶
func LoadClientConfig ¶
func LoadClientConfig(contents string, config *types.ClientConfig) error
LoadClientConfig load a ClientConfig from the given contents
func LoadGlobalConfig ¶
func LoadGlobalConfig(contents string, config *types.GlobalConfig) error
LoadGlobalConfig load a GlobalConfig from the given contents
func LoadServerConfig ¶
func LoadServerConfig(contents string, config *types.ServerConfig) error
LoadServerConfig loads a ServerConfig from the given contents
func MapDataType ¶
func MapServerHost ¶
func NewClientConfigEmbedded ¶
func NewClientConfigEmbedded() (*types.ClientConfig, error)
NewClientConfigEmbedded reads the embedded toml file and creates a ClientConfig
func NewServerConfigEmbedded ¶
func NewServerConfigEmbedded() (*types.ServerConfig, error)
NewServerConfigEmbedded reads the embedded toml file and creates a ServerConfig
func PostgresRebind ¶
func RebindQuery ¶
func SQLItePragmas ¶
func SetProcessGroup ¶
SetProcessGroup sets the process group flag for the command
Types ¶
type HttpClient ¶
type HttpClient struct {
// contains filtered or unexported fields
}
func NewHttpClient ¶
func NewHttpClient(serverUri, user, password string, skipCertCheck bool) *HttpClient
NewHttpClient creates a new HttpClient instance
type SecretManager ¶
type SecretManager struct {
// contains filtered or unexported fields
}
SecretManager provides access to the secrets for the system
func NewSecretManager ¶
func NewSecretManager(ctx context.Context, secretConfig map[string]types.SecretConfig, defaultProvider string) (*SecretManager, error)
func (*SecretManager) AppEvalTemplate ¶
func (s *SecretManager) AppEvalTemplate(appSecrets [][]string, defaultProvider, input string) (string, error)
EvalTemplate evaluates the input string and replaces any secret placeholders with the actual secret value
func (*SecretManager) EvalTemplate ¶
func (s *SecretManager) EvalTemplate(input string) (string, error)
EvalTemplate evaluates the input string and replaces any secret placeholders with the actual secret value
type Transport ¶
type Transport struct {
// DialTimeout is deprecated. Use context instead.
DialTimeout time.Duration
// RequestTimeout is deprecated and has no effect.
RequestTimeout time.Duration
// ResponseHeaderTimeout is deprecated. Use context instead.
ResponseHeaderTimeout time.Duration
// contains filtered or unexported fields
}
Transport is a http.RoundTripper that connects to Unix domain sockets.
func (*Transport) RegisterLocation ¶
RegisterLocation registers an URL location and maps it to the given file system path.
Calling RegisterLocation twice for the same location is a programmer error, and causes a panic.
Source Files