shared

Documentation

Index

• func CheckPreconditions(ctx context.Context, rwt datastore.ReadWriteTransaction, ...) error
• func EnsureNoRelationshipsExist(ctx context.Context, rwt datastore.ReadWriteTransaction, namespaceName string) error
• func ErrorIfTupleIteratorReturnsTuples(ctx context.Context, qy datastore.RelationshipIterator, qyErr error, ...) error
• func NewPreconditionFailedErr(precondition *v1.Precondition) error
• func SanityCheckExistingRelationships(ctx context.Context, rwt datastore.ReadWriteTransaction, ...) error
• type ErrPreconditionFailed
  • func (epf ErrPreconditionFailed) MarshalZerologObject(e *zerolog.Event)
• type WithServiceSpecificInterceptors
  • func (wssi WithServiceSpecificInterceptors) StreamInterceptor() grpc.StreamServerInterceptor
  • func (wssi WithServiceSpecificInterceptors) UnaryInterceptor() grpc.UnaryServerInterceptor
• type WithStreamServiceSpecificInterceptor
  • func (wsssi WithStreamServiceSpecificInterceptor) StreamInterceptor() grpc.StreamServerInterceptor
• type WithUnaryServiceSpecificInterceptor
  • func (wussi WithUnaryServiceSpecificInterceptor) UnaryInterceptor() grpc.UnaryServerInterceptor

Functions

func CheckPreconditions

func CheckPreconditions(
	ctx context.Context,
	rwt datastore.ReadWriteTransaction,
	preconditions []*v1.Precondition,
) error

CheckPreconditions checks whether the preconditions are met in the context of a datastore read-write transaction, and returns an error if they are not met.

func EnsureNoRelationshipsExist

func EnsureNoRelationshipsExist(ctx context.Context, rwt datastore.ReadWriteTransaction, namespaceName string) error

EnsureNoRelationshipsExist ensures that no relationships exist within the namespace with the given name.

func ErrorIfTupleIteratorReturnsTuples

func ErrorIfTupleIteratorReturnsTuples(ctx context.Context, qy datastore.RelationshipIterator, qyErr error, message string, args ...interface{}) error

ErrorIfTupleIteratorReturnsTuples takes a tuple iterator and any error that was generated when the original iterator was created, and returns an error if iterator contains any tuples.

func NewPreconditionFailedErr

func NewPreconditionFailedErr(precondition *v1.Precondition) error

NewPreconditionFailedErr constructs a new precondition failed error.

func SanityCheckExistingRelationships

func SanityCheckExistingRelationships(
	ctx context.Context,
	rwt datastore.ReadWriteTransaction,
	nsdef *core.NamespaceDefinition,
	existingDefs map[string]*core.NamespaceDefinition,
) error

SanityCheckExistingRelationships ensures that a namespace definition being written does not result in relationships without associated defined schema object definitions and relations.

Types

type ErrPreconditionFailed

type ErrPreconditionFailed struct {
	// contains filtered or unexported fields
}

ErrPreconditionFailed occurs when the precondition to a write tuple call does not match.

func (ErrPreconditionFailed) MarshalZerologObject

func (epf ErrPreconditionFailed) MarshalZerologObject(e *zerolog.Event)

MarshalZerologObject implements zerolog object marshalling.

type WithServiceSpecificInterceptors

type WithServiceSpecificInterceptors struct {
	Unary  grpc.UnaryServerInterceptor
	Stream grpc.StreamServerInterceptor
}

WithServiceSpecificInterceptors is a helper to add both a unary and stream interceptor or interceptor chain to a service.

func (WithServiceSpecificInterceptors) StreamInterceptor

func (wssi WithServiceSpecificInterceptors) StreamInterceptor() grpc.StreamServerInterceptor

StreamInterceptor implements servicespecific.ExtraStreamInterceptor

func (WithServiceSpecificInterceptors) UnaryInterceptor

func (wssi WithServiceSpecificInterceptors) UnaryInterceptor() grpc.UnaryServerInterceptor

UnaryInterceptor implements servicespecific.ExtraUnaryInterceptor

type WithStreamServiceSpecificInterceptor

type WithStreamServiceSpecificInterceptor struct {
	Stream grpc.StreamServerInterceptor
}

WithStreamServiceSpecificInterceptor is a helper to add a stream interceptor or interceptor chain to a service.

func (WithStreamServiceSpecificInterceptor) StreamInterceptor

func (wsssi WithStreamServiceSpecificInterceptor) StreamInterceptor() grpc.StreamServerInterceptor

StreamInterceptor implements servicespecific.ExtraStreamInterceptor

type WithUnaryServiceSpecificInterceptor

type WithUnaryServiceSpecificInterceptor struct {
	Unary grpc.UnaryServerInterceptor
}

WithUnaryServiceSpecificInterceptor is a helper to add a unary interceptor or interceptor chain to a service.

func (WithUnaryServiceSpecificInterceptor) UnaryInterceptor

func (wussi WithUnaryServiceSpecificInterceptor) UnaryInterceptor() grpc.UnaryServerInterceptor

UnaryInterceptor implements servicespecific.ExtraUnaryInterceptor