rdb

Documentation

Index

• type DBResult
• type FilterFunc
• type PolicySchema
  • func (s *PolicySchema) GetID() string
  • func (s *PolicySchema) GetPolicy() (Policy, error)
  • func (s *PolicySchema) PopulateWithPolicy(p Policy) error
• type PolicySchemaManager
  • func (_ *PolicySchemaManager) GetFilterFunc(sbj, res, act string) FilterFunc
  • func (sm *PolicySchemaManager) GetRequestCandidatesTerm(table r.Term, sbj, res, act string) r.Term
  • func (_ *PolicySchemaManager) NewSchema() Schema
  • func (_ *PolicySchemaManager) ProcessResult(r DBResult) chan *ProcessResult
• type ProcessResult
• type RdbManager
  • func NewRdbManager(session *r.Session, table string, s SchemaManager) *RdbManager
  • func (m *RdbManager) Create(policy Policy) error
  • func (m *RdbManager) Delete(id string) error
  • func (m *RdbManager) FindRequestCandidates(req *Request) (Policies, error)
  • func (m *RdbManager) Get(id string) (Policy, error)
  • func (m *RdbManager) GetAll(limit, offset int64) (Policies, error)
  • func (m *RdbManager) Update(policy Policy) error
• type Schema
• type SchemaManager

Types

type DBResult

type DBResult interface {
	Next(dest interface{}) bool
	Err() error
}

type FilterFunc

type FilterFunc func(t r.Term) r.Term

type PolicySchema

type PolicySchema struct {
	ID          string          `json:"id" gorethink:"id"`
	Description string          `json:"description" gorethink:"description"`
	Subjects    subjects        `json:"subjects" gorethink:"subjects"`
	Effect      string          `json:"effect" gorethink:"effect"`
	Resources   resources       `json:"resources" gorethink:"resources"`
	Actions     actions         `json:"actions" gorethink:"actions"`
	Conditions  json.RawMessage `json:"conditions" gorethink:"conditions"`
}

func (*PolicySchema) GetID

func (s *PolicySchema) GetID() string

func (*PolicySchema) GetPolicy

func (s *PolicySchema) GetPolicy() (Policy, error)

func (*PolicySchema) PopulateWithPolicy

func (s *PolicySchema) PopulateWithPolicy(p Policy) error

type PolicySchemaManager

type PolicySchemaManager struct{}

func (*PolicySchemaManager) GetFilterFunc

func (_ *PolicySchemaManager) GetFilterFunc(sbj, res, act string) FilterFunc

func (*PolicySchemaManager) GetRequestCandidatesTerm

func (sm *PolicySchemaManager) GetRequestCandidatesTerm(table r.Term, sbj, res, act string) r.Term

GetRequestCandidates term returns term to provide getRequestCandidates ability

func (*PolicySchemaManager) NewSchema

func (_ *PolicySchemaManager) NewSchema() Schema

func (*PolicySchemaManager) ProcessResult

func (_ *PolicySchemaManager) ProcessResult(r DBResult) chan *ProcessResult

type ProcessResult

type ProcessResult struct {
	Schema Schema
	Err    error
}

type RdbManager

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

RdbManager is a rethinkdb implementation of Manager to store policies persistently.

func NewRdbManager

func NewRdbManager(session *r.Session, table string, s SchemaManager) *RdbManager

NewRdbManager initializes a new RdbManager for given session.

func (*RdbManager) Create

func (m *RdbManager) Create(policy Policy) error

Create inserts a new policy.

func (*RdbManager) Delete

func (m *RdbManager) Delete(id string) error

Delete removes a policy.

func (*RdbManager) FindRequestCandidates

func (m *RdbManager) FindRequestCandidates(req *Request) (Policies, error)

FindRequestCandidates returns candidates that could match the request object. It either returns a set that exactly matches the request, or a superset of it. If an error occurs, it returns nil and the error.

func (*RdbManager) Get

func (m *RdbManager) Get(id string) (Policy, error)

Get retrieves a policy.

func (*RdbManager) GetAll

func (m *RdbManager) GetAll(limit, offset int64) (Policies, error)

GetAll returns all policies.

func (*RdbManager) Update

func (m *RdbManager) Update(policy Policy) error

Update updates an existing policy.

type Schema

type Schema interface {
	GetID() string
	GetPolicy() (Policy, error)
	PopulateWithPolicy(Policy) error
}

type SchemaManager

type SchemaManager interface {
	NewSchema() Schema
	GetFilterFunc(subject, resource, action string) FilterFunc
	GetRequestCandidatesTerm(table r.Term, subject, resource, action string) r.Term
	ProcessResult(r DBResult) chan *ProcessResult
}