mocks

Documentation

Index

• type RelationshipReader
  • func (_m *RelationshipReader) GetUniqueEntityIDsByEntityType(ctx context.Context, tenantID string, typ, token string) (ids []string, err error)
  • func (_m *RelationshipReader) HeadSnapshot(ctx context.Context, tenantID string) (token.SnapToken, error)
  • func (_m *RelationshipReader) QueryRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter, snap string) (*database.TupleIterator, error)
  • func (_m *RelationshipReader) ReadRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter, snap string, ...) (collection *database.TupleCollection, ct database.EncodedContinuousToken, ...)
• type RelationshipWriter
• type SchemaReader
  • func (_m *SchemaReader) DeleteRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter) (token.EncodedSnapToken, error)
  • func (_m *SchemaReader) HeadVersion(ctx context.Context, tenantID string) (version string, err error)
  • func (_m *SchemaReader) ReadSchema(ctx context.Context, tenantID string, version string) (schema *base.SchemaDefinition, err error)
  • func (_m *SchemaReader) ReadSchemaDefinition(ctx context.Context, tenantID string, entityType, version string) (definition *base.EntityDefinition, v string, err error)
  • func (_m *SchemaReader) WriteRelationships(ctx context.Context, tenantID string, collection *database.TupleCollection) (token.EncodedSnapToken, error)
  • func (_m *SchemaReader) WriteSchema(ctx context.Context, definitions []repositories.SchemaDefinition) (err error)
• type SchemaWriter
• type TenantReader
  • func (_m *TenantReader) ListTenants(ctx context.Context, pagination database.Pagination) (tenants []*base.Tenant, ct database.EncodedContinuousToken, err error)
• type TenantWriter
  • func (_m *TenantWriter) CreateTenant(ctx context.Context, id, name string) (tenant *base.Tenant, err error)
  • func (_m *TenantWriter) DeleteTenant(ctx context.Context, tenantID string) (tenant *base.Tenant, err error)

Types

type RelationshipReader

type RelationshipReader struct {
	mock.Mock
}

RelationshipReader is an autogenerated mock type for the RelationshipReader type

func (*RelationshipReader) GetUniqueEntityIDsByEntityType

func (_m *RelationshipReader) GetUniqueEntityIDsByEntityType(ctx context.Context, tenantID string, typ, token string) (ids []string, err error)

GetUniqueEntityIDsByEntityType - Reads relation tuples from the repository.

func (*RelationshipReader) HeadSnapshot

func (_m *RelationshipReader) HeadSnapshot(ctx context.Context, tenantID string) (token.SnapToken, error)

HeadSnapshot - Reads the latest version of the snapshot from the repository.

func (*RelationshipReader) QueryRelationships

func (_m *RelationshipReader) QueryRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter, snap string) (*database.TupleIterator, error)

QueryRelationships - Reads relation tuples from the repository.

func (*RelationshipReader) ReadRelationships

func (_m *RelationshipReader) ReadRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter, snap string, pagination database.Pagination) (collection *database.TupleCollection, ct database.EncodedContinuousToken, err error)

ReadRelationships reads relation tuples from the repository with different options.

type RelationshipWriter

type RelationshipWriter struct {
	mock.Mock
}

RelationshipWriter is an autogenerated mock type for the RelationshipWriter type

type SchemaReader

type SchemaReader struct {
	mock.Mock
}

SchemaReader is an autogenerated mock type for the SchemaReader type

func (*SchemaReader) DeleteRelationships

func (_m *SchemaReader) DeleteRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter) (token.EncodedSnapToken, error)

DeleteRelationships - Delete relationship from repository

func (*SchemaReader) HeadVersion

func (_m *SchemaReader) HeadVersion(ctx context.Context, tenantID string) (version string, err error)

HeadVersion - Reads the latest version from the repository.

func (*SchemaReader) ReadSchema

func (_m *SchemaReader) ReadSchema(ctx context.Context, tenantID string, version string) (schema *base.SchemaDefinition, err error)

ReadSchema - Reads a new schema from repository

func (*SchemaReader) ReadSchemaDefinition

func (_m *SchemaReader) ReadSchemaDefinition(ctx context.Context, tenantID string, entityType, version string) (definition *base.EntityDefinition, v string, err error)

ReadSchemaDefinition - Reads a Schema Definition from repository

func (*SchemaReader) WriteRelationships

func (_m *SchemaReader) WriteRelationships(ctx context.Context, tenantID string, collection *database.TupleCollection) (token.EncodedSnapToken, error)

WriteRelationships - Write a Relation to repository

func (*SchemaReader) WriteSchema

func (_m *SchemaReader) WriteSchema(ctx context.Context, definitions []repositories.SchemaDefinition) (err error)

WriteSchema - Write Schema to repository

type SchemaWriter

type SchemaWriter struct {
	mock.Mock
}

SchemaWriter is an autogenerated mock type for the SchemaWriter type

type TenantReader

type TenantReader struct {
	mock.Mock
}

TenantReader is an autogenerated mock type for the TenantReader type

func (*TenantReader) ListTenants

func (_m *TenantReader) ListTenants(ctx context.Context, pagination database.Pagination) (tenants []*base.Tenant, ct database.EncodedContinuousToken, err error)

ListTenants - Reads a Schema Definition from repository

type TenantWriter

type TenantWriter struct {
	mock.Mock
}

TenantWriter is an autogenerated mock type for the TenantWriter type

func (*TenantWriter) CreateTenant

func (_m *TenantWriter) CreateTenant(ctx context.Context, id, name string) (tenant *base.Tenant, err error)

CreateTenant - Create Tenant to repository

func (*TenantWriter) DeleteTenant

func (_m *TenantWriter) DeleteTenant(ctx context.Context, tenantID string) (tenant *base.Tenant, err error)

DeleteTenant - Delete Tenant to repository