server

package

v0.1.0-alpha.2 Latest Latest Go to latest Published: Jul 17, 2026 License: Apache-2.0 Imports: 2 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/crapthings/meldbase

Links

Open Source Insights

Documentation ¶

Overview ¶

Package server exposes Meldbase's authenticated HTTP, WebSocket realtime and data-only RPC transport. Protocol implementation remains isolated from the storage engine; applications opt into this package explicitly.

Index ¶

Constants
Variables
type Authenticator
type Authorizer
type Config
type DeletePolicy
type DurablePolicyGenerationStore
- func NewDurablePolicyGenerationStore(db *meldbase.DB) (*DurablePolicyGenerationStore, error)
type DurableRPCIdempotencyStore
- func NewDurableRPCIdempotencyStore(db *meldbase.DB) (DurableRPCIdempotencyStore, error)
type Handler
- func New(config Config) (*Handler, error)
type InsertPolicy
type PolicyGenerationStore
type Principal
type QueryPolicy
type QueryPolicyLease
- func NewQueryPolicyLease(version string) (*QueryPolicyLease, error)
type QueryPolicyResolver
type RPCAuthorizer
type RPCError
type RPCIdempotencyClaim
type RPCIdempotencyCompletion
type RPCIdempotencyDecision
type RPCIdempotencyDecisionKind
type RPCIdempotencyMaintenance
type RPCIdempotencyStore
type RPCMethod
type RPCMethodResolver
type RPCTransactionalMethod
type RPCTransactionalMethodResolver
type ServerStats
type UpdatePolicy
type WorkerAuthenticator
- func NewWorkerTokenAuthenticator(token string) (WorkerAuthenticator, error)
type WorkerHub
- func NewWorkerHub(config WorkerHubConfig) (*WorkerHub, error)
type WorkerHubConfig
type WorkerHubStats
type WorkerPrincipal

Constants ¶

View Source

const (
	ProtocolVersion              = internal.ProtocolVersion
	RPCIdempotencyExecute        = internal.RPCIdempotencyExecute
	RPCIdempotencyReplayResult   = internal.RPCIdempotencyReplayResult
	RPCIdempotencyReplayError    = internal.RPCIdempotencyReplayError
	RPCIdempotencyInProgress     = internal.RPCIdempotencyInProgress
	RPCIdempotencyOutcomeUnknown = internal.RPCIdempotencyOutcomeUnknown
	RPCIdempotencyConflict       = internal.RPCIdempotencyConflict
)

Variables ¶

View Source

var (
	ErrUnauthenticated = internal.ErrUnauthenticated
	ErrForbidden       = internal.ErrForbidden
)

Functions ¶

This section is empty.

Types ¶

type Authenticator ¶

type Authenticator = internal.Authenticator

type Authorizer ¶

type Authorizer = internal.Authorizer

type Config ¶

type Config = internal.Config

type DeletePolicy ¶

type DeletePolicy = internal.DeletePolicy

type DurablePolicyGenerationStore ¶

type DurablePolicyGenerationStore = internal.DurablePolicyGenerationStore

func NewDurablePolicyGenerationStore ¶

func NewDurablePolicyGenerationStore(db *meldbase.DB) (*DurablePolicyGenerationStore, error)

type DurableRPCIdempotencyStore ¶

type DurableRPCIdempotencyStore = internal.DurableRPCIdempotencyStore

func NewDurableRPCIdempotencyStore ¶

func NewDurableRPCIdempotencyStore(db *meldbase.DB) (DurableRPCIdempotencyStore, error)

type Handler ¶

type Handler = internal.Handler

func New ¶

func New(config Config) (*Handler, error)

type InsertPolicy ¶

type InsertPolicy = internal.InsertPolicy

type PolicyGenerationStore ¶

type PolicyGenerationStore = internal.PolicyGenerationStore

type Principal ¶

type Principal = internal.Principal

type QueryPolicy ¶

type QueryPolicy = internal.QueryPolicy

type QueryPolicyLease ¶

type QueryPolicyLease = internal.QueryPolicyLease

func NewQueryPolicyLease ¶

func NewQueryPolicyLease(version string) (*QueryPolicyLease, error)

type QueryPolicyResolver ¶

type QueryPolicyResolver = internal.QueryPolicyResolver

type RPCAuthorizer ¶

type RPCAuthorizer = internal.RPCAuthorizer

type RPCError ¶

type RPCError = internal.RPCError

type RPCIdempotencyClaim ¶

type RPCIdempotencyClaim = internal.RPCIdempotencyClaim

type RPCIdempotencyCompletion ¶

type RPCIdempotencyCompletion = internal.RPCIdempotencyCompletion

type RPCIdempotencyDecision ¶

type RPCIdempotencyDecision = internal.RPCIdempotencyDecision

type RPCIdempotencyDecisionKind ¶

type RPCIdempotencyDecisionKind = internal.RPCIdempotencyDecisionKind

type RPCIdempotencyMaintenance ¶

type RPCIdempotencyMaintenance = internal.RPCIdempotencyMaintenance

type RPCIdempotencyStore ¶

type RPCIdempotencyStore = internal.RPCIdempotencyStore

type RPCMethod ¶

type RPCMethod = internal.RPCMethod

type RPCMethodResolver ¶

type RPCMethodResolver = internal.RPCMethodResolver

type RPCTransactionalMethod ¶

type RPCTransactionalMethod = internal.RPCTransactionalMethod

type RPCTransactionalMethodResolver ¶

type RPCTransactionalMethodResolver = internal.RPCTransactionalMethodResolver

type ServerStats ¶

type ServerStats = internal.ServerStats

type UpdatePolicy ¶

type UpdatePolicy = internal.UpdatePolicy

type WorkerAuthenticator ¶

type WorkerAuthenticator = internal.WorkerAuthenticator

func NewWorkerTokenAuthenticator ¶

func NewWorkerTokenAuthenticator(token string) (WorkerAuthenticator, error)

type WorkerHub ¶

type WorkerHub = internal.WorkerHub

func NewWorkerHub ¶

func NewWorkerHub(config WorkerHubConfig) (*WorkerHub, error)

type WorkerHubConfig ¶

type WorkerHubConfig = internal.WorkerHubConfig

type WorkerHubStats ¶

type WorkerHubStats = internal.WorkerHubStats

type WorkerPrincipal ¶

type WorkerPrincipal = internal.WorkerPrincipal

Source Files ¶

View all Source files

server.go

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