frame

Dec 2, 2025

Changes in this version

+ var Commit string

+ var Date string

+ var Version string

Nov 22, 2025

Changes in this version

+ func ErrorIsNotFound(err error) bool

Nov 17, 2025

Changes in this version

type Service

+ func (s *Service) TelemetryManager() telemetry.Manager

Nov 1, 2025

Changes in this version

type Service

+ func (s *Service) EventsManager(_ context.Context) events.Manager

Oct 24, 2025

Changes in this version

+ const MemScheme

+ const MysqlScheme

+ const NatsScheme

+ const RedisScheme

type Option

+ func WithDatastoreConnectionWithOptions(name string, opts ...pool.Option) Option

+ func WithDatastoreManager() Option

+ func WithTelemetry(opts ...telemetry.Option) Option

type Service

+ func (s *Service) DatastoreManager() datastore.Manager

+ func (s *Service) HTTPClientManager() client.Manager

+ func (s *Service) LocalizationManager() localization.Manager

+ func (s *Service) QueueManager(_ context.Context) queue.Manager

+ func (s *Service) SecurityManager() security.Manager

Oct 24, 2025

Changes in this version

type Option

+ func WithRegisterServerOauth2Client() Option

Oct 23, 2025

Changes in this version

type Option

+ func WithCache(name string, rawCache cache.RawCache) Option

+ func WithCacheManager() Option

+ func WithInMemoryCache(name string) Option

+ func WithTranslation(translationsFolder string, languages ...string) Option

type Service

+ func (s *Service) AddPublisherStartup(f func(ctx context.Context, s *Service))

+ func (s *Service) AddStartupError(err error)

+ func (s *Service) AddSubscriberStartup(f func(ctx context.Context, s *Service))

+ func (s *Service) CacheManager() cache.Manager

+ func (s *Service) GetRawCache(name string) (cache.RawCache, bool)

+ func (s *Service) GetStartupErrors() []error

+ func (s *Service) Localization() localization.Manager

+ func (s *Service) Queue(_ context.Context) queue.Manager

+ func (s *Service) Security() security.Manager

+ func (s *Service) WorkManager() workerpool.Manager

Oct 4, 2025

Changes in this version

+ func ErrIsNotFound(err error) bool

Sep 29, 2025

Changes in this version

+ type Tracer interface

+ End func(ctx context.Context, span trace.Span, err error, ...)

+ Start func(ctx context.Context, methodName string, options ...trace.SpanStartOption) (context.Context, trace.Span)

Sep 28, 2025

Changes in this version

+ func NewHTTPClient(opts ...HTTPOption) *http.Client

type HTTPOption

+ func WithHTTPCheckRedirect(checkRedirect func(req *http.Request, via []*http.Request) error) HTTPOption

+ func WithHTTPCookieJar(jar http.CookieJar) HTTPOption

+ func WithHTTPIdleTimeout(timeout time.Duration) HTTPOption

+ func WithHTTPTimeout(timeout time.Duration) HTTPOption

+ func WithHTTPTransport(transport http.RoundTripper) HTTPOption

type Option

+ func WithHTTPClient(opts ...HTTPOption) Option

Sep 28, 2025

Changes in this version

type ConfigurationDefault

+ OpenTelemetryDisable bool

+ OpenTelemetryTraceRatio float64

+ func (c *ConfigurationDefault) SamplingRatio() float64

+ type ConfigurationTelemetry interface

+ DisableOpenTelemetry func() bool

+ SamplingRatio func() float64

+ type HTTPOption func(*httpConfig)

+ func WithTimeout(timeout time.Duration) HTTPOption

type Service

+ func (s *Service) HTTPClient() *http.Client

Sep 28, 2025

Changes in this version

type ConfigurationDefault

+ DisableOpenTelemetry bool

Sep 2, 2025

Changes in this version

type JSONMap

+ func (m *JSONMap) GetFloat(key string) float64

Sep 2, 2025

Changes in this version

type JSONMap

+ func (m *JSONMap) Copy() *JSONMap

+ func (m *JSONMap) GetString(key string) string

Sep 2, 2025

Changes in this version

type JSONMap

+ func (m *JSONMap) Update(update *JSONMap) *JSONMap

Sep 2, 2025

Changes in this version

type JSONMap

+ func (m *JSONMap) FromProtoStruct(s *structpb.Struct) *JSONMap

+ func (m *JSONMap) ToProtoStruct() (*structpb.Struct, error)

Sep 1, 2025

Changes in this version

type JSONMap

+ func (m *JSONMap) ToStructPB() (*structpb.Struct, error)

Aug 31, 2025

Changes in this version

type Option

+ func WithDriver(driver ServerDriver) Option

Aug 29, 2025

Changes in this version

+ type ServerDriver interface

Aug 23, 2025

Changes in this version

+ const ConstSystemScopeExternal

+ const ConstSystemScopeInternal

Aug 15, 2025

Changes in this version

type AuthenticationClaims

+ SessionID string

+ func (a *AuthenticationClaims) GetSessionID() string

Aug 15, 2025

Changes in this version

+ const ConstInternalSystemScope

type ConfigurationDefault

+ ServiceEnvironment string

+ ServiceName string

+ ServiceVersion string

Aug 15, 2025

Changes in this version

type ConfigurationDefault

+ Oauth2ServiceClientID string

+ func (c *ConfigurationDefault) GetOauth2ServiceClientID() string

type ConfigurationOAUTH2

+ GetOauth2ServiceClientID func() string

type Option

+ func WithEnvironment(environment string) Option

+ func WithName(name string) Option

+ func WithVersion(version string) Option

Aug 13, 2025

Changes in this version

type Option

+ func WithEnableTracing() Option

Aug 12, 2025

Changes in this version

type DataSource

+ func (d DataSource) ChangePort(newPort string) (DataSource, error)

Aug 1, 2025

Changes in this version

type JobResult

+ func ErrorResult[T any](err error) JobResult[T]

+ func Result[T any](item T) JobResult[T]

Jul 9, 2025

Changes in this version

type Option

+ func WithDisableTracing() Option

+ func WithMetricsReader(reader sdkmetrics.Reader) Option

+ func WithPropagationTextMap(carrier propagation.TextMapPropagator) Option

+ func WithTraceLogsExporter(exporter sdklogs.Exporter) Option

Jul 5, 2025

Changes in this version

+ const PostgresScheme

type ConfigurationDefault

+ WorkerPoolCPUFactorForWorkerCount int

+ WorkerPoolCapacity int

+ WorkerPoolCount int

+ WorkerPoolExpiryDuration string

+ func (c *ConfigurationDefault) GetCPUFactor() int

+ func (c *ConfigurationDefault) GetCapacity() int

+ func (c *ConfigurationDefault) GetCount() int

+ func (c *ConfigurationDefault) GetExpiryDuration() time.Duration

+ type ConfigurationWorkerPool interface

+ GetCPUFactor func() int

+ GetCapacity func() int

+ GetCount func() int

+ GetExpiryDuration func() time.Duration

+ type DataSource string

+ func (d DataSource) DelPath() DataSource

+ func (d DataSource) ExtendPath(epath ...string) DataSource

+ func (d DataSource) ExtendQuery(key, value string) DataSource

+ func (d DataSource) GetQuery(key string) string

+ func (d DataSource) IsCache() bool

+ func (d DataSource) IsDB() bool

+ func (d DataSource) IsMem() bool

+ func (d DataSource) IsMySQL() bool

+ func (d DataSource) IsNats() bool

+ func (d DataSource) IsPostgres() bool

+ func (d DataSource) IsQueue() bool

+ func (d DataSource) IsRedis() bool

+ func (d DataSource) PrefixPath(prefix string) DataSource

+ func (d DataSource) RemoveQuery(key ...string) DataSource

+ func (d DataSource) String() string

+ func (d DataSource) SuffixPath(suffix string) DataSource

+ func (d DataSource) ToArray() []DataSource

+ func (d DataSource) ToURI() (*url.URL, error)

+ func (d DataSource) WithPassword(password string) (DataSource, error)

+ func (d DataSource) WithPath(path string) (DataSource, error)

+ func (d DataSource) WithPathSuffix(suffix string) (DataSource, error)

+ func (d DataSource) WithQuery(query string) (DataSource, error)

+ func (d DataSource) WithUser(user string) (DataSource, error)

+ func (d DataSource) WithUserAndPassword(userName, password string) (DataSource, error)

Jun 28, 2025

Changes in this version

+ type JSONMap map[string]interface

+ func (m *JSONMap) GormDBDataType(db *gorm.DB, _ *schema.Field) string

+ func (m *JSONMap) GormDataType() string

+ func (m *JSONMap) GormValue(_ context.Context, db *gorm.DB) clause.Expr

+ func (m *JSONMap) MarshalJSON() ([]byte, error)

+ func (m *JSONMap) Scan(value interface{}) error

+ func (m *JSONMap) UnmarshalJSON(data []byte) error

+ func (m *JSONMap) Value() (driver.Value, error)

Jun 27, 2025

Changes in this version

+ func LanguageFromContext(ctx context.Context) []string

+ func LanguageFromGrpcRequest(ctx context.Context) []string

+ func LanguageFromMap(m map[string]string) []string

+ func LanguageToMap(m map[string]string, lang []string) map[string]string

+ func LangugageToContext(ctx context.Context, lang []string) context.Context

type Service

+ func (s *Service) LanguageHTTPMiddleware(next http.Handler) http.Handler

+ func (s *Service) LanguageStreamInterceptor() grpc.StreamServerInterceptor

+ func (s *Service) LanguageUnaryInterceptor() grpc.UnaryServerInterceptor

Jun 18, 2025

Changes in this version

type Subscriber

+ IsIdle func() bool

+ Metrics func() *SubscriberMetrics

+ State func() SubscriberState

+ type SubscriberMetrics struct

+ ActiveMessages *atomic.Int64

+ ErrorCount *atomic.Int64

+ LastActivity *atomic.Int64

+ MessageCount *atomic.Int64

+ ProcessingTime *atomic.Int64

+ func (m *SubscriberMetrics) AverageProcessingTime() time.Duration

+ func (m *SubscriberMetrics) IdleTime(state SubscriberState) time.Duration

+ func (m *SubscriberMetrics) IsIdle(state SubscriberState) bool

+ type SubscriberState int

+ const SubscriberStateInError

+ const SubscriberStateProcessing

+ const SubscriberStateWaiting

Jun 16, 2025

Changes in this version

+ func ConfigFillEnv(v any) error

Jun 12, 2025

Changes in this version

+ const DefaultSlowQueryThreshold

+ var ErrHealthCheckFailed = errors.New("health check failed")

+ var ErrTLSPathsNotProvided = errors.New("TLS certificate path or key path not provided")

+ var ErrWorkerPoolResultChannelIsClosed = errors.New("worker job is already closed")

+ func GetIP(r *http.Request) string

type AuthenticationClaims

+ func (a *AuthenticationClaims) GetAccessID() string

+ func (a *AuthenticationClaims) GetContactID() string

+ func (a *AuthenticationClaims) GetDeviceID() string

+ func (a *AuthenticationClaims) GetPartitionID() string

+ func (a *AuthenticationClaims) GetTenantID() string

type ConfigurationDefault

+ EventsQueueURL string

+ HTTPServerPort string

+ func (c *ConfigurationDefault) GetEventsQueueURL() string

+ func (c *ConfigurationDefault) HTTPPort() string

type ConfigurationEvents

+ GetEventsQueueURL func() string

type ConfigurationPorts

+ HTTPPort func() string

+ type DatastoreMigrator struct

+ func (m *DatastoreMigrator) ApplyNewMigrations(ctx context.Context) error

+ func (m *DatastoreMigrator) DB(ctx context.Context) *gorm.DB

+ func (m *DatastoreMigrator) SaveMigrationString(ctx context.Context, filename string, migrationPatch string, ...) error

type Option

+ func WithBackgroundConsumer(deque func(_ context.Context) error) Option

+ func WithEnableGRPCServerReflection() Option

+ func WithGRPCPort(port string) Option

+ func WithGRPCServer(grpcServer *grpc.Server) Option

+ func WithGRPCServerListener(listener net.Listener) Option

+ func WithHTTPHandler(h http.Handler) Option

+ func WithWorkerPoolOptions(options ...WorkerPoolOption) Option

type Service

+ func (s *Service) InvokeRestServiceURLEncoded(ctx context.Context, method string, endpointURL string, payload url.Values, ...) (int, []byte, error)

+ func (s *Service) NewMigrator(ctx context.Context, poolOpts ...*Pool) *DatastoreMigrator

+ func (s *Service) SetJwtClient(jwtCli map[string]any)

+ type WorkerPool interface

+ Shutdown func()

+ Submit func(ctx context.Context, task func()) error

+ type WorkerPoolOption func(*WorkerPoolOptions)

+ func WithPoolCount(count int) WorkerPoolOption

+ func WithPoolDisablePurge(disable bool) WorkerPoolOption

+ func WithPoolExpiryDuration(duration time.Duration) WorkerPoolOption

+ func WithPoolLogger(logger *util.LogEntry) WorkerPoolOption

+ func WithPoolNonblocking(nonblocking bool) WorkerPoolOption

+ func WithPoolPanicHandler(handler func(interface{})) WorkerPoolOption

+ func WithPoolPreAlloc(preAlloc bool) WorkerPoolOption

+ func WithSinglePoolCapacity(capacity int) WorkerPoolOption

+ type WorkerPoolOptions struct

+ Concurrency int

+ DisablePurge bool

+ ExpiryDuration time.Duration

+ Logger *util.LogEntry

+ Nonblocking bool

+ PanicHandler func(interface{})

+ PoolCount int

+ PreAlloc bool

+ SinglePoolCapacity int

Jun 11, 2025

Changes in this version

type Option

+ func WithBackGroundConsumer(deque func(ctx context.Context) error) Option

+ func WithConfig(config any) Option

+ func WithDatastore() Option

+ func WithDatastoreConnection(postgresqlConnection string, readOnly bool) Option

+ func WithDatastoreConnectionWithName(name string, postgresqlConnection string, readOnly bool) Option

+ func WithEnableGrpcServerReflection() Option

+ func WithGrpcPort(port string) Option

+ func WithGrpcServer(grpcServer *grpc.Server) Option

+ func WithGrpcServerListener(listener net.Listener) Option

+ func WithHealthCheckPath(path string) Option

+ func WithHttpHandler(h http.Handler) Option

+ func WithNoopDriver() Option

+ func WithRegisterEvents(events ...EventI) Option

+ func WithRegisterPublisher(reference string, queueURL string) Option

+ func WithRegisterSubscriber(reference string, queueURL string, handler ...SubscribeWorker) Option

+ func WithServerListener(listener net.Listener) Option

+ func WithTraceExporter(exporter sdktrace.SpanExporter) Option

+ func WithTraceSampler(sampler sdktrace.Sampler) Option

+ func WithTranslations(translationsFolder string, languages ...string) Option

Jun 11, 2025

Changes in this version

type ConfigurationDefault

+ LogShowStackTrace bool

+ func (c *ConfigurationDefault) LoggingShowStackTrace() bool

type ConfigurationLogLevel

+ LoggingShowStackTrace func() bool

type LogOptions

+ ShowStackTrace bool

Jun 11, 2025

Changes in this version

type LogEntry

+ func (e *LogEntry) With(args ...any) *LogEntry

type Logger

+ func (l *Logger) With(args ...any)

Jun 11, 2025

Changes in this version

type ConfigurationDatabase

+ CanDatabaseTraceQueries func() bool

+ GetDatabaseSlowQueryLogThreshold func() time.Duration

type ConfigurationDefault

+ DatabaseSlowQueryLogThreshold string

+ DatabaseTraceQueries bool

+ LogColored bool

+ LogFormat string

+ LogTimeFormat string

+ func (c *ConfigurationDefault) CanDatabaseTraceQueries() bool

+ func (c *ConfigurationDefault) GetDatabaseSlowQueryLogThreshold() time.Duration

+ func (c *ConfigurationDefault) LoggingColored() bool

+ func (c *ConfigurationDefault) LoggingFormat() string

+ func (c *ConfigurationDefault) LoggingTimeFormat() string

type ConfigurationLogLevel

+ LoggingColored func() bool

+ LoggingFormat func() string

+ LoggingTimeFormat func() string

type LogEntry

+ func (e *LogEntry) LevelEnabled(ctx context.Context, level slog.Level) bool

+ func (e *LogEntry) WithAttr(attr ...any) *LogEntry

+ type LogOptions struct

+ NoColor bool

+ PrintFormat string

+ TimeFormat string

type Logger

+ func (l *Logger) Enabled(ctx context.Context, level slog.Level) bool

+ func (l *Logger) WithAttr(attr ...any)

type Service

+ func (s *Service) Log(ctx context.Context) *LogEntry

Jun 10, 2025

Changes in this version

type ConfigurationDatabase

+ CanLogDatabaseQueries func() bool

type ConfigurationDefault

+ DatabaseLogQueries bool

+ func (c *ConfigurationDefault) CanLogDatabaseQueries() bool

Jun 10, 2025

Changes in this version

+ type LogEntry struct

+ func (e *LogEntry) Debug(msg string, args ...any)

+ func (e *LogEntry) Error(msg string, args ...any)

+ func (e *LogEntry) Fatal(msg string, args ...any)

+ func (e *LogEntry) Info(msg string, args ...any)

+ func (e *LogEntry) Level() slog.Level

+ func (e *LogEntry) Log(ctx context.Context, level slog.Level, msg string, fields ...any)

+ func (e *LogEntry) Panic(msg string, args ...any)

+ func (e *LogEntry) Printf(format string, args ...any)

+ func (e *LogEntry) Warn(msg string, args ...any)

+ func (e *LogEntry) WithContext(ctx context.Context) *LogEntry

+ func (e *LogEntry) WithError(err error) *LogEntry

+ func (e *LogEntry) WithField(key string, value any) *LogEntry

type Publisher

+ Ref func() string

Jun 9, 2025

Changes in this version

+ func Cfg(ctx context.Context) any

+ func LogToContext(ctx context.Context, logger *Entry) context.Context

+ func SvcToContext(ctx context.Context, service *Service) context.Context

type Entry

+ func Log(ctx context.Context) *Entry

type Service

+ func Svc(ctx context.Context) *Service

Jun 9, 2025

Changes in this version

type Entry

+ func (e *Entry) Panic(msg string, args ...any)

Jun 9, 2025

Changes in this version

type Logger

+ func (l *Logger) Panic(msg string, args ...any)

Jun 9, 2025

Changes in this version

+ func ParseLevel(levelStr string) (slog.Level, error)

+ type Entry struct

+ func (e *Entry) Debug(msg string, args ...any)

+ func (e *Entry) Error(msg string, args ...any)

+ func (e *Entry) Fatal(msg string, args ...any)

+ func (e *Entry) Info(msg string, args ...any)

+ func (e *Entry) Level() slog.Level

+ func (e *Entry) Log(ctx context.Context, level slog.Level, msg string, fields ...any)

+ func (e *Entry) Printf(format string, args ...any)

+ func (e *Entry) Warn(msg string, args ...any)

+ func (e *Entry) WithContext(ctx context.Context) *Entry

+ func (e *Entry) WithError(err error) *Entry

+ func (e *Entry) WithField(key string, value any) *Entry

type Logger

+ ExitFunc exitFunc

+ func NewLogger(logLevel slog.Level) *Logger

+ func (l *Logger) Debug(msg string, args ...any)

+ func (l *Logger) Error(msg string, args ...any)

+ func (l *Logger) Exit(code int)

+ func (l *Logger) Fatal(msg string, args ...any)

+ func (l *Logger) Info(msg string, args ...any)

+ func (l *Logger) Log(ctx context.Context, level slog.Level, msg string, fields ...any)

+ func (l *Logger) Warn(msg string, args ...any)

+ func (l *Logger) WithContext(ctx context.Context) *Entry

+ func (l *Logger) WithError(err error) *Entry

+ func (l *Logger) WithField(key string, value any) *Entry

+ func (l *Logger) WithFields(key string, value any) *Entry

type Option

+ func WithLogger() Option

type Service

+ func (s *Service) SLog(_ context.Context) *slog.Logger

Jun 8, 2025

Changes in this version

type Service

+ func (s *Service) DiscardPublisher(ctx context.Context, reference string) error

+ func (s *Service) DiscardSubscriber(ctx context.Context, reference string) error

May 28, 2025

Changes in this version

type Subscriber

+ Ref func() string

+ URI func() string

May 22, 2025

Changes in this version

type Subscriber

+ Idle func() bool

May 22, 2025

Changes in this version

+ type Publisher interface

+ Init func(ctx context.Context) error

+ Initiated func() bool

+ Publish func(ctx context.Context, payload any, headers ...map[string]string) error

+ Stop func(ctx context.Context) error

type Service

+ func (s *Service) AddSubscriber(ctx context.Context, reference string, queueURL string, ...) error

+ func (s *Service) GetPublisher(path string) Publisher

+ func (s *Service) GetSubscriber(path string) Subscriber

+ type Subscriber interface

+ Init func(ctx context.Context) error

+ Initiated func() bool

+ Receive func(ctx context.Context) (*pubsub.Message, error)

+ Stop func(ctx context.Context) error

May 13, 2025

Changes in this version

+ func ErrorIsNoRows(err error) bool

type ConfigurationDatabase

+ GetSlowQueryThreshold func() time.Duration

type ConfigurationDefault

+ DatabaseSlowQueryThreshold string

+ func (c *ConfigurationDefault) GetSlowQueryThreshold() time.Duration

May 2, 2025

Changes in this version

+ type MigrationPatch struct

+ Name string

+ Patch string

+ RevertPatch string

type Service

+ func (s *Service) MigratePool(ctx context.Context, pool *Pool, migrationsDirPath string, migrations ...any) error

+ func (s *Service) SaveMigration(ctx context.Context, migrationPatches ...MigrationPatch) error

+ func (s *Service) SaveMigrationWithPool(ctx context.Context, pool *Pool, migrationPatches ...MigrationPatch) error

May 2, 2025

Changes in this version

type Migration

+ RevertPatch string

Apr 28, 2025

Changes in this version

type Pool

+ func (s *Pool) CanMigrate() bool

Apr 24, 2025

Changes in this version

+ type Pool struct

+ func (s *Pool) CheckHealth() error

+ func (s *Pool) DB(ctx context.Context, readOnly bool) *gorm.DB

+ func (s *Pool) SetPoolConfig(maxOpen, maxIdle int, maxLifetime time.Duration)

type Service

+ func (s *Service) DBPool(name string) *Pool

Apr 24, 2025

Changes in this version

+ func CleanPostgresDSN(pgString string) (string, error)

type ConfigurationDatabase

+ PreferSimpleProtocol func() bool

type ConfigurationDefault

+ DatabasePreferSimpleProtocol bool

+ func (c *ConfigurationDefault) PreferSimpleProtocol() bool

type Option

+ func DatastoreConnectionWithName(ctx context.Context, name string, postgresqlConnection string, readOnly bool) Option

type Service

+ func (s *Service) DBWithName(ctx context.Context, name string, readOnly bool) *gorm.DB

+ type Store struct

+ func NewStore(ctx context.Context, srv *Service) *Store

+ func (s *Store) AddConnection(db *gorm.DB, readOnly bool)

+ func (s *Store) CheckHealth() error

+ func (s *Store) Cleanup(_ context.Context)

+ func (s *Store) MarkHealthy(readOnly bool, db *gorm.DB, isHealthy bool, err error) error

+ func (s *Store) PingWithTimeoutAndRetry(ctx context.Context, readOnly bool, db *gorm.DB) error

+ func (s *Store) SetPoolConfig(maxOpen, maxIdle int, maxLifetime time.Duration)

Feb 28, 2025

Changes in this version

+ func GenerateID(_ context.Context) string

Feb 27, 2025

Changes in this version

type AuthenticationClaims

+ func (a *AuthenticationClaims) GetServiceName() string

Feb 26, 2025

Changes in this version

+ func ConfigLoadWithOIDC[T any](ctx context.Context) (cfg T, err error)

type ConfigurationDefault

+ Oauth2WellKnownJwkData string

+ Oauth2WellKnownOIDCPath string

+ func (c *ConfigurationDefault) GetOauth2AuthorizationEndpoint() string

+ func (c *ConfigurationDefault) GetOauth2EndSessionEndpoint() string

+ func (c *ConfigurationDefault) GetOauth2Issuer() string

+ func (c *ConfigurationDefault) GetOauth2RegistrationEndpoint() string

+ func (c *ConfigurationDefault) GetOauth2RevocationEndpoint() string

+ func (c *ConfigurationDefault) GetOauth2TokenEndpoint() string

+ func (c *ConfigurationDefault) GetOauth2UserInfoEndpoint() string

+ func (c *ConfigurationDefault) GetOauth2WellKnownJwk() string

+ func (c *ConfigurationDefault) GetOauth2WellKnownJwkData() string

+ func (c *ConfigurationDefault) GetOauth2WellKnownOIDC() string

+ func (c *ConfigurationDefault) LoadOauth2Config(ctx context.Context) error

type ConfigurationOAUTH2

+ GetOauth2AuthorizationEndpoint func() string

+ GetOauth2EndSessionEndpoint func() string

+ GetOauth2Issuer func() string

+ GetOauth2RegistrationEndpoint func() string

+ GetOauth2RevocationEndpoint func() string

+ GetOauth2TokenEndpoint func() string

+ GetOauth2UserInfoEndpoint func() string

+ GetOauth2WellKnownJwk func() string

+ GetOauth2WellKnownJwkData func() string

+ GetOauth2WellKnownOIDC func() string

+ LoadOauth2Config func(ctx context.Context) error

+ type OIDCMap map[string]any

Feb 11, 2025

Changes in this version

+ func ConfigFillFromEnv(cfg any) error

+ func ConfigFromEnv[T any]() (cfg T, err error)

Jan 24, 2025

Changes in this version

type JobImpl

+ func (ji *JobImpl[J]) WriteError(ctx context.Context, val error) error

type JobResultPipe

+ WriteError func(ctx context.Context, val error) error

Jan 24, 2025

Changes in this version

+ func SubmitJob[J any](ctx context.Context, s *Service, job Job[J]) error

type Job

+ func NewJobWithBufferAndRetry[J any](process func(ctx context.Context, result JobResultPipe[J]) error, ...) Job[J]

+ func NewJobWithBuffer[J any](process func(ctx context.Context, result JobResultPipe[J]) error, buffer int) Job[J]

+ func NewJobWithRetry[J any](process func(ctx context.Context, result JobResultPipe[J]) error, retries int) Job[J]

+ func NewJob[J any](process func(ctx context.Context, result JobResultPipe[J]) error) Job[J]

+ type JobResult struct

+ Error error

+ Item J

+ func (j JobResult[J]) IsError() bool

Jan 15, 2025

Changes in this version

type AuthenticationClaims

+ DeviceID string

+ func (a *AuthenticationClaims) GetDeviceId() string

Dec 25, 2024

Changes in this version

+ func IsTenancyChecksOnClaimSkipped(ctx context.Context) bool

+ func SkipTenancyChecksOnClaims(ctx context.Context) context.Context

Oct 9, 2024

Changes in this version

+ func RemoveClaimsFromContext(ctx context.Context) context.Context

Oct 6, 2024

Changes in this version

+ func ConfigFromContext(ctx context.Context) any

+ func ConfigToContext(ctx context.Context, config any) context.Context

type ConfigurationDefault

+ RunServiceSecurely bool

+ func (c *ConfigurationDefault) IsRunSecurely() bool

+ type ConfigurationSecurity interface

+ IsRunSecurely func() bool

Oct 4, 2024

Changes in this version

type Service

+ func NewServiceWithContext(ctx context.Context, name string, opts ...Option) (context.Context, *Service)

Aug 26, 2024

Changes in this version

type ConfigurationDatabase

+ GetMaxConnectionLifeTimeInSeconds func() time.Duration

+ GetMaxIdleConnections func() int

+ GetMaxOpenConnections func() int

type ConfigurationDefault

+ DatabaseMaxConnectionLifeTimeSeconds int

+ DatabaseMaxIdleConnections int

+ DatabaseMaxOpenConnections int

+ func (c *ConfigurationDefault) GetMaxConnectionLifeTimeInSeconds() time.Duration

+ func (c *ConfigurationDefault) GetMaxIdleConnections() int

+ func (c *ConfigurationDefault) GetMaxOpenConnections() int

type Option

+ func DatastoreConnection(postgresqlConnection string, readOnly bool) Option

+ func DatastoreConnectionWithPooling(postgresqlConnection string, skipDefaultTransaction bool, ...) Option

+ func DatastoreConnectionWithSkipDefaultTransaction(postgresqlConnection string, skipDefaultTransaction bool, readOnly bool) Option

Aug 25, 2024

Changes in this version

type ConfigurationDatabase

+ SkipDefaultTransaction func() bool

type ConfigurationDefault

+ DatabaseSkipDefaultTransaction bool

+ func (c *ConfigurationDefault) SkipDefaultTransaction() bool

Aug 23, 2024

Changes in this version

+ func SafeChannelRead(ctx context.Context, ch <-chan any) (any, bool, error)

type Job

+ IncreaseRuns func()

type JobImpl

+ func (ji *JobImpl) IncreaseRuns()

+ func (ji *JobImpl) ReadResult(ctx context.Context) (any, bool, error)

+ type JobResultPipe interface

+ Close func()

+ IsClosed func() bool

+ ReadResult func(ctx context.Context) (any, bool, error)

+ ResultBufferSize func() int

+ ResultChan func() <-chan any

+ WriteResult func(ctx context.Context, val any) error

Aug 22, 2024

Changes in this version

type Job

+ CanRun func() bool

+ Close func()

+ IsClosed func() bool

+ ResultBufferSize func() int

+ ResultChan func() <-chan any

+ Retries func() int

+ Runs func() int

+ WriteResult func(ctx context.Context, val any) error

type JobImpl

+ func (ji *JobImpl) CanRun() bool

+ func (ji *JobImpl) Close()

+ func (ji *JobImpl) IsClosed() bool

+ func (ji *JobImpl) ResultBufferSize() int

+ func (ji *JobImpl) ResultChan() <-chan any

+ func (ji *JobImpl) Runs() int

+ func (ji *JobImpl) WriteResult(ctx context.Context, val any) error

type Service

+ func (s *Service) NewJobWithBuffer(process func(ctx context.Context) error, buffer int) Job

+ func (s *Service) NewJobWithBufferAndRetry(process func(ctx context.Context) error, resultBufferSize, retries int) Job

Aug 18, 2024

Changes in this version

+ func SafeChannelWrite(ctx context.Context, ch chan<- any, value any) error

Aug 16, 2024

Changes in this version

+ func RecoveryHandlerFun(ctx context.Context, p interface{}) error

May 17, 2024

Changes in this version

type AuthenticationClaims

+ ContactID string

+ func (a *AuthenticationClaims) GetAccessId() string

+ func (a *AuthenticationClaims) GetContactId() string

+ func (a *AuthenticationClaims) GetPartitionId() string

+ func (a *AuthenticationClaims) GetRoles() []string

+ func (a *AuthenticationClaims) GetTenantId() string

Apr 27, 2024

Changes in this version

type ConfigurationDefault

+ func (c *ConfigurationDefault) GetCORSExposedHeaders() []string

+ func (c *ConfigurationDefault) GetCORSMaxAge() int

Apr 23, 2024

Changes in this version

type ConfigurationCORS

+ GetCORSExposedHeaders func() []string

+ GetCORSMaxAge func() int

+ IsCORSAllowCredentials func() bool

type ConfigurationDefault

+ CORSAllowCredentials bool

+ CORSExposedHeaders []string

+ CORSMaxAge int

+ func (c *ConfigurationDefault) IsCORSAllowCredentials() bool

Apr 1, 2024

Changes in this version

type ConfigurationDefault

+ func (c *ConfigurationDefault) LoggingLevel() string

+ func (c *ConfigurationDefault) LoggingLevelIsDebug() bool

+ type ConfigurationLogLevel interface

+ LoggingLevel func() string

+ LoggingLevelIsDebug func() bool

Feb 22, 2024

Changes in this version

type BaseModel

+ func (model *BaseModel) CopyPartitionInfo(parent *BaseModel)

Feb 22, 2024

Changes in this version

type BaseModel

+ func (model *BaseModel) SetPartitionInfo(ctx context.Context)

Jan 24, 2024

Changes in this version

+ func GetLoggingOptions() []logging.Option

+ func LoggingInterceptor(l logrus.FieldLogger) logging.Logger

Jan 23, 2024

Changes in this version

type ConfigurationDefault

+ LogLevel string

Jan 22, 2024

Changes in this version

type AuthenticationClaims

+ func (a *AuthenticationClaims) ServiceName() string

Jan 22, 2024

Changes in this version

+ func JwtFromContext(ctx context.Context) string

Jan 20, 2024

Changes in this version

type AuthenticationClaims

+ Ext map[string]any

+ func (a *AuthenticationClaims) AccessId() string

+ func (a *AuthenticationClaims) PartitionId() string

+ func (a *AuthenticationClaims) TenantId() string

Jan 17, 2024

Changes in this version

type Service

+ func (s *Service) AddPublisher(ctx context.Context, reference string, queueURL string)

+ func (s *Service) IsPublisherRegistered(_ context.Context, reference string) bool

Dec 12, 2023

Changes in this version

+ type ConfigurationCORS interface

+ GetCORSAllowedHeaders func() []string

+ GetCORSAllowedMethods func() []string

+ GetCORSAllowedOrigins func() []string

+ IsCORSEnabled func() bool

type ConfigurationDefault

+ CORSAllowedHeaders []string

+ CORSAllowedMethods []string

+ CORSAllowedOrigins []string

+ CORSEnabled bool

+ func (c *ConfigurationDefault) GetCORSAllowedHeaders() []string

+ func (c *ConfigurationDefault) GetCORSAllowedMethods() []string

+ func (c *ConfigurationDefault) GetCORSAllowedOrigins() []string

+ func (c *ConfigurationDefault) IsCORSEnabled() bool

Dec 11, 2023

Changes in this version

type ConfigurationDefault

+ AllowedOrigins string

Jul 3, 2023

Changes in this version

type Service

+ func (s *Service) NewJobWithErrorChan(process func(ctx context.Context) error) Job

Jul 3, 2023

Changes in this version

type Job

+ CloseChan func()

+ F func() func(ctx context.Context) error

+ PipeError func(err error)

type JobImpl

+ func (ji *JobImpl) CloseChan()

+ func (ji *JobImpl) F() func(ctx context.Context) error

+ func (ji *JobImpl) PipeError(err error)

Jul 3, 2023

Changes in this version

type Job

+ ErrChan func() chan error

type JobImpl

+ ErrorChan chan error

+ func (ji *JobImpl) ErrChan() chan error

type Service

+ func (s *Service) NewJobWithRetry(process func(ctx context.Context) error, retries int) Job

+ func (s *Service) NewJobWithRetryAndErrorChan(process func(ctx context.Context) error, retries int, errsChan chan error) Job

Jun 29, 2023

Changes in this version

type ConfigurationDefault

+ HttpServerPort string

+ func (c *ConfigurationDefault) HttpPort() string

+ type ConfigurationPorts interface

+ GrpcPort func() string

+ HttpPort func() string

+ Port func() string

Jun 27, 2023

Changes in this version

type Option

+ func EnableGrpcServerReflection() Option

Jun 19, 2023

Changes in this version

+ func NewGrpcHealthServer(service *Service) grpc_health_v1.HealthServer

Jun 18, 2023

Changes in this version

+ func OutputGeneratedTLSCertificate(cert *tls.Certificate, certFile, keyFile string) error

type ConfigurationDefault

+ GrpcServerPort string

+ TLSCertificateCommonName string

+ TLSCertificateCountry string

+ TLSCertificateDomains string

+ TLSCertificateKeyPath string

+ TLSCertificateOrganization string

+ TLSCertificateOrganizationUnit string

+ TLSCertificatePath string

+ TLSCertificateValidDays string

+ TLSCertificateValidMonths string

+ TLSCertificateValidYears string

+ func (c *ConfigurationDefault) GrpcPort() string

+ func (c *ConfigurationDefault) Port() string

+ func (c *ConfigurationDefault) SetTLSCertAndKeyPath(certificatePath, certificateKeyPath string)

+ func (c *ConfigurationDefault) TLSCertCommonName() string

+ func (c *ConfigurationDefault) TLSCertCountry() string

+ func (c *ConfigurationDefault) TLSCertDomains() []string

+ func (c *ConfigurationDefault) TLSCertKeyPath() string

+ func (c *ConfigurationDefault) TLSCertOrganization() string

+ func (c *ConfigurationDefault) TLSCertOrganizationUnit() string

+ func (c *ConfigurationDefault) TLSCertPath() string

+ func (c *ConfigurationDefault) TLSCertValidDays() int

+ func (c *ConfigurationDefault) TLSCertValidMonths() int

+ func (c *ConfigurationDefault) TLSCertValidYears() int

+ type ConfigurationGrpcPort interface

+ GrpcPort func() string

+ type ConfigurationPort interface

+ Port func() string

+ type ConfigurationTLS interface

+ SetTLSCertAndKeyPath func(certificatePath, certificateKeyPath string)

+ TLSCertCommonName func() string

+ TLSCertCountry func() string

+ TLSCertDomains func() []string

+ TLSCertKeyPath func() string

+ TLSCertOrganization func() string

+ TLSCertOrganizationUnit func() string

+ TLSCertPath func() string

+ TLSCertValidDays func() int

+ TLSCertValidMonths func() int

+ TLSCertValidYears func() int

type Option

+ func GrpcPort(port string) Option

+ func GrpcServerListener(listener net.Listener) Option

+ func TLSCertificateGenerate() Option

type Service

+ func (s *Service) TLSConfig() *tls.Config

+ func (s *Service) TLSEnabled() bool

Jun 15, 2023

Changes in this version

type Option

+ func HealthCheckPath(path string) Option

type Service

+ func (s *Service) HandleHealthByDefault(w http.ResponseWriter, r *http.Request)

Jun 15, 2023

Changes in this version

type Service

+ func (s *Service) H() http.Handler

+ func (s *Service) HandleHealth(w http.ResponseWriter, _ *http.Request)

May 7, 2023

Changes in this version

type Job

+ Async func() bool

type JobImpl

+ IsAsync bool

+ func (ji *JobImpl) Async() bool

type Service

+ func (s *Service) NewSyncJob(process func(ctx context.Context) error) Job

May 7, 2023

Changes in this version

type Option

+ func WithPoolCapacity(capacity int) Option

+ func WithPoolConcurrency(workers int) Option

Apr 25, 2023

Changes in this version

type Service

+ func (s *Service) JwtClientSecret() string

+ func (s *Service) RegisterForJwt(ctx context.Context) error

Apr 24, 2023

Changes in this version

type Service

+ func (s *Service) JwtClient() map[string]interface{}

+ func (s *Service) JwtClientID() string

Apr 22, 2023

Changes in this version

+ type Job interface

+ CanRetry func() bool

+ DecreaseRetries func() int

+ ID func() string

+ Process func(ctx context.Context) error

+ type JobImpl struct

+ Id string

+ Retries int

+ func (ji *JobImpl) CanRetry() bool

+ func (ji *JobImpl) DecreaseRetries() int

+ func (ji *JobImpl) ID() string

+ func (ji *JobImpl) Process(ctx context.Context) error

type Option

+ func WithConcurrency(workers int) Option

type Service

+ JwtClientId string

+ func (s *Service) InvokeRestServiceUrlEncoded(ctx context.Context, method string, endpointURL string, payload url.Values, ...) (int, []byte, error)

+ func (s *Service) LogLevel() *logrus.Level

+ func (s *Service) NewJob(process func(ctx context.Context) error, retries int) Job

+ func (s *Service) SubmitJob(ctx context.Context, job Job) error

Apr 18, 2023

Changes in this version

type ConfigurationDefault

+ EventsQueueName string

+ EventsQueueUrl string

+ func (c *ConfigurationDefault) GetEventsQueueName() string

+ func (c *ConfigurationDefault) GetEventsQueueUrl() string

+ type ConfigurationEvents interface

+ GetEventsQueueName func() string

+ GetEventsQueueUrl func() string

Apr 18, 2023

Changes in this version

type Service

+ func (s *Service) ErrorGroup() *errgroup.Group

Apr 12, 2023

Changes in this version

type Option

+ func BackGroundConsumer(deque func() error) Option

Apr 12, 2023

Changes in this version

type Option

+ func DequeueClient(deque func() error) Option

type Service

+ func (s *Service) Authenticate(ctx context.Context, jwtToken string, audience string, issuer string) (context.Context, error)

Jan 26, 2023

Changes in this version

type Service

+ func (s *Service) UnRegisterForJwt(ctx context.Context, oauth2ServiceAdminHost string, clientID string) error

Jan 7, 2023

Changes in this version

type ConfigurationDatabase

+ GetDatabasePrimaryHostURL func() string

+ GetDatabaseReplicaHostURL func() string

type ConfigurationDefault

+ Oauth2ServiceAdminURI string

+ func (c *ConfigurationDefault) GetDatabasePrimaryHostURL() string

+ func (c *ConfigurationDefault) GetDatabaseReplicaHostURL() string

+ func (c *ConfigurationDefault) GetOauth2ServiceAdminURI() string

+ func (c *ConfigurationDefault) GetOauth2ServiceAudience() string

+ func (c *ConfigurationDefault) GetOauth2ServiceClientSecret() string

type ConfigurationOAUTH2

+ GetOauth2ServiceAdminURI func() string

+ GetOauth2ServiceAudience func() string

+ GetOauth2ServiceClientSecret func() string

Jan 1, 2023

Changes in this version

type Service

+ func (s *Service) RegisterForJwtWithParams(ctx context.Context, clientName string, clientID string, clientSecret string) error

Sep 2, 2022

Changes in this version

+ type ConfigurationDatabase interface

+ DoDatabaseMigrate func() bool

+ GetDatabaseMigrationPath func() string

+ GetDatabasePrimaryHostUrl func() string

+ GetDatabaseReplicaHostUrl func() string

type ConfigurationDefault

+ DatabaseMigrate string

+ DatabaseMigrationPath string

+ DatabasePrimaryURL string

+ DatabaseReplicaURL string

+ func (c *ConfigurationDefault) DoDatabaseMigrate() bool

+ func (c *ConfigurationDefault) GetDatabaseMigrationPath() string

+ func (c *ConfigurationDefault) GetDatabasePrimaryHostUrl() string

+ func (c *ConfigurationDefault) GetDatabaseReplicaHostUrl() string

type Option

+ func DatastoreCon(ctx context.Context, postgresqlConnection string, readOnly bool) Option

Aug 30, 2022

Changes in this version

+ type ConfigurationAuthorization interface

+ GetAuthorizationServiceReadURI func() string

+ GetAuthorizationServiceWriteURI func() string

+ type ConfigurationDefault struct

+ AuthorizationServiceReadURI string

+ AuthorizationServiceWriteURI string

+ Oauth2JwtVerifyAudience string

+ Oauth2JwtVerifyIssuer string

+ Oauth2ServiceAudience string

+ Oauth2ServiceClientSecret string

+ Oauth2ServiceURI string

+ Oauth2WellKnownJwk string

+ ServerPort string

+ func (c *ConfigurationDefault) GetAuthorizationServiceReadURI() string

+ func (c *ConfigurationDefault) GetAuthorizationServiceWriteURI() string

+ func (c *ConfigurationDefault) GetOauth2ServiceURI() string

+ func (c *ConfigurationDefault) GetOauthWellKnownJwk() string

+ type ConfigurationOAUTH2 interface

+ GetOauth2ServiceURI func() string

+ GetOauthWellKnownJwk func() string

Aug 29, 2022

Changes in this version

+ type AuthorizationConfiguration interface

+ GetAuthorizationServiceReadURI func() string

+ GetAuthorizationServiceWriteURI func() string

type DefaultConfiguration

+ AuthorizationServiceReadURI string

+ AuthorizationServiceWriteURI string

+ Oauth2JwtVerifyAudience string

+ Oauth2JwtVerifyIssuer string

+ Oauth2ServiceAudience string

+ Oauth2ServiceClientSecret string

+ Oauth2ServiceURI string

+ Oauth2WellKnownJwk string

+ func (d DefaultConfiguration) GetAuthorizationServiceReadURI() string

+ func (d DefaultConfiguration) GetAuthorizationServiceWriteURI() string

+ func (d DefaultConfiguration) GetOauth2ServiceURI() string

+ func (d DefaultConfiguration) GetOauthWellKnownJwk() string

type OAUTH2Configuration

+ GetOauth2ServiceURI func() string

+ GetOauthWellKnownJwk func() string

Aug 29, 2022

Changes in this version

type Service

+ func (s *Service) AuthenticationMiddleware(next http.Handler, audience string, issuer string) http.Handler

+ func (s *Service) StreamAuthInterceptor(audience string, issuer string) grpc.StreamServerInterceptor

+ func (s *Service) UnaryAuthInterceptor(audience string, issuer string) grpc.UnaryServerInterceptor

Aug 29, 2022

Changes in this version

+ func ConfigProcess(prefix string, config interface{}) error

type DatabaseConfiguration

+ DatabaseURL string

+ Migrate string

+ MigrationPath string

+ ReplicaDatabaseURL string

Aug 29, 2022

Changes in this version

+ type DatabaseConfiguration struct

+ EnvDatabaseURL string

+ EnvMigrate string

+ EnvMigrationPath string

+ EnvReplicaDatabaseURL string

+ type DefaultConfiguration struct

+ ServerPort string

+ type OAUTH2Configuration struct

+ AuthorizationServiceReadURI string

+ AuthorizationServiceWriteURI string

+ Oauth2JwtVerifyAudience string

+ Oauth2JwtVerifyIssuer string

+ Oauth2ServiceAudience string

+ Oauth2ServiceClientSecret string

+ Oauth2ServiceURI string

+ Oauth2WellKnownJwk string

type Service

+ func (s *Service) ProcessConfig(prefix string, config interface{}) error

Aug 29, 2022

Changes in this version

+ func HandleLive(w http.ResponseWriter, _ *http.Request)

+ type Checker interface

+ CheckHealth func() error

+ type CheckerFunc func() error

+ func (f CheckerFunc) CheckHealth() error

+ type Configuration struct

+ AuthorizationServiceReadURI string

+ AuthorizationServiceWriteURI string

+ Oauth2WellKnownJwk string

type Option

+ func Config(config interface{}) Option

+ func LivelinessPath(path string) Option

+ func NoopDriver() Option

+ func ReadinessPath(path string) Option

+ func TraceExporter(exporter sdktrace.SpanExporter) Option

+ func TraceSampler(sampler sdktrace.Sampler) Option

type Service

+ func (s *Service) Config() interface{}

+ func (s *Service) Environment() string

+ func (s *Service) HealthCheckers() []Checker

+ func (s *Service) ServeHTTP(w http.ResponseWriter, _ *http.Request)

+ func (s *Service) SubscriptionIsInitiated(path string) bool

+ func (s *Service) Version() string

Apr 22, 2022

Changes in this version

type Option

+ func CorsPolicy(cors string) Option

Jan 23, 2022

Changes in this version

+ type BaseRepositoryI interface

+ Delete func(id string) error

+ GetByID func(id string, result BaseModelI) error

+ Save func(instance BaseModelI) error

Jan 23, 2022

Changes in this version

type BaseRepository

+ func NewBaseRepository(readDb *gorm.DB, writeDB *gorm.DB, instanceCreator func() BaseModelI) BaseRepository

Jan 23, 2022

Changes in this version

+ type BaseRepository struct

+ func (repo *BaseRepository) Delete(id string) error

+ func (repo *BaseRepository) GetAllBy(properties map[string]interface{}, instanceList interface{}) error

+ func (repo *BaseRepository) GetByID(id string) (BaseModelI, error)

+ func (repo *BaseRepository) GetLastestBy(properties map[string]interface{}) (BaseModelI, error)

+ func (repo *BaseRepository) Save(instance BaseModelI) error

+ func (repo *BaseRepository) Search(query string, searchFields []string, instanceList interface{}) error

Jan 22, 2022

Changes in this version

type BaseModel

+ func (model *BaseModel) GetVersion() uint

type BaseModelI

+ GetVersion func() uint

Oct 12, 2021

Changes in this version

type AuthenticationClaims

+ func (a *AuthenticationClaims) VerifyIssuer(cmp string, req bool) bool

Oct 10, 2021

Changes in this version

type BaseModel

+ func (model *BaseModel) ValidXID(id string) bool

Oct 10, 2021

Changes in this version

type Option

+ func RegisterEvents(events ...EventI) Option

Sep 5, 2021

Changes in this version

+ type EventI interface

+ Execute func(ctx context.Context, payload interface{}) error

+ Name func() string

+ PayloadType func() interface{}

+ Validate func(ctx context.Context, payload interface{}) error

+ type ILogger interface

+ Debug func(template string, args ...interface{})

+ Error func(template string, args ...interface{})

+ Fatal func(template string, args ...interface{})

+ Info func(template string, args ...interface{})

+ Panic func(template string, args ...interface{})

+ Warn func(template string, args ...interface{})

type Option

+ func Logger() Option

+ func RegisterEvent(e EventI) Option

type Service

+ func (s *Service) Emit(ctx context.Context, name string, payload interface{}) error

+ func (s *Service) L() ILogger

Sep 4, 2021

Changes in this version

type BaseModel

+ AccessID string

Aug 24, 2021

Changes in this version

+ func AuthHasAccess(ctx context.Context, action string, subject string) (error, bool)

type Option

+ func QueuePath(path string) Option

type Service

+ func (s *Service) Name() string

Jun 17, 2021

Changes in this version

type Option

+ func NoopHttpOptions() Option

Jun 15, 2021

Changes in this version

type BaseModel

+ func (model *BaseModel) BeforeSave(db *gorm.DB) error

Jun 13, 2021

Changes in this version

+ func DBErrorIsRecordNotFound(err error) bool

+ func DBPropertiesFromMap(propsMap map[string]string) datatypes.JSONMap

+ func DBPropertiesToMap(props datatypes.JSONMap) map[string]string

Jun 13, 2021

Changes in this version

type BaseModel

+ func (model *BaseModel) GenID()

Jun 5, 2021

Changes in this version

+ func PropertiesFromMap(propsMap map[string]string) datatypes.JSONMap

+ func PropertiesToMap(props datatypes.JSONMap) map[string]string

Jun 1, 2021

Changes in this version

type AuthenticationClaims

+ IsCCBot bool

+ Roles []string

May 29, 2021

Changes in this version

type Service

+ func (s *Service) Translate(lang string, messageId string) (string, error)

+ func (s *Service) TranslateWithMap(lang string, messageId string, variables map[string]interface{}) (string, error)

+ func (s *Service) TranslateWithMapAndCount(lang string, messageId string, variables map[string]interface{}, count int) (string, error)

May 29, 2021

Changes in this version

+ type JSONWebKeys struct

+ E string

+ Kid string

+ Kty string

+ N string

+ Use string

+ X5c []string

+ type Jwks struct

+ Keys []JSONWebKeys

May 26, 2021

Changes in this version

type Service

+ func (s *Service) AddPreStartMethod(f func(s *Service))

May 24, 2021

Changes in this version

type AuthenticationClaims

+ func ClaimsFromMap(m map[string]string) *AuthenticationClaims

May 17, 2021

Changes in this version

type Service

+ func (s *Service) InvokeRestService(ctx context.Context, method string, authorizationUrl string, ...) ([]byte, error)

May 17, 2021

Changes in this version

+ func InvokeRestService(ctx context.Context, method string, authorizationUrl string, ...) ([]byte, error)

type AuthenticationClaims

+ AccessID string

Apr 29, 2021

Changes in this version

+ func AuthenticationMiddleware(next http.Handler) http.Handler

+ func StreamAuthInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error

+ func TenantPartition(ctx context.Context) func(db *gorm.DB) *gorm.DB

+ func UnaryAuthInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

+ type AuthenticationClaims struct

+ PartitionID string

+ ProfileID string

+ SubscriptionID string

+ TenantID string

+ func ClaimsFromContext(ctx context.Context) *AuthenticationClaims

+ func (a *AuthenticationClaims) AsMetadata() map[string]string

+ func (a *AuthenticationClaims) ClaimsToContext(ctx context.Context) context.Context

type BaseModel

+ PartitionID string

+ TenantID string

Apr 20, 2021

Changes in this version

type Service

+ func (s *Service) Bundle() *i18n.Bundle

Apr 20, 2021

Changes in this version

+ func AuthorizationControlListHasAccess(ctx context.Context, action string, subject string) (error, bool)

+ func AuthorizationControlListWrite(ctx context.Context, action string, subject string) error

type Option

+ func Translations(languages ...string) Option

Jan 29, 2021

Changes in this version

type Service

+ func (s *Service) Init(opts ...Option)

Jan 29, 2021

Changes in this version

+ func GetEnv(key, fallback string) string

+ func GetIp(r *http.Request) string

+ func GetLocalIP() string

+ func GetMacAddress() string

+ func ToContext(ctx context.Context, service *Service) context.Context

+ type BaseModel struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ ID string

+ ModifiedAt time.Time

+ Version uint32

+ func (model *BaseModel) BeforeCreate(db *gorm.DB) error

+ func (model *BaseModel) BeforeUpdate(db *gorm.DB) error

+ func (model *BaseModel) GetID() string

+ type BaseModelI interface

+ GetID func() string

+ type Migration struct

+ AppliedAt *time.Time

+ Name string

+ Patch string

+ type Option func(service *Service)

+ func Datastore(ctx context.Context, postgresqlConnection string, readOnly bool) Option

+ func GrpcServer(grpcServer *grpc.Server) Option

+ func HttpHandler(h http.Handler) Option

+ func HttpOptions(httpOpts *server.Options) Option

+ func RegisterPublisher(reference string, queueUrl string) Option

+ func RegisterSubscriber(reference string, queueUrl string, concurrency int, handler SubscribeWorker) Option

+ func ServerListener(listener net.Listener) Option

+ type Queue struct

+ type Service struct

+ func FromContext(ctx context.Context) *Service

+ func NewService(name string, opts ...Option) *Service

+ func (s *Service) AddCleanupMethod(f func())

+ func (s *Service) AddHealthCheck(checker health.Checker)

+ func (s *Service) DB(ctx context.Context, readOnly bool) *gorm.DB

+ func (s *Service) MigrateDatastore(ctx context.Context, migrationsDirPath string, migrations ...interface{}) error

+ func (s *Service) Run(ctx context.Context, address string) error

+ func (s *Service) Stop()

+ func (s Service) Publish(ctx context.Context, reference string, message []byte, ...) error

+ func (s Service) QID(ctx context.Context, payload []byte) (string, error)

+ func (s Service) QObject(ctx context.Context, model BaseModelI) ([]byte, map[string]string, error)

+ type SubscribeWorker interface

+ Handle func(ctx context.Context, message []byte, metadata map[string]string) error