cfg

package

Go to main page

Versions in this module

v0

v0.3.9-beta.1

Nov 17, 2025

v0.3.8

Jan 15, 2025

Changes in this version

+ type AutomationsConfig struct

+ Enable bool

+ Kubernetes KubernetesConfig

+ type CacheboxConfig struct

+ Driver string

+ Enable bool

+ Memory MemoryCacheboxConfig

+ Redis RedisCacheboxConfig

type CloudEventsConfig

+ AuditPolicy struct{ ... }

+ Enable bool

+ type FlowClientConfig struct

+ Appname string

+ Config *rest.Config

+ Namespace string

+ func (fcc *FlowClientConfig) GetScriptSource(assets fs.FS, name string) (string, error)

+ type KubernetesConfig struct

+ ConfigPath string

+ RestConfig ...

+ type LRUCachebox interface

+ GetStructValue func(ctx context.Context, key string, ptx any) bool

+ Remove func(ctx context.Context, key string) bool

+ SetValue func(ctx context.Context, key string, value any) bool

type LocalConfig

+ Automations *AutomationsConfig

+ Cachebox *CacheboxConfig

+ func (c *LocalConfig) GetAppname() string

+ func (c *LocalConfig) GetCacheboxRedisClient() (redis.UniversalClient, error)

+ func (c *LocalConfig) GetFlowClientConfig() (*FlowClientConfig, error)

+ func (c *LocalConfig) GetLRUCachebox() (LRUCachebox, error)

+ func (c *LocalConfig) GetNamespace() string

+ func (c *LocalConfig) GetRBACData(ctx context.Context) *rbacv3.RBAC

+ func (c *LocalConfig) HasCacheboxEnabled() bool

+ type MemoryCacheboxConfig struct

+ MaxEntry int

+ type RedisCacheboxConfig struct

+ DBNumber int

+ Endpoints []string

+ Password string

+ Sentinel struct{ ... }

+ TLSClientConfig *TLSConfig

+ Username string

v0.3.7

Aug 28, 2024

Changes in this version

type LocalConfig

+ func (c *LocalConfig) GetDatabaseEntSQLDriver() (*entsql.Driver, error)

v0.3.6

May 25, 2024

Changes in this version

type Authorization

+ OPAEnvoyPlugin OPAEnvoyPlugin

+ OPAExternal OPAExternal

+ OPANative OPANative

type LocalConfig

+ func (c *LocalConfig) SecurityPolicyLoad(ctx context.Context, assets embed.FS) error

+ type OPAEnvoyPlugin struct

+ Enabled *bool

+ Service struct{ ... }

+ type OPAExternal struct

+ Config string

+ Enabled *bool

+ type OPANative struct

+ Enabled *bool

+ Policy struct{ ... }

v0.3.5

Dec 26, 2023

Changes in this version

+ type FrontendConfig struct

+ Enable *bool

+ Interface FrontendInterface

+ type FrontendInterface struct

+ Admin *WebInterfaceConfig

+ Openapi *WebInterfaceConfig

+ Webroot *WebInterfaceConfig

+ type GRPCService struct

+ Address string

+ Enabled *bool

+ TLSServer *TLSConfig

+ type HTTPService struct

+ Address string

+ Enabled *bool

+ TLSAuto *TLSAutoConfig

+ TLSClient *TLSConfig

+ TLSServer *TLSConfig

type LocalConfig

+ Frontend *FrontendConfig

+ func (c *LocalConfig) HTTPHandlerFrontend(mux *http.ServeMux, assets fs.FS) error

+ func (c *LocalConfig) InitFrontend() error

type ServicesConfig

+ GRPCService *GRPCService

+ HTTPService *HTTPService

+ type TLSAutoConfig struct

+ ACME ...

+ SPIFFE ...

+ type WebInterfaceConfig struct

+ Embedded *bool

+ Enabled *bool

+ HandleURL string

+ Tracing bool

v0.3.4

Nov 15, 2023

v0.3.3

Nov 9, 2023

Changes in this version

+ const ScopeNameGRPCKit

+ type ExporterEnable struct

+ Logging *bool

+ OTLP *bool

+ OTLPHTTP *bool

+ Prometheus *bool

+ type ExportersConfig struct

+ Logging ...

+ OTLPGRPC *OTLPGRPCConfig

+ OTLPHTTP *OTLPHTTPConfig

+ Prometheus ...

type IDTokenClaims

+ Tenant string

type LocalConfig

+ Observables *ObservablesConfig

+ func (c *LocalConfig) GetTraceID(ctx context.Context) string

+ func (c *LocalConfig) HTTPHandler(handler http.Handler) http.Handler

+ func (c *LocalConfig) HTTPHandlerFunc(handler http.HandlerFunc) http.Handler

+ func (c *LocalConfig) InitObservables() error

+ func (c *LocalConfig) InitPrometheus() error

+ type OTLPGRPCConfig struct

+ Endpoint string

+ Headers map[string]string

+ type OTLPHTTPConfig struct

+ Endpoint string

+ Headers map[string]string

+ LogsURLPath string

+ MetricsURLPath string

+ TracesURLPath string

+ type ObservablesConfig struct

+ Enable *bool

+ Exporters *ExportersConfig

+ Telemetry *TelemetryConfig

+ type TelemetryConfig struct

+ Metrics *TelemetryMetric

+ Traces *TelemetryTrace

+ type TelemetryMetric struct

+ Exporters ExporterEnable

+ Namespace string

+ PushInterval int

+ type TelemetryTrace struct

+ Exporters ExporterEnable

+ Filters []struct{ ... }

+ LogFields struct{ ... }

+ SampleRatio *float64

v0.3.2

Aug 15, 2023

Changes in this version

+ const HTTPHeaderEtag

+ const HTTPHeaderHost

+ const ProxyContextHeader

+ const ProxyContextURLStyle

+ const URLStyleAuto

+ const URLStylePath

+ const URLStyleVirtualHosted

+ func NewHTTPTransport(config HTTPConfig) (*http.Transport, error)

+ func NewTLSConfig(t *TLSConfig) (*tls.Config, error)

+ type HTTPConfig struct

+ DisableCompression bool

+ DisableKeepAlives bool

+ ExpectContinueTimeout time.Duration

+ ForceAttemptHTTP2 bool

+ IdleConnTimeout time.Duration

+ MaxConnsPerHost int

+ MaxIdleConns int

+ MaxIdleConnsPerHost int

+ MaxResponseHeaderBytes int64

+ ReadBufferSize int

+ ResponseHeaderTimeout time.Duration

+ TLSClientConfig TLSConfig

+ TLSHandshakeTimeout time.Duration

+ WriteBufferSize int

type LocalConfig

+ Objstore *ObjstoreConfig

+ func (c *LocalConfig) GetObjstoreBucket() (ObjstoreBucket, error)

+ func (c *LocalConfig) GetObjstoreBucketReader() (ObjstoreBucketReader, error)

+ func (c *LocalConfig) GetObjstoreMinioClient() (*minio.Client, error)

+ func (c *LocalConfig) InitObjstore() error

+ type ObjstoreAttributes struct

+ ETag string

+ LastModified time.Time

+ Size int64

+ UserMetadata map[string]string

+ UserTags map[string]string

+ VersionID string

+ type ObjstoreBucket interface

+ CopyTo func(ctx context.Context, srcObjectKey, dstObjectKey string) (ObjstoreAttributes, error)

+ Delete func(ctx context.Context, objectKey string) error

+ Name func() string

+ Upload func(ctx context.Context, objectKey string, r io.Reader) (ObjstoreAttributes, error)

+ type ObjstoreBucketReader interface

+ Attributes func(ctx context.Context, objectKey string) (ObjstoreAttributes, error)

+ Exists func(ctx context.Context, objectKey string) (bool, error)

+ Get func(ctx context.Context, objectKey string) (io.ReadCloser, ObjstoreAttributes, error)

+ GetRange func(ctx context.Context, objectKey string, start, end int64) (io.ReadCloser, ObjstoreAttributes, error)

+ IsObjNotFoundErr func(err error) bool

+ Iter func(ctx context.Context, dir string, f func(string) error) error

+ type ObjstoreConfig struct

+ Config S3Config

+ Enable bool

+ Type string

+ func (o *ObjstoreConfig) BucketClient(logger *logrus.Entry) (ObjstoreBucket, error)

+ type ProxyBucket struct

+ func (b *ProxyBucket) Attributes(ctx context.Context, objectKey string) (ObjstoreAttributes, error)

+ func (b *ProxyBucket) Close() error

+ func (b *ProxyBucket) CopyTo(ctx context.Context, srcObjectKey, dstObjectKey string) (ObjstoreAttributes, error)

+ func (b *ProxyBucket) Delete(ctx context.Context, objectKey string) error

+ func (b *ProxyBucket) Exists(ctx context.Context, objectKey string) (bool, error)

+ func (b *ProxyBucket) Get(ctx context.Context, objectKey string) (io.ReadCloser, ObjstoreAttributes, error)

+ func (b *ProxyBucket) GetRange(ctx context.Context, objectKey string, start, end int64) (io.ReadCloser, ObjstoreAttributes, error)

+ func (b *ProxyBucket) IsObjNotFoundErr(err error) bool

+ func (b *ProxyBucket) Iter(ctx context.Context, dir string, f func(string) error) error

+ func (b *ProxyBucket) Name() string

+ func (b *ProxyBucket) Upload(ctx context.Context, objectKey string, r io.Reader) (ObjstoreAttributes, error)

+ type S3Bucket struct

+ func (b *S3Bucket) Attributes(ctx context.Context, objectkey string) (ObjstoreAttributes, error)

+ func (b *S3Bucket) Close() error

+ func (b *S3Bucket) CopyTo(ctx context.Context, srcObjectKey, dstObjectKey string) (ObjstoreAttributes, error)

+ func (b *S3Bucket) Delete(ctx context.Context, objectKey string) error

+ func (b *S3Bucket) Exists(ctx context.Context, objectKey string) (bool, error)

+ func (b *S3Bucket) Get(ctx context.Context, objectKey string) (io.ReadCloser, ObjstoreAttributes, error)

+ func (b *S3Bucket) GetRange(ctx context.Context, objectKey string, start, end int64) (io.ReadCloser, ObjstoreAttributes, error)

+ func (b *S3Bucket) IsObjNotFoundErr(err error) bool

+ func (b *S3Bucket) Iter(ctx context.Context, dir string, f func(string) error) error

+ func (b *S3Bucket) Name() string

+ func (b *S3Bucket) Upload(ctx context.Context, objectKey string, r io.Reader) (ObjstoreAttributes, error)

+ type S3Config struct

+ AccessKey string

+ Bucket string

+ BucketLookupType string

+ Endpoint string

+ HTTPConfig HTTPConfig

+ Insecure bool

+ ListObjectsVersion string

+ PartSize uint64

+ PutUserMetadata map[string]string

+ PutUserTags map[string]string

+ Region string

+ SSEConfig SSEConfig

+ SecretKey string

+ SessionToken string

+ SignatureVersion string

+ type SSEConfig struct

+ EncryptionKey string

+ KMSEncryptionContext map[string]string

+ KMSKeyID string

+ Type string

type TLSConfig

+ MaxVersion string

+ MinVersion string

+ ServerName string

+ type URLStyle string

v0.3.1

Apr 9, 2023

Changes in this version

+ const AuthenticationTypeBasic

+ const AuthenticationTypeBearer

+ const AuthenticationTypeNone

+ const CloudEventsProtocolKafkaSarama

+ const DatabaseDriverMysql

+ const DatabaseDriverPostgresql

+ const HTTPHeaderRequestID

+ const TraceBaggageHeaderPrefix

+ const TraceContextHeaderName

+ const UsernameAnonymous

+ var ErrDatabaseNotEnable = errors.New("database not enable")

+ var ErrDatabaseNotInit = errors.New("database not initialize")

+ var ErrDatabaseNotSupportDriver = errors.New("database driver not support")

+ var ErrDatabaseParamsMust = errors.New("database dbname username or password must")

+ var SHA256 scram.HashGeneratorFcn = sha256.New

+ var SHA512 scram.HashGeneratorFcn = sha512.New

+ type Authentication struct

+ HTTPUsers []*BasicAuth

+ InsecureRPCs []string

+ OIDCProvider *OIDCProvider

+ type Authorization struct

+ AllowedGroups []string

+ type BasicAuth struct

+ Groups []string

+ Password string

+ Username string

+ type CachebufConfig struct

+ Address string

+ Driver string

+ Enable bool

+ Password string

+ type CloudEventsConfig struct

+ KafkaSarama KafkaSarama

+ Protocol string

+ type ConnectionPool struct

+ MaxIdleConns int

+ MaxIdleTime time.Duration

+ MaxLifeTime time.Duration

+ MaxOpenConns int

+ type DatabaseConfig struct

+ Address string

+ ConnectionPool ConnectionPool

+ DBName string

+ Driver string

+ Enable bool

+ Parameters string

+ Password string

+ Protocol string

+ Username string

+ type DebuggerConfig struct

+ EnablePprof bool

+ LogFormat string

+ LogLevel string

+ type DiscoverConfig struct

+ Driver string

+ Endpoints []string

+ Heartbeat int64

+ TLS *TLSConfig

+ type IDTokenClaims struct

+ Email string

+ EmailVerified bool

+ FederatedClaims map[string]string

+ Groups []string

+ type KafkaSarama struct

+ Brokers []string

+ Config SaramaConfig

+ Topic string

+ type LocalConfig struct

+ Cachebuf *CachebufConfig

+ CloudEvents *CloudEventsConfig

+ Database *DatabaseConfig

+ Debugger *DebuggerConfig

+ Discover *DiscoverConfig

+ Independent interface{}

+ Opentracing *OpentracingConfig

+ Security *SecurityConfig

+ Services *ServicesConfig

+ func New(v *viper.Viper) (*LocalConfig, error)

+ func (c *LocalConfig) AuthenticationTypeFrom(ctx context.Context) (string, bool)

+ func (c *LocalConfig) Deregister() error

+ func (c *LocalConfig) GetClientDialOption(customOpts ...grpc.DialOption) []grpc.DialOption

+ func (c *LocalConfig) GetClientStreamInterceptor() []grpc.StreamClientInterceptor

+ func (c *LocalConfig) GetClientUnaryInterceptor() []grpc.UnaryClientInterceptor

+ func (c *LocalConfig) GetCloudEvents() (eventclient.Client, error)

+ func (c *LocalConfig) GetDatabase() (*sql.DB, error)

+ func (c *LocalConfig) GetIndependent(t interface{}) error

+ func (c *LocalConfig) GetLogger() *logrus.Entry

+ func (c *LocalConfig) GetRPCClient() (*rpc.Client, error)

+ func (c *LocalConfig) GetRPCServer() (*rpc.Server, error)

+ func (c *LocalConfig) GetServiceName() string

+ func (c *LocalConfig) GetStreamInterceptor(interceptors ...grpc.StreamServerInterceptor) grpc.ServerOption

+ func (c *LocalConfig) GetUnaryInterceptor(interceptors ...grpc.UnaryServerInterceptor) grpc.ServerOption

+ func (c *LocalConfig) GroupsFrom(ctx context.Context) ([]string, bool)

+ func (c *LocalConfig) IDTokenFrom(ctx context.Context) (IDTokenClaims, bool)

+ func (c *LocalConfig) Init() error

+ func (c *LocalConfig) InitCloudEvents() error

+ func (c *LocalConfig) InitDatabase() error

+ func (c *LocalConfig) InitDebugger() error

+ func (c *LocalConfig) InitOpentracing() (io.Closer, error)

+ func (c *LocalConfig) InitRPCConfig() error

+ func (c *LocalConfig) InitSecurity() error

+ func (c *LocalConfig) InitServices() error

+ func (c *LocalConfig) Register(ctx context.Context, ...) (*http.ServeMux, error)

+ func (c *LocalConfig) UsernameFrom(ctx context.Context) (string, bool)

+ func (c *LocalConfig) WithAuthenticationType(parent context.Context, authType string) context.Context

+ func (c *LocalConfig) WithGroups(parent context.Context, groups []string) context.Context

+ func (c *LocalConfig) WithIDToken(parent context.Context, token IDTokenClaims) context.Context

+ func (c *LocalConfig) WithUsername(parent context.Context, username string) context.Context

+ type LogFields struct

+ HTTPBody bool

+ HTTPResponse bool

+ type OIDCConfig struct

+ ClientID string

+ InsecureSkipVerify bool

+ SkipClientIDCheck bool

+ SkipExpiryCheck bool

+ SkipIssuerCheck bool

+ SupportedSigningAlgs []string

+ type OIDCProvider struct

+ Config *OIDCConfig

+ Issuer string

+ type OpentracingConfig struct

+ Enable bool

+ Host string

+ LogFields LogFields

+ Port int

+ type SaramaConfig struct

+ ChannelBufferSize int

+ ClientID string

+ Consumer struct{ ... }

+ Metadata struct{ ... }

+ Net struct{ ... }

+ Producer struct{ ... }

+ RackID string

+ Version string

+ func (s *SaramaConfig) Parse() *sarama.Config

+ type SecurityConfig struct

+ Authentication *Authentication

+ Authorization *Authorization

+ Enable bool

+ type ServicesConfig struct

+ APIEndpoint string

+ GRPCAddress string

+ HTTPAddress string

+ Namespace string

+ PublicAddress string

+ RootPath string

+ ServiceCode string

+ type TLSConfig struct

+ CAFile string

+ CertFile string

+ InsecureSkipVerify bool

+ KeyFile string

+ type XDGSCRAMClient struct

+ func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

+ func (x *XDGSCRAMClient) Done() bool

+ func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)

v0.3.0

Mar 10, 2023

v0.2.5

Apr 8, 2023

v0.2.4

Feb 26, 2023

v0.2.3

Nov 21, 2022

v0.1.11

Jun 9, 2022

v0.1.10

Jun 5, 2022

v0.1.9

May 7, 2022

v0.1.8

Apr 26, 2022

v0.1.7

Mar 13, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL