monolith

README

monolith

Documentation

Index

• type Connection
• type IAuthorizer
• type ICache
• type IConnection
• type IObserver
• type ISession
• type Observer

Types

type Connection

type Connection = IConnection[sqlx.DB]

type IAuthorizer

type IAuthorizer interface {
	Authorize(actor interface{}, action interface{}, resource interface{}) error
}

type ICache

type ICache interface {
	Get(ctx context.Context, key string, out protoreflect.ProtoMessage) error
	Set(ctx context.Context, key string, val protoreflect.ProtoMessage, expiration ...time.Duration) error
}

type IConnection

type IConnection[T any] interface {
	GetConnection(ctx context.Context) (T, bool)
}

type IObserver

type IObserver[T comparable] interface {
	Subscribe(t T, p observer.Processor[T]) observer.SourceID
	Unsubscribe(s observer.SourceID)
	Emit(e *observer.Event[T]) error
}

type ISession

type ISession interface {
	Claims(accessToken string) (*jwt.RegisteredClaims, error)
}

type Observer

type Observer = IObserver[string]