core

Documentation

Index

• Variables
• func FormatResponse(err error) *command.Response
• func NewGrpcService(core Core) *grpc.Server
• func NewHttpService(core Core) *httpService
• type AddPoliciesRequest
• type ClearPolicyRequest
• type Core
  • func New(store *store.Store) Core
• type CreateNameSpaceRequest
• type EnforceReply
• type EnforceRequest
• type JoinRequest
• type ListPoliciesRequest
• type Middleware
• type PrintModelRequest
• type RemoveFilteredPolicyRequest
• type RemovePoliciesRequest
• type RemoveRequest
• type Response
• type SetModelFromStringRequest
• type UpdatePoliciesRequest

Variables

var (
	NamespaceExisted = errors.New("namespace already existed")

	// NamespaceNotExist namespace not exist
	NamespaceNotExist = errors.New("namespace not exist")
	// UnmarshalFailed unmarshal failed
	UnmarshalFailed = errors.New("unmarshal failed")
)

Functions

func FormatResponse

func FormatResponse(err error) *command.Response

func NewGrpcService

func NewGrpcService(core Core) *grpc.Server

func NewHttpService

func NewHttpService(core Core) *httpService

Types

type AddPoliciesRequest

type AddPoliciesRequest struct {
	NS    string     `json:"ns" validate:"required"`
	Sec   string     `json:"sec" validate:"required"`
	PType string     `json:"ptype" validate:"required"`
	Rules [][]string `json:"rules" validate:"required"`
}

type ClearPolicyRequest

type ClearPolicyRequest struct {
	NS string `json:"ns" validate:"required"`
}

type Core

type Core interface {
	AuthType() auth.AuthType
	Check(username string, password string) bool
	ListNamespaces(ctx context.Context) ([]string, error)
	ListPolicies(ctx context.Context, namespace, cursor string, skip, limit int64, reverse bool) ([][]string, error)
	PrintModel(ctx context.Context, namespace string) (string, error)
	IsLeader(ctx context.Context) bool
	LeaderAddr() string
	Stats(ctx context.Context) (map[string]interface{}, error)
	CreateNamespace(ctx context.Context, ns string) error
	SetModelFromString(ctx context.Context, ns string, text string) error
	Enforce(ctx context.Context, ns string, level int32, freshness int64, params ...interface{}) (bool, error)
	AddPolicies(ctx context.Context, ns string, sec string, pType string, rules [][]string) ([][]string, error)
	RemovePolicies(ctx context.Context, ns string, sec string, pType string, rules [][]string) ([][]string, error)
	RemoveFilteredPolicy(ctx context.Context, ns string, sec string, pType string, fi int32, fv []string) ([][]string, error)
	UpdatePolicies(ctx context.Context, ns string, sec string, pType string, nr, or [][]string) (bool, error)
	ClearPolicy(ctx context.Context, ns string) error
	Join(ctx context.Context, id, addr string, voter bool, metadata map[string]string) error
	Remove(ctx context.Context, id string) error
}

func New

func New(store *store.Store) Core

type CreateNameSpaceRequest

type CreateNameSpaceRequest struct {
	NS string `json:"ns" validate:"required"`
}

type EnforceReply

type EnforceReply struct {
	Ok bool `json:"ok"`
}

type EnforceRequest

type EnforceRequest struct {
	NS        string        `json:"ns" validate:"required"`
	Level     int32         `json:"level"`
	Freshness int64         `json:"freshness"`
	Params    []interface{} `json:"params"`
}

type JoinRequest

type JoinRequest struct {
	ID       string            `json:"id" validate:"required"`
	Addr     string            `json:"addr" validate:"required"`
	Voter    bool              `json:"voter" validate:"required"`
	Metadata map[string]string `json:"metadata"`
}

type ListPoliciesRequest

type ListPoliciesRequest struct {
	NS      string `json:"ns" validate:"required"`
	Cursor  string `json:"cursor"`
	Skip    int64  `json:"skip"`
	Limit   int64  `json:"limit"`
	Reverse bool   `json:"reverse"`
}

type Middleware

type Middleware func(handlerFunc http.HandlerFunc) http.HandlerFunc

type PrintModelRequest

type PrintModelRequest struct {
	NS string `json:"ns" validate:"required"`
}

type RemoveFilteredPolicyRequest

type RemoveFilteredPolicyRequest struct {
	NS          string   `json:"ns" validate:"required"`
	Sec         string   `json:"sec" validate:"required"`
	PType       string   `json:"ptype" validate:"required"`
	FieldIndex  int32    `json:"fieldIndex" validate:"required"`
	FieldValues []string `json:"fieldValues" validate:"required"`
}

type RemovePoliciesRequest

type RemovePoliciesRequest struct {
	NS    string     `json:"ns" validate:"required"`
	Sec   string     `json:"sec" validate:"required"`
	PType string     `json:"ptype" validate:"required"`
	Rules [][]string `json:"rules" validate:"required"`
}

type RemoveRequest

type RemoveRequest struct {
	ID string `json:"id" validate:"required"`
}

type Response

type Response struct {
	Effected      bool       `json:"effected,omitempty"`
	EffectedRules [][]string `json:"effected_rules,omitempty"`
}

type SetModelFromStringRequest

type SetModelFromStringRequest struct {
	NS   string `json:"ns" validate:"required"`
	Text string `json:"text" validate:"required"`
}

type UpdatePoliciesRequest

type UpdatePoliciesRequest struct {
	NS       string     `json:"ns" validate:"required"`
	Sec      string     `json:"sec" validate:"required"`
	PType    string     `json:"ptype" validate:"required"`
	NewRules [][]string `json:"newRules" validate:"required"`
	OldRules [][]string `json:"oldRules" validate:"required"`
}