commands

package
v1.5.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 18, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Overview

Package commands contains the code that handles each endpoint.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateStoreCmdOption added in v1.3.8 

type CreateStoreCmdOption func(*CreateStoreCommand)

func WithCreateStoreCmdLogger added in v1.3.8 

func WithCreateStoreCmdLogger(l logger.Logger) CreateStoreCmdOption

type CreateStoreCommand 

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

func NewCreateStoreCommand 

func NewCreateStoreCommand(
	storesBackend storage.StoresBackend,
	opts ...CreateStoreCmdOption,
) *CreateStoreCommand

func (*CreateStoreCommand) Execute 

func (s *CreateStoreCommand) Execute(ctx context.Context, req *openfgav1.CreateStoreRequest) (*openfgav1.CreateStoreResponse, error)

type DeleteStoreCmdOption added in v1.3.8 

type DeleteStoreCmdOption func(*DeleteStoreCommand)

func WithDeleteStoreCmdLogger added in v1.3.8 

func WithDeleteStoreCmdLogger(l logger.Logger) DeleteStoreCmdOption

type DeleteStoreCommand 

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

func NewDeleteStoreCommand 

func NewDeleteStoreCommand(
	storesBackend storage.StoresBackend,
	opts ...DeleteStoreCmdOption,
) *DeleteStoreCommand

func (*DeleteStoreCommand) Execute 

func (s *DeleteStoreCommand) Execute(ctx context.Context, req *openfgav1.DeleteStoreRequest) (*openfgav1.DeleteStoreResponse, error)

type ExpandQuery 

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

ExpandQuery resolves a target TupleKey into a UsersetTree by expanding type definitions.

func NewExpandQuery 

func NewExpandQuery(datastore storage.OpenFGADatastore, opts ...ExpandQueryOption) *ExpandQuery

NewExpandQuery creates a new ExpandQuery using the supplied backends for retrieving data.

func (*ExpandQuery) Execute 

func (q *ExpandQuery) Execute(ctx context.Context, req *openfgav1.ExpandRequest) (*openfgav1.ExpandResponse, error)

type ExpandQueryOption added in v1.3.8 

type ExpandQueryOption func(*ExpandQuery)

func WithExpandQueryLogger added in v1.3.8 

func WithExpandQueryLogger(l logger.Logger) ExpandQueryOption

type GetStoreQuery 

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

func NewGetStoreQuery 

func NewGetStoreQuery(storesBackend storage.StoresBackend, opts ...GetStoreQueryOption) *GetStoreQuery

func (*GetStoreQuery) Execute 

func (q *GetStoreQuery) Execute(ctx context.Context, req *openfgav1.GetStoreRequest) (*openfgav1.GetStoreResponse, error)

type GetStoreQueryOption added in v1.3.8 

type GetStoreQueryOption func(*GetStoreQuery)

func WithGetStoreQueryLogger added in v1.3.8 

func WithGetStoreQueryLogger(l logger.Logger) GetStoreQueryOption

type ListObjectsQuery 

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

func NewListObjectsQuery added in v1.3.0 

func NewListObjectsQuery(
	ds storage.RelationshipTupleReader,
	checkResolver graph.CheckResolver,
	opts ...ListObjectsQueryOption,
) (*ListObjectsQuery, error)

func (*ListObjectsQuery) Execute 

func (q *ListObjectsQuery) Execute(
	ctx context.Context,
	req *openfgav1.ListObjectsRequest,
) (*ListObjectsResponse, error)

Execute the ListObjectsQuery, returning a list of object IDs up to a maximum of q.listObjectsMaxResults or until q.listObjectsDeadline is hit, whichever happens first.

func (*ListObjectsQuery) ExecuteStreamed 

func (q *ListObjectsQuery) ExecuteStreamed(ctx context.Context, req *openfgav1.StreamedListObjectsRequest, srv openfgav1.OpenFGAService_StreamedListObjectsServer) (*ListObjectsResolutionMetadata, error)

ExecuteStreamed executes the ListObjectsQuery, returning a stream of object IDs. It ignores the value of q.listObjectsMaxResults and returns all available results until q.listObjectsDeadline is hit.

type ListObjectsQueryOption added in v1.3.0 

type ListObjectsQueryOption func(d *ListObjectsQuery)

func WithDispatchThrottlerConfig added in v1.5.4 

func WithDispatchThrottlerConfig(config threshold.Config) ListObjectsQueryOption

func WithListObjectsDeadline added in v1.3.0 

func WithListObjectsDeadline(deadline time.Duration) ListObjectsQueryOption

func WithListObjectsMaxResults added in v1.3.0 

func WithListObjectsMaxResults(max uint32) ListObjectsQueryOption

func WithLogger added in v1.3.0 

func WithLogger(l logger.Logger) ListObjectsQueryOption

func WithMaxConcurrentReads added in v1.3.0 

func WithMaxConcurrentReads(limit uint32) ListObjectsQueryOption

WithMaxConcurrentReads see server.WithMaxConcurrentReadsForListObjects.

func WithResolveNodeBreadthLimit added in v1.3.0 

func WithResolveNodeBreadthLimit(limit uint32) ListObjectsQueryOption

WithResolveNodeBreadthLimit see server.WithResolveNodeBreadthLimit.

func WithResolveNodeLimit added in v1.3.0 

func WithResolveNodeLimit(limit uint32) ListObjectsQueryOption

WithResolveNodeLimit see server.WithResolveNodeLimit.

type ListObjectsResolutionMetadata added in v1.5.1 

type ListObjectsResolutionMetadata struct {
	// The total number of database reads from reverse_expand and Check (if any) to complete the ListObjects request
	DatastoreQueryCount *uint32

	// The total number of dispatches aggregated from reverse_expand and check resolutions (if any) to complete the ListObjects request
	DispatchCounter *atomic.Uint32

	// WasThrottled indicates whether the request was throttled
	WasThrottled *atomic.Bool
}

func NewListObjectsResolutionMetadata added in v1.5.1 

func NewListObjectsResolutionMetadata() *ListObjectsResolutionMetadata

type ListObjectsResponse added in v1.3.2 

type ListObjectsResponse struct {
	Objects            []string
	ResolutionMetadata ListObjectsResolutionMetadata
}

type ListObjectsResult added in v1.1.1 

type ListObjectsResult struct {
	ObjectID string
	Err      error
}

type ListStoresQuery 

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

func NewListStoresQuery 

func NewListStoresQuery(storesBackend storage.StoresBackend, opts ...ListStoresQueryOption) *ListStoresQuery

func (*ListStoresQuery) Execute 

func (q *ListStoresQuery) Execute(ctx context.Context, req *openfgav1.ListStoresRequest) (*openfgav1.ListStoresResponse, error)

type ListStoresQueryOption added in v1.3.8 

type ListStoresQueryOption func(*ListStoresQuery)

func WithListStoresQueryEncoder added in v1.3.8 

func WithListStoresQueryEncoder(e encoder.Encoder) ListStoresQueryOption

func WithListStoresQueryLogger added in v1.3.8 

func WithListStoresQueryLogger(l logger.Logger) ListStoresQueryOption

type ReadAssertionsQuery 

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

func NewReadAssertionsQuery 

func NewReadAssertionsQuery(backend storage.AssertionsBackend, opts ...ReadAssertionsQueryOption) *ReadAssertionsQuery

func (*ReadAssertionsQuery) Execute 

func (q *ReadAssertionsQuery) Execute(ctx context.Context, store, authorizationModelID string) (*openfgav1.ReadAssertionsResponse, error)

type ReadAssertionsQueryOption added in v1.3.8 

type ReadAssertionsQueryOption func(*ReadAssertionsQuery)

func WithReadAssertionsQueryLogger added in v1.3.8 

func WithReadAssertionsQueryLogger(l logger.Logger) ReadAssertionsQueryOption

type ReadAuthModelQueryOption added in v1.3.8 

type ReadAuthModelQueryOption func(*ReadAuthorizationModelQuery)

func WithReadAuthModelQueryLogger added in v1.3.8 

func WithReadAuthModelQueryLogger(l logger.Logger) ReadAuthModelQueryOption

type ReadAuthModelsQueryOption added in v1.3.8 

type ReadAuthModelsQueryOption func(*ReadAuthorizationModelsQuery)

func WithReadAuthModelsQueryEncoder added in v1.3.8 

func WithReadAuthModelsQueryEncoder(e encoder.Encoder) ReadAuthModelsQueryOption

func WithReadAuthModelsQueryLogger added in v1.3.8 

func WithReadAuthModelsQueryLogger(l logger.Logger) ReadAuthModelsQueryOption

type ReadAuthorizationModelQuery 

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

ReadAuthorizationModelQuery retrieves a single type definition from a storage backend.

func NewReadAuthorizationModelQuery 

func NewReadAuthorizationModelQuery(backend storage.AuthorizationModelReadBackend, opts ...ReadAuthModelQueryOption) *ReadAuthorizationModelQuery

func (*ReadAuthorizationModelQuery) Execute 

func (q *ReadAuthorizationModelQuery) Execute(ctx context.Context, req *openfgav1.ReadAuthorizationModelRequest) (*openfgav1.ReadAuthorizationModelResponse, error)

type ReadAuthorizationModelsQuery 

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

func NewReadAuthorizationModelsQuery 

func NewReadAuthorizationModelsQuery(backend storage.AuthorizationModelReadBackend, opts ...ReadAuthModelsQueryOption) *ReadAuthorizationModelsQuery

func (*ReadAuthorizationModelsQuery) Execute 

func (q *ReadAuthorizationModelsQuery) Execute(ctx context.Context, req *openfgav1.ReadAuthorizationModelsRequest) (*openfgav1.ReadAuthorizationModelsResponse, error)

type ReadChangesQuery 

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

func NewReadChangesQuery 

func NewReadChangesQuery(backend storage.ChangelogBackend, opts ...ReadChangesQueryOption) *ReadChangesQuery

NewReadChangesQuery creates a ReadChangesQuery with specified `ChangelogBackend`.

func (*ReadChangesQuery) Execute 

func (q *ReadChangesQuery) Execute(ctx context.Context, req *openfgav1.ReadChangesRequest) (*openfgav1.ReadChangesResponse, error)

Execute the ReadChangesQuery, returning paginated `openfga.TupleChange`(s) and a possibly non-empty continuation token.

type ReadChangesQueryOption added in v1.3.8 

type ReadChangesQueryOption func(*ReadChangesQuery)

func WithReadChangeQueryHorizonOffset added in v1.3.8 

func WithReadChangeQueryHorizonOffset(horizonOffset int) ReadChangesQueryOption

func WithReadChangesQueryEncoder added in v1.3.8 

func WithReadChangesQueryEncoder(e encoder.Encoder) ReadChangesQueryOption

func WithReadChangesQueryLogger added in v1.3.8 

func WithReadChangesQueryLogger(l logger.Logger) ReadChangesQueryOption

type ReadQuery 

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

A ReadQuery can be used to read one or many tuplesets Each tupleset specifies keys of a set of relation tuples. The set can include a single tuple key, or all tuples with a given object ID or userset in a type, optionally constrained by a relation name.

func NewReadQuery 

func NewReadQuery(datastore storage.OpenFGADatastore, opts ...ReadQueryOption) *ReadQuery

NewReadQuery creates a ReadQuery using the provided OpenFGA datastore implementation.

func (*ReadQuery) Execute 

func (q *ReadQuery) Execute(ctx context.Context, req *openfgav1.ReadRequest) (*openfgav1.ReadResponse, error)

Execute the ReadQuery, returning paginated `openfga.Tuple`(s) that match the tuple. Return all tuples if the tuple is nil or empty.

type ReadQueryOption added in v1.3.8 

type ReadQueryOption func(*ReadQuery)

func WithReadQueryEncoder added in v1.3.8 

func WithReadQueryEncoder(e encoder.Encoder) ReadQueryOption

func WithReadQueryLogger added in v1.3.8 

func WithReadQueryLogger(l logger.Logger) ReadQueryOption

type WriteAssertionsCmdOption added in v1.3.8 

type WriteAssertionsCmdOption func(*WriteAssertionsCommand)

func WithWriteAssertCmdLogger added in v1.3.8 

func WithWriteAssertCmdLogger(l logger.Logger) WriteAssertionsCmdOption

type WriteAssertionsCommand 

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

func NewWriteAssertionsCommand 

func NewWriteAssertionsCommand(
	datastore storage.OpenFGADatastore, opts ...WriteAssertionsCmdOption) *WriteAssertionsCommand

func (*WriteAssertionsCommand) Execute 

func (w *WriteAssertionsCommand) Execute(ctx context.Context, req *openfgav1.WriteAssertionsRequest) (*openfgav1.WriteAssertionsResponse, error)

type WriteAuthModelOption added in v1.3.8 

type WriteAuthModelOption func(*WriteAuthorizationModelCommand)

func WithWriteAuthModelLogger added in v1.3.8 

func WithWriteAuthModelLogger(l logger.Logger) WriteAuthModelOption

func WithWriteAuthModelMaxSizeInBytes added in v1.3.8 

func WithWriteAuthModelMaxSizeInBytes(size int) WriteAuthModelOption

type WriteAuthorizationModelCommand 

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

WriteAuthorizationModelCommand performs updates of the store authorization model.

func NewWriteAuthorizationModelCommand 

func NewWriteAuthorizationModelCommand(backend storage.TypeDefinitionWriteBackend, opts ...WriteAuthModelOption) *WriteAuthorizationModelCommand

func (*WriteAuthorizationModelCommand) Execute 

func (w *WriteAuthorizationModelCommand) Execute(ctx context.Context, req *openfgav1.WriteAuthorizationModelRequest) (*openfgav1.WriteAuthorizationModelResponse, error)

Execute the command using the supplied request.

type WriteCommand 

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

WriteCommand is used to Write and Delete tuples. Instances may be safely shared by multiple goroutines.

func NewWriteCommand 

func NewWriteCommand(datastore storage.OpenFGADatastore, opts ...WriteCommandOption) *WriteCommand

NewWriteCommand creates a WriteCommand with specified storage.OpenFGADatastore to use for storage.

func (*WriteCommand) Execute 

func (c *WriteCommand) Execute(ctx context.Context, req *openfgav1.WriteRequest) (*openfgav1.WriteResponse, error)

Execute deletes and writes the specified tuples. Deletes are applied first, then writes.

type WriteCommandOption added in v1.3.8 

type WriteCommandOption func(*WriteCommand)

func WithConditionContextByteLimit added in v1.3.8 

func WithConditionContextByteLimit(limit int) WriteCommandOption

func WithWriteCmdLogger added in v1.3.8 

func WithWriteCmdLogger(l logger.Logger) WriteCommandOption

Source Files

View all Source files

Directories

Path Synopsis
Package reverseexpand contains the code that handles the ReverseExpand API
 Package reverseexpand contains the code that handles the ReverseExpand API

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.