Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

accesscontroller

package

Go to main page

Versions in this module

v0

v0.1.5

Aug 31, 2021

v0.1.4

Aug 19, 2021

v0.1.3

Jul 9, 2021

v0.1.2

Jun 29, 2021

Changes in this version

type AccessController

+ func (a *AccessController) HealthCheck(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

+ type HealthChecker struct

+ func NewHealthChecker(handler healthCheckHandler) *HealthChecker

+ func (s *HealthChecker) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

+ func (s *HealthChecker) Watch(req *grpc_health_v1.HealthCheckRequest, srv grpc_health_v1.Health_WatchServer) error

v0.1.1

Jun 26, 2021

v0.1.0

Jun 18, 2021

Changes in this version

+ var ErrClientNotFound = fmt.Errorf("the client with the provided identifier was not found")

+ var ErrInvalidSubjectSetString = fmt.Errorf("the provided SubjectSet string is malformed")

+ var ErrNamespaceDoesntExist error = errors.New("the provided namespace doesn't exist, please add it first")

+ var ErrNoLocalNamespacesDefined error = errors.New("no local namespace configs have been defined at this time")

+ func ChecksumFromContext(ctx context.Context) (uint32, bool)

+ func NamespaceConfigTimestampFromContext(ctx context.Context) (time.Time, bool)

+ func NewContextWithChecksum(ctx context.Context, hashringChecksum uint32) context.Context

+ func NewContextWithNamespaceConfigTimestamp(ctx context.Context, timestamp time.Time) context.Context

+ type AccessController struct

+ Hashring Hashring

+ Memberlist *memberlist.Memberlist

+ RPCRouter ClientRouter

+ func NewAccessController(opts ...AccessControllerOption) (*AccessController, error)

+ func (a *AccessController) Check(ctx context.Context, req *aclpb.CheckRequest) (*aclpb.CheckResponse, error)

+ func (a *AccessController) Close() error

+ func (a *AccessController) Expand(ctx context.Context, req *aclpb.ExpandRequest) (*aclpb.ExpandResponse, error)

+ func (a *AccessController) GetBroadcasts(overhead, limit int) [][]byte

+ func (a *AccessController) ListRelationTuples(ctx context.Context, req *aclpb.ListRelationTuplesRequest) (*aclpb.ListRelationTuplesResponse, error)

+ func (a *AccessController) LocalState(join bool) []byte

+ func (a *AccessController) MergeRemoteState(buf []byte, join bool)

+ func (a *AccessController) NodeMeta(limit int) []byte

+ func (a *AccessController) NotifyJoin(member *memberlist.Node)

+ func (a *AccessController) NotifyLeave(member *memberlist.Node)

+ func (a *AccessController) NotifyMsg(msg []byte)

+ func (a *AccessController) NotifyUpdate(member *memberlist.Node)

+ func (a *AccessController) ReadConfig(ctx context.Context, req *aclpb.ReadConfigRequest) (*aclpb.ReadConfigResponse, error)

+ func (a *AccessController) WriteConfig(ctx context.Context, req *aclpb.WriteConfigRequest) (*aclpb.WriteConfigResponse, error)

+ func (a *AccessController) WriteRelationTuplesTxn(ctx context.Context, req *aclpb.WriteRelationTuplesTxnRequest) (*aclpb.WriteRelationTuplesTxnResponse, error)

+ type AccessControllerOption func(*AccessController)

+ func WithNamespaceManager(m NamespaceManager) AccessControllerOption

+ func WithNodeConfigs(cfg NodeConfigs) AccessControllerOption

+ func WithStore(store RelationTupleStore) AccessControllerOption

+ type ChangelogIterator interface

+ Close func(ctx context.Context) error

+ Next func() bool

+ Value func() (*NamespaceChangelogEntry, error)

+ type ClientRouter interface

+ AddClient func(nodeID string, client interface{})

+ GetClient func(nodeID string) (interface{}, error)

+ RemoveClient func(nodeID string)

+ func NewMapClientRouter() ClientRouter

+ type ConsistentHashring struct

+ func (ch *ConsistentHashring) Add(member HashringMember)

+ func (ch *ConsistentHashring) Checksum() uint32

+ func (ch *ConsistentHashring) LocateKey(key []byte) HashringMember

+ func (ch *ConsistentHashring) Remove(member HashringMember)

+ type Hashring interface

+ Add func(member HashringMember)

+ Checksum func() uint32

+ LocateKey func(key []byte) HashringMember

+ Remove func(member HashringMember)

+ func NewConsistentHashring(cfg *consistent.Config) Hashring

+ type HashringMember interface

+ String func() string

+ type InternalRelationTuple struct

+ Namespace string

+ Object string

+ Relation string

+ Subject Subject

+ func (r *InternalRelationTuple) ToProto() *pb.RelationTuple

+ func (r InternalRelationTuple) String() string

+ type NamespaceChangelogEntry struct

+ Config *aclpb.NamespaceConfig

+ Namespace string

+ Operation NamespaceOperation

+ Timestamp time.Time

+ type NamespaceConfigError struct

+ Message string

+ Type NamespaceConfigErrorType

+ func (e NamespaceConfigError) Error() string

+ func (e NamespaceConfigError) ToStatus() *status.Status

+ type NamespaceConfigErrorType int

+ const NamespaceAlreadyExists

+ const NamespaceDoesntExist

+ const NamespaceRelationUndefined

+ const NamespaceUpdateFailedPrecondition

+ type NamespaceConfigSnapshot struct

+ Config *aclpb.NamespaceConfig

+ Timestamp time.Time

+ type NamespaceManager interface

+ GetConfig func(ctx context.Context, namespace string) (*aclpb.NamespaceConfig, error)

+ GetRewrite func(ctx context.Context, namespace, relation string) (*aclpb.Rewrite, error)

+ LookupRelationReferencesByCount func(ctx context.Context, namespace string, relations ...string) (map[string]int, error)

+ TopChanges func(ctx context.Context, n uint) (ChangelogIterator, error)

+ UpsertConfig func(ctx context.Context, cfg *aclpb.NamespaceConfig) error

+ WrapTransaction func(ctx context.Context, fn func(ctx context.Context) error) error

+ type NamespaceOperation string

+ const AddNamespace

+ const UpdateNamespace

+ type NodeConfigs struct

+ Advertise string

+ Join string

+ NodePort int

+ ServerID string

+ ServerPort int

+ type NodeMetadata struct

+ NamespaceConfigSnapshots map[string]map[time.Time][]byte

+ NodeID string

+ ServerPort int

+ type NodeType string

+ const IntersectionNode

+ const LeafNode

+ const UnionNode

+ func (t NodeType) ToProto() aclpb.NodeType

+ type Object struct

+ ID string

+ Namespace string

+ type PeerNamespaceConfigStore interface

+ DeleteNamespaceConfigSnapshots func(peerID string) error

+ GetNamespaceConfigSnapshot func(peerID, namespace string, timestamp time.Time) (*aclpb.NamespaceConfig, error)

+ GetNamespaceConfigSnapshots func(peerID string) (map[string]map[time.Time]*aclpb.NamespaceConfig, error)

+ ListNamespaceConfigSnapshots func(namespace string) (map[string]map[time.Time]*aclpb.NamespaceConfig, error)

+ SetNamespaceConfigSnapshot func(peerID string, namespace string, config *aclpb.NamespaceConfig, ts time.Time) error

+ type RelationTupleQuery struct

+ Object Object

+ Relations []string

+ Subject Subject

+ type RelationTupleStore interface

+ ListRelationTuples func(ctx context.Context, query *aclpb.ListRelationTuplesRequest_Query, ...) ([]InternalRelationTuple, error)

+ RowCount func(ctx context.Context, query RelationTupleQuery) (int64, error)

+ SubjectSets func(ctx context.Context, object Object, relations ...string) ([]SubjectSet, error)

+ TransactRelationTuples func(ctx context.Context, insert []*InternalRelationTuple, ...) error

+ type Subject interface

+ Equals func(interface{}) bool

+ FromString func(string) (Subject, error)

+ String func() string

+ ToProto func() *pb.Subject

+ func SubjectFromProto(sub *pb.Subject) Subject

+ func SubjectFromString(s string) (Subject, error)

+ type SubjectID struct

+ ID string

+ func (s *SubjectID) Equals(v interface{}) bool

+ func (s *SubjectID) FromString(str string) (Subject, error)

+ func (s *SubjectID) String() string

+ func (s *SubjectID) ToProto() *pb.Subject

+ func (s SubjectID) MarshalJSON() ([]byte, error)

+ type SubjectSet struct

+ Namespace string

+ Object string

+ Relation string

+ func SubjectSetFromString(s string) (SubjectSet, error)

+ func (s *SubjectSet) Equals(v interface{}) bool

+ func (s *SubjectSet) FromString(str string) (Subject, error)

+ func (s *SubjectSet) String() string

+ func (s *SubjectSet) ToProto() *pb.Subject

+ func (s SubjectSet) MarshalJSON() ([]byte, error)

+ type SubjectTree struct

+ Children []*SubjectTree

+ Subject Subject

+ Type NodeType

+ func (t *SubjectTree) ToProto() *aclpb.SubjectTree