watcher

type AccessWatcher struct {
	watchpb.UnimplementedWatchServiceServer
	// contains filtered or unexported fields
}

type AccessWatcherOption func(*AccessWatcher)

type ChangelogDatastore interface {
	GetRelationTupleChanges(ctx context.Context, namespaces []string, timestamp time.Time) (ChangelogIterator, error)
}

type ChangelogEntry struct {
	Namespace     string
	Operation     string
	RelationTuple *InternalRelationTuple
	Timestamp     time.Time
}

type ChangelogIterator interface {

	// Next prepares the next changelog entry for reading. It returns true
	// if there is another entry and false if no more entries are available.
	Next() bool

	// Value returns the current most changelog entry that the iterator is
	// iterating over.
	Value() (*ChangelogEntry, error)
}

type InternalRelationTuple struct {
	Namespace string  `json:"namespace"`
	Object    string  `json:"object"`
	Relation  string  `json:"relation"`
	Subject   Subject `json:"subject"`
}

type Subject interface {
	json.Marshaler

	String() string
	FromString(string) (Subject, error)
	Equals(interface{}) bool
	ToProto() *watchpb.Subject
}

type SubjectID struct {
	ID string `json:"id"`
}

type SubjectSet struct {
	Namespace string `json:"namespace"`
	Object    string `json:"object"`
	Relation  string `json:"relation"`
}