graph

package
v0.0.16-r00 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 23, 2022 License: Apache-2.0 Imports: 20 Imported by: 1

Documentation

Overview

Copyright © 2021-2022 Nikita Ivanovski info@slnt-opp.xyz

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021-2022 Nikita Ivanovski info@slnt-opp.xyz

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021-2022 Nikita Ivanovski info@slnt-opp.xyz

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021-2022 Nikita Ivanovski info@slnt-opp.xyz

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021-2022 Nikita Ivanovski info@slnt-opp.xyz

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021-2022 Nikita Ivanovski info@slnt-opp.xyz

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021-2022 Nikita Ivanovski info@slnt-opp.xyz

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021-2022 Nikita Ivanovski info@slnt-opp.xyz

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021-2022 Nikita Ivanovski info@slnt-opp.xyz

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021-2022 Nikita Ivanovski info@slnt-opp.xyz

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021-2022 Nikita Ivanovski info@slnt-opp.xyz

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021-2022 Nikita Ivanovski info@slnt-opp.xyz

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source 
const (
	INSTANCES_COL = "Instances"
)
View Source 
const (
	INSTANCES_GROUPS_COL = "InstancesGroups"
)

Variables

This section is empty.

Functions

func AccessLevel 

func AccessLevel(ctx context.Context, db driver.Database, account string, node string) (bool, int32)

account - Account Key, node - DocumentID

func DeleteByDocID 

func DeleteByDocID(ctx context.Context, db driver.Database, id driver.DocumentID) error

func DeleteEdge 

func DeleteEdge(ctx context.Context, db driver.Database, fromCollection, toCollection, fromKey, toKey string) error

func DeleteInBoundEdges 

func DeleteInBoundEdges(ctx context.Context, db driver.Database, id driver.DocumentID, graph string) error

func DeleteRecursive 

func DeleteRecursive(ctx context.Context, db driver.Database, id driver.DocumentID, graph string) error

func EdgeExist 

func EdgeExist(ctx context.Context, db driver.Database, fromCollection, toCollection, fromKey, toKey string) (bool, error)

func GetEnsureCollection 

func GetEnsureCollection(log *zap.Logger, ctx context.Context, db driver.Database, name string) driver.Collection

func GetWithAccess 

func GetWithAccess(ctx context.Context, db driver.Database, acc, id driver.DocumentID, node interface{}) error

func GraphGetEdgeEnsure 

func GraphGetEdgeEnsure(log *zap.Logger, ctx context.Context, graph driver.Graph, name, from, to string) driver.Collection

func GraphGetEnsure 

func GraphGetEnsure(log *zap.Logger, ctx context.Context, db driver.Database, name string) driver.Graph

func GraphGetVertexEnsure 

func GraphGetVertexEnsure(log *zap.Logger, ctx context.Context, db driver.Database, graph driver.Graph, name string) (col driver.Collection)

func HasAccess 

func HasAccess(ctx context.Context, db driver.Database, account string, node string, level int32) bool

account - Account Key, node - DocumentID

Types

type Access 

type Access struct {
	From  driver.DocumentID `json:"_from"`
	To    driver.DocumentID `json:"_to"`
	Level int32             `json:"level"`
	Role  string            `json:"role"`

	driver.DocumentMeta
}

type Account 

type Account struct {
	*pb.Account
	driver.DocumentMeta
}

func Authorisable 

func Authorisable(ctx context.Context, cred *credentials.Credentials, db driver.Database) (Account, bool)

Return Account authorisable by this Credentials

func (*Account) Delete 

func (acc *Account) Delete(ctx context.Context, db driver.Database) error

func (*Account) JoinNamespace 

func (acc *Account) JoinNamespace(ctx context.Context, edge driver.Collection, ns Namespace, level int32, role string) error

Grant namespace access to account

func (*Account) LinkNamespace 

func (acc *Account) LinkNamespace(ctx context.Context, edge driver.Collection, ns Namespace, level int32, role string) error

Grant account access to namespace

type AccountsController 

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

func NewAccountsController 

func NewAccountsController(logger *zap.Logger, db driver.Database) AccountsController

func (*AccountsController) Authorize 

func (ctrl *AccountsController) Authorize(ctx context.Context, auth_type string, args ...string) (Account, bool)

func (*AccountsController) Create 

func (ctrl *AccountsController) Create(ctx context.Context, title string) (Account, error)

func (*AccountsController) Delete 

func (ctrl *AccountsController) Delete(ctx context.Context, id string) error

func (*AccountsController) EnsureRootExists 

func (ctrl *AccountsController) EnsureRootExists(passwd string) (err error)

func (*AccountsController) Exists 

func (ctrl *AccountsController) Exists(ctx context.Context, id string) (bool, error)

func (*AccountsController) Get 

func (ctrl *AccountsController) Get(ctx context.Context, id string) (Account, error)

func (*AccountsController) GetCredentials 

func (ctrl *AccountsController) GetCredentials(ctx context.Context, edge_col driver.Collection, acc Account, auth_type string) (key string, has_credentials bool)

func (*AccountsController) List 

func (ctrl *AccountsController) List(ctx context.Context, requestor Account, req_depth *int32) ([]Account, error)

func (*AccountsController) SetCredentials 

func (ctrl *AccountsController) SetCredentials(ctx context.Context, acc Account, edge driver.Collection, c credentials.Credentials, role string) error

Set Account Credentials, ensure account has only one credentials document linked per credentials type

func (*AccountsController) Update 

func (ctrl *AccountsController) Update(ctx context.Context, acc Account, patch map[string]interface{}) (err error)

func (*AccountsController) UpdateCredentials 

func (ctrl *AccountsController) UpdateCredentials(ctx context.Context, cred string, c credentials.Credentials) (err error)

type BillingPlan 

type BillingPlan struct {
	*pb.Plan
	driver.DocumentMeta
}

type BillingPlansController 

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

func NewBillingPlansController 

func NewBillingPlansController(logger *zap.Logger, db driver.Database) BillingPlansController

func (*BillingPlansController) Create 

func (ctrl *BillingPlansController) Create(ctx context.Context, plan *pb.Plan) (*BillingPlan, error)

func (*BillingPlansController) Delete 

func (ctrl *BillingPlansController) Delete(ctx context.Context, plan *pb.Plan) (err error)

func (*BillingPlansController) Get 

func (ctrl *BillingPlansController) Get(ctx context.Context, plan *pb.Plan) (*BillingPlan, error)

func (*BillingPlansController) List 

func (ctrl *BillingPlansController) List(ctx context.Context, spUuid string) ([]*BillingPlan, error)

func (*BillingPlansController) Update 

func (ctrl *BillingPlansController) Update(ctx context.Context, plan *pb.Plan) (*BillingPlan, error)

type Deletable 

type Deletable interface {
	Delete(context.Context, driver.Database) error
}

type GroupWithSP 

type GroupWithSP struct {
	Group *pb.InstancesGroup     `json:"group"`
	SP    *sppb.ServicesProvider `json:"sp"`
}

type InstancesController 

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

func NewInstancesController 

func NewInstancesController(log *zap.Logger, db driver.Database) *InstancesController

func (*InstancesController) Create 

func (ctrl *InstancesController) Create(ctx context.Context, group driver.DocumentID, sp string, i *pb.Instance) error

func (*InstancesController) Delete 

func (ctrl *InstancesController) Delete(ctx context.Context, group string, i *pb.Instance) error

func (*InstancesController) GetGroup 

func (ctrl *InstancesController) GetGroup(ctx context.Context, i string) (*GroupWithSP, error)

func (*InstancesController) SetStatus 

func (ctrl *InstancesController) SetStatus(ctx context.Context, inst *pb.Instance, status pb.InstanceStatus) (err error)

func (*InstancesController) Update 

func (ctrl *InstancesController) Update(ctx context.Context, sp string, inst, oldInst *pb.Instance) error

func (*InstancesController) ValidateBillingPlan 

func (ctrl *InstancesController) ValidateBillingPlan(ctx context.Context, spUuid string, i *pb.Instance) error

type InstancesGroupsController 

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

func NewInstancesGroupsController 

func NewInstancesGroupsController(log *zap.Logger, db driver.Database) *InstancesGroupsController

func (*InstancesGroupsController) Create 

func (ctrl *InstancesGroupsController) Create(ctx context.Context, service driver.DocumentID, g *pb.InstancesGroup) error

func (*InstancesGroupsController) Delete 

func (ctrl *InstancesGroupsController) Delete(ctx context.Context, service string, g *pb.InstancesGroup) error

func (*InstancesGroupsController) Instances 

func (ctrl *InstancesGroupsController) Instances() *InstancesController

func (*InstancesGroupsController) Provide 

func (ctrl *InstancesGroupsController) Provide(ctx context.Context, group, sp string) error

func (*InstancesGroupsController) SetStatus 

func (ctrl *InstancesGroupsController) SetStatus(ctx context.Context, ig *pb.InstancesGroup, status pb.InstanceStatus) (err error)

func (*InstancesGroupsController) Update 

func (ctrl *InstancesGroupsController) Update(ctx context.Context, ig, oldIg *pb.InstancesGroup) error

type Namespace 

type Namespace struct {
	Title string `json:"title"`
	driver.DocumentMeta
}

func (*Namespace) Delete 

func (ns *Namespace) Delete(ctx context.Context, db driver.Database) error

type NamespacesController 

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

func NewNamespacesController 

func NewNamespacesController(logger *zap.Logger, db driver.Database) NamespacesController

func (*NamespacesController) Create 

func (ctrl *NamespacesController) Create(ctx context.Context, title string) (Namespace, error)

func (*NamespacesController) Delete 

func (ctrl *NamespacesController) Delete(ctx context.Context, id string) error

func (*NamespacesController) Get 

func (ctrl *NamespacesController) Get(ctx context.Context, id string) (Namespace, error)

func (*NamespacesController) Join 

func (ctrl *NamespacesController) Join(ctx context.Context, acc Account, ns Namespace, access int32, role string) error
func (ctrl *NamespacesController) Link(ctx context.Context, acc Account, ns Namespace, access int32, role string) error

func (*NamespacesController) List 

func (ctrl *NamespacesController) List(ctx context.Context, requestor Account, req_depth *int32) ([]Namespace, error)

type Node 

type Node struct {
	Collection string `json:"collection"`
	Key        string `json:"key"`
}

type Provision 

type Provision struct {
	From  driver.DocumentID `json:"_from"`
	To    driver.DocumentID `json:"_to"`
	Group string            `json:"group"`

	driver.DocumentMeta
}

type Record 

type Record struct {
	*pb.Record
	driver.DocumentMeta
}

type RecordsController 

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

func NewRecordsController 

func NewRecordsController(logger *zap.Logger, db driver.Database) RecordsController

func (*RecordsController) CheckOverlapping 

func (ctrl *RecordsController) CheckOverlapping(ctx context.Context, r *pb.Record) (ok bool)

func (*RecordsController) Create 

func (ctrl *RecordsController) Create(ctx context.Context, r *pb.Record)

func (*RecordsController) Get 

func (ctrl *RecordsController) Get(ctx context.Context, tr string) (res []*pb.Record, err error)

type ServicesController 

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

func NewServicesController 

func NewServicesController(log *zap.Logger, db driver.Database) ServicesController

func (*ServicesController) Create 

func (ctrl *ServicesController) Create(ctx context.Context, service *pb.Service) (*pb.Service, error)

Create Service and underlaying entities and store in DB

func (*ServicesController) Delete 

func (ctrl *ServicesController) Delete(ctx context.Context, s *pb.Service) (err error)

func (*ServicesController) Get 

func (ctrl *ServicesController) Get(ctx context.Context, acc, key string) (*pb.Service, error)

func (*ServicesController) GetServiceInstancesUuids 

func (ctrl *ServicesController) GetServiceInstancesUuids(key string) ([]string, error)

func (*ServicesController) IGController 

func (ctrl *ServicesController) IGController() *InstancesGroupsController

func (*ServicesController) Join 

func (ctrl *ServicesController) Join(ctx context.Context, service *pb.Service, namespace *Namespace, access int32, role string) error

Join Service into Namespace

func (*ServicesController) List 

func (ctrl *ServicesController) List(ctx context.Context, requestor string, request *pb.ListRequest) ([]*pb.Service, error)

List Services in DB

func (*ServicesController) SetStatus 

func (ctrl *ServicesController) SetStatus(ctx context.Context, s *pb.Service, status pb.ServiceStatus) (err error)

func (*ServicesController) Update 

func (ctrl *ServicesController) Update(ctx context.Context, service *pb.Service, hash bool) error

Update Service and underlaying entities and store in DB

type ServicesProvider 

type ServicesProvider struct {
	*pb.ServicesProvider
	driver.DocumentMeta
}

type ServicesProvidersController 

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

func NewServicesProvidersController 

func NewServicesProvidersController(logger *zap.Logger, db driver.Database) ServicesProvidersController

func (*ServicesProvidersController) BindPlan 

func (ctrl *ServicesProvidersController) BindPlan(ctx context.Context, uuid, planUuid string) error

func (*ServicesProvidersController) Create 

func (ctrl *ServicesProvidersController) Create(ctx context.Context, sp *ServicesProvider) (err error)

func (*ServicesProvidersController) Delete 

func (ctrl *ServicesProvidersController) Delete(ctx context.Context, id string) (err error)

func (*ServicesProvidersController) Get 

func (ctrl *ServicesProvidersController) Get(ctx context.Context, id string) (r *ServicesProvider, err error)

func (*ServicesProvidersController) List 

func (ctrl *ServicesProvidersController) List(ctx context.Context, requestor string) ([]*ServicesProvider, error)

List Services Providers in DB

func (*ServicesProvidersController) ListDeployments 

func (ctrl *ServicesProvidersController) ListDeployments(ctx context.Context, sp *ServicesProvider, includeInstances bool) ([]*ipb.InstancesGroup, error)

func (*ServicesProvidersController) Update 

func (ctrl *ServicesProvidersController) Update(ctx context.Context, sp *pb.ServicesProvider) error

Update ServicesProvider in DB

type Transaction 

type Transaction struct {
	*pb.Transaction
	driver.DocumentMeta
}

type TransactionsController 

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

func NewTransactionsController 

func NewTransactionsController(logger *zap.Logger, db driver.Database) TransactionsController

func (*TransactionsController) Create 

func (ctrl *TransactionsController) Create(ctx context.Context, tx *pb.Transaction) (*Transaction, error)

func (*TransactionsController) Get 

func (ctrl *TransactionsController) Get(ctx context.Context, uuid string) (*pb.Transaction, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.