shared

Documentation

Index

• func EnsureNoRelationshipsExist(ctx context.Context, ds datastore.Datastore, namespaceName string) error
• func ErrorIfTupleIteratorReturnsTuples(ctx context.Context, qy datastore.TupleIterator, qyErr error, message string, ...) error
• func SanityCheckExistingRelationships(ctx context.Context, ds datastore.Datastore, nsdef *core.NamespaceDefinition, ...) error
• 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 EnsureNoRelationshipsExist

func EnsureNoRelationshipsExist(ctx context.Context, ds datastore.Datastore, 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.TupleIterator, 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 SanityCheckExistingRelationships

func SanityCheckExistingRelationships(ctx context.Context, ds datastore.Datastore, nsdef *core.NamespaceDefinition, revision decimal.Decimal) error

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

Types

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