consistency

Documentation

Index

• Variables
• func AddRevisionToContext(ctx context.Context, req interface{}, ds datastore.Datastore, ...) error
• func ContextWithHandle(ctx context.Context) context.Context
• func ForceFullConsistencyStreamServerInterceptor(serviceLabel string) grpc.StreamServerInterceptor
• func ForceFullConsistencyUnaryServerInterceptor(serviceLabel string) grpc.UnaryServerInterceptor
• func RevisionFromContext(ctx context.Context) (datastore.Revision, *v1.ZedToken, error)
• func StreamServerInterceptor(serviceLabel string) grpc.StreamServerInterceptor
• func UnaryServerInterceptor(serviceLabel string) grpc.UnaryServerInterceptor

Variables

var ConsistencyCounter = promauto.NewCounterVec(prometheus.CounterOpts{
	Namespace: "spicedb",
	Subsystem: "middleware",
	Name:      "consistency_assigned_total",
	Help:      "Count of the consistencies used per request",
}, []string{"method", "source", "service"})

Functions

func AddRevisionToContext

func AddRevisionToContext(ctx context.Context, req interface{}, ds datastore.Datastore, serviceLabel string) error

AddRevisionToContext adds a revision to the given context, based on the consistency block found in the given request (if applicable).

func ContextWithHandle

func ContextWithHandle(ctx context.Context) context.Context

ContextWithHandle adds a placeholder to a context that will later be filled by the revision

func ForceFullConsistencyStreamServerInterceptor

func ForceFullConsistencyStreamServerInterceptor(serviceLabel string) grpc.StreamServerInterceptor

ForceFullConsistencyStreamServerInterceptor returns a new stream server interceptor that enforces full consistency for all requests, except for those in the bypassServiceWhitelist.

func ForceFullConsistencyUnaryServerInterceptor

func ForceFullConsistencyUnaryServerInterceptor(serviceLabel string) grpc.UnaryServerInterceptor

ForceFullConsistencyUnaryServerInterceptor returns a new unary server interceptor that enforces full consistency for all requests, except for those in the bypassServiceWhitelist.

func RevisionFromContext

func RevisionFromContext(ctx context.Context) (datastore.Revision, *v1.ZedToken, error)

RevisionFromContext reads the selected revision out of a context.Context, computes a zedtoken from it, and returns an error if it has not been set on the context.

func StreamServerInterceptor

func StreamServerInterceptor(serviceLabel string) grpc.StreamServerInterceptor

StreamServerInterceptor returns a new stream server interceptor that performs per-request exchange of the specified consistency configuration for the revision at which to perform the request.

func UnaryServerInterceptor

func UnaryServerInterceptor(serviceLabel string) grpc.UnaryServerInterceptor

UnaryServerInterceptor returns a new unary server interceptor that performs per-request exchange of the specified consistency configuration for the revision at which to perform the request.