client

package
v0.0.0-...-0485310 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewBaseServiceDelegate 

func NewBaseServiceDelegate(opts ...ModelBaseServiceDelegateOption) (svc2 interfaces.GrpcClientModelBaseService, err error)

func NewBasicBinder 

func NewBasicBinder(id interfaces.ModelId, res *grpc.Response) (b interfaces.GrpcModelBinder)

func NewEnvironmentServiceDelegate 

func NewEnvironmentServiceDelegate() (svc2 interfaces.GrpcClientModelEnvironmentService, err error)

func NewListBinder 

func NewListBinder(id interfaces.ModelId, res *grpc.Response) (b interfaces.GrpcModelListBinder)

func NewModelDelegate 

func NewModelDelegate(doc interfaces.Model, opts ...ModelDelegateOption) interfaces.GrpcClientModelDelegate

func NewModelNodeDelegate 

func NewModelNodeDelegate(n interfaces.Node) interfaces.ModelNodeDelegate

func NewNodeServiceDelegate 

func NewNodeServiceDelegate() (svc2 interfaces.GrpcClientModelNodeService, err error)

func NewServiceDelegate 

func NewServiceDelegate() (svc2 interfaces.GrpcClientModelService, err error)

func NewSpiderServiceDelegate 

func NewSpiderServiceDelegate() (svc2 interfaces.GrpcClientModelSpiderService, err error)

func NewTaskServiceDelegate 

func NewTaskServiceDelegate() (svc2 interfaces.GrpcClientModelTaskService, err error)

func NewTaskStatServiceDelegate 

func NewTaskStatServiceDelegate() (svc2 interfaces.GrpcClientModelTaskStatService, err error)

func ProvideBaseServiceDelegate 

func ProvideBaseServiceDelegate(id interfaces.ModelId) func() (svc interfaces.GrpcClientModelBaseService, err error)

Types

type BaseServiceDelegate 

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

func (*BaseServiceDelegate) Count 

func (d *BaseServiceDelegate) Count(query bson.M) (total int, err error)

func (*BaseServiceDelegate) Delete 

func (d *BaseServiceDelegate) Delete(query bson.M, args ...interface{}) (err error)

func (*BaseServiceDelegate) DeleteById 

func (d *BaseServiceDelegate) DeleteById(id primitive.ObjectID, args ...interface{}) (err error)

func (*BaseServiceDelegate) DeleteList 

func (d *BaseServiceDelegate) DeleteList(query bson.M, args ...interface{}) (err error)

func (*BaseServiceDelegate) ForceDeleteList 

func (d *BaseServiceDelegate) ForceDeleteList(query bson.M, args ...interface{}) (err error)

func (*BaseServiceDelegate) Get 

func (d *BaseServiceDelegate) Get(query bson.M, opts *mongo.FindOptions) (doc interfaces.Model, err error)

func (*BaseServiceDelegate) GetById 

func (d *BaseServiceDelegate) GetById(id primitive.ObjectID) (doc interfaces.Model, err error)

func (*BaseServiceDelegate) GetConfigPath 

func (d *BaseServiceDelegate) GetConfigPath() (path string)

func (*BaseServiceDelegate) GetList 

func (d *BaseServiceDelegate) GetList(query bson.M, opts *mongo.FindOptions) (l interfaces.List, err error)

func (*BaseServiceDelegate) GetModelId 

func (d *BaseServiceDelegate) GetModelId() (id interfaces.ModelId)

func (*BaseServiceDelegate) Insert 

func (d *BaseServiceDelegate) Insert(u interfaces.User, docs ...interface{}) (err error)

func (*BaseServiceDelegate) SetConfigPath 

func (d *BaseServiceDelegate) SetConfigPath(path string)

func (*BaseServiceDelegate) SetModelId 

func (d *BaseServiceDelegate) SetModelId(id interfaces.ModelId)

func (*BaseServiceDelegate) Update 

func (d *BaseServiceDelegate) Update(query bson.M, update bson.M, fields []string, args ...interface{}) (err error)

func (*BaseServiceDelegate) UpdateById 

func (d *BaseServiceDelegate) UpdateById(id primitive.ObjectID, update bson.M, args ...interface{}) (err error)

func (*BaseServiceDelegate) UpdateDoc 

func (d *BaseServiceDelegate) UpdateDoc(query bson.M, doc interfaces.Model, fields []string, args ...interface{}) (err error)

type BasicBinder 

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

func (*BasicBinder) Bind 

func (b *BasicBinder) Bind() (res interfaces.Model, err error)

func (*BasicBinder) Process 

func (b *BasicBinder) Process(d interfaces.Model) (res interfaces.Model, err error)

type EnvironmentServiceDelegate 

type EnvironmentServiceDelegate struct {
	interfaces.GrpcClientModelBaseService
}

func (*EnvironmentServiceDelegate) GetEnvironment 

func (svc *EnvironmentServiceDelegate) GetEnvironment(query bson.M, opts *mongo.FindOptions) (e interfaces.Environment, err error)

func (*EnvironmentServiceDelegate) GetEnvironmentById 

func (svc *EnvironmentServiceDelegate) GetEnvironmentById(id primitive.ObjectID) (e interfaces.Environment, err error)

func (*EnvironmentServiceDelegate) GetEnvironmentList 

func (svc *EnvironmentServiceDelegate) GetEnvironmentList(query bson.M, opts *mongo.FindOptions) (res []interfaces.Environment, err error)

type ListBinder 

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

func (*ListBinder) Bind 

func (b *ListBinder) Bind() (l interfaces.List, err error)

func (*ListBinder) MustBind 

func (b *ListBinder) MustBind() (res interface{})

func (*ListBinder) Process 

func (b *ListBinder) Process(d interface{}) (l interfaces.List, err error)

type ModelBaseServiceDelegateOption 

type ModelBaseServiceDelegateOption func(delegate interfaces.GrpcClientModelBaseService)

func WithBaseServiceConfigPath 

func WithBaseServiceConfigPath(path string) ModelBaseServiceDelegateOption

func WithBaseServiceModelId 

func WithBaseServiceModelId(id interfaces.ModelId) ModelBaseServiceDelegateOption

type ModelDelegate 

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

func (*ModelDelegate) Add 

func (d *ModelDelegate) Add() (err error)

func (*ModelDelegate) Close 

func (d *ModelDelegate) Close() (err error)

func (*ModelDelegate) Delete 

func (d *ModelDelegate) Delete() (err error)

func (*ModelDelegate) GetArtifact 

func (d *ModelDelegate) GetArtifact() (res interfaces.ModelArtifact, err error)

func (*ModelDelegate) GetConfigPath 

func (d *ModelDelegate) GetConfigPath() (path string)

func (*ModelDelegate) GetModel 

func (d *ModelDelegate) GetModel() (res interfaces.Model)

func (*ModelDelegate) Refresh 

func (d *ModelDelegate) Refresh() (err error)

func (*ModelDelegate) Save 

func (d *ModelDelegate) Save() (err error)

func (*ModelDelegate) SetConfigPath 

func (d *ModelDelegate) SetConfigPath(path string)

func (*ModelDelegate) ToBytes 

func (d *ModelDelegate) ToBytes(m interface{}) (bytes []byte, err error)

type ModelDelegateOption 

type ModelDelegateOption func(delegate interfaces.GrpcClientModelDelegate)

func WithDelegateConfigPath 

func WithDelegateConfigPath(path string) ModelDelegateOption

type ModelNodeDelegate 

type ModelNodeDelegate struct {
	interfaces.GrpcClientModelDelegate
	// contains filtered or unexported fields
}

func (*ModelNodeDelegate) UpdateStatus 

func (d *ModelNodeDelegate) UpdateStatus(active bool, activeTs *time.Time, status string) (err error)

func (*ModelNodeDelegate) UpdateStatusOffline 

func (d *ModelNodeDelegate) UpdateStatusOffline() (err error)

func (*ModelNodeDelegate) UpdateStatusOnline 

func (d *ModelNodeDelegate) UpdateStatusOnline() (err error)

type ModelServiceDelegateOption 

type ModelServiceDelegateOption func(delegate interfaces.GrpcClientModelService)

func WithServiceConfigPath 

func WithServiceConfigPath(path string) ModelServiceDelegateOption

type ModelServiceV2 

type ModelServiceV2[T any] struct {
	// contains filtered or unexported fields
}

func NewModelServiceV2 

func NewModelServiceV2[T any]() *ModelServiceV2[T]

func (*ModelServiceV2[T]) Count 

func (svc *ModelServiceV2[T]) Count(query bson.M) (total int, err error)

func (*ModelServiceV2[T]) DeleteById 

func (svc *ModelServiceV2[T]) DeleteById(id primitive.ObjectID) (err error)

func (*ModelServiceV2[T]) DeleteMany 

func (svc *ModelServiceV2[T]) DeleteMany(query bson.M) (err error)

func (*ModelServiceV2[T]) DeleteOne 

func (svc *ModelServiceV2[T]) DeleteOne(query bson.M) (err error)

func (*ModelServiceV2[T]) GetById 

func (svc *ModelServiceV2[T]) GetById(id primitive.ObjectID) (model *T, err error)

func (*ModelServiceV2[T]) GetCol 

func (svc *ModelServiceV2[T]) GetCol() (col *mongo.Col)

func (*ModelServiceV2[T]) GetMany 

func (svc *ModelServiceV2[T]) GetMany(query bson.M, options *mongo.FindOptions) (models []T, err error)

func (*ModelServiceV2[T]) GetOne 

func (svc *ModelServiceV2[T]) GetOne(query bson.M, options *mongo.FindOptions) (model *T, err error)

func (*ModelServiceV2[T]) InsertMany 

func (svc *ModelServiceV2[T]) InsertMany(models []T) (ids []primitive.ObjectID, err error)

func (*ModelServiceV2[T]) InsertOne 

func (svc *ModelServiceV2[T]) InsertOne(model T) (id primitive.ObjectID, err error)

func (*ModelServiceV2[T]) ReplaceById 

func (svc *ModelServiceV2[T]) ReplaceById(id primitive.ObjectID, model T) (err error)

func (*ModelServiceV2[T]) ReplaceOne 

func (svc *ModelServiceV2[T]) ReplaceOne(query bson.M, model T) (err error)

func (*ModelServiceV2[T]) UpdateById 

func (svc *ModelServiceV2[T]) UpdateById(id primitive.ObjectID, update bson.M) (err error)

func (*ModelServiceV2[T]) UpdateMany 

func (svc *ModelServiceV2[T]) UpdateMany(query bson.M, update bson.M) (err error)

func (*ModelServiceV2[T]) UpdateOne 

func (svc *ModelServiceV2[T]) UpdateOne(query bson.M, update bson.M) (err error)

type NodeServiceDelegate 

type NodeServiceDelegate struct {
	interfaces.GrpcClientModelBaseService
}

func (*NodeServiceDelegate) GetNode 

func (svc *NodeServiceDelegate) GetNode(query bson.M, opts *mongo.FindOptions) (n interfaces.Node, err error)

func (*NodeServiceDelegate) GetNodeById 

func (svc *NodeServiceDelegate) GetNodeById(id primitive.ObjectID) (n interfaces.Node, err error)

func (*NodeServiceDelegate) GetNodeByKey 

func (svc *NodeServiceDelegate) GetNodeByKey(key string) (n interfaces.Node, err error)

func (*NodeServiceDelegate) GetNodeList 

func (svc *NodeServiceDelegate) GetNodeList(query bson.M, opts *mongo.FindOptions) (res []interfaces.Node, err error)

type ServiceDelegate 

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

func (*ServiceDelegate) GetConfigPath 

func (d *ServiceDelegate) GetConfigPath() string

func (*ServiceDelegate) NewBaseServiceDelegate 

func (d *ServiceDelegate) NewBaseServiceDelegate(id interfaces.ModelId) (svc interfaces.GrpcClientModelBaseService, err error)

func (*ServiceDelegate) SetConfigPath 

func (d *ServiceDelegate) SetConfigPath(path string)

type SpiderServiceDelegate 

type SpiderServiceDelegate struct {
	interfaces.GrpcClientModelBaseService
}

func (*SpiderServiceDelegate) GetSpider 

func (svc *SpiderServiceDelegate) GetSpider(query bson.M, opts *mongo.FindOptions) (s interfaces.Spider, err error)

func (*SpiderServiceDelegate) GetSpiderById 

func (svc *SpiderServiceDelegate) GetSpiderById(id primitive.ObjectID) (s interfaces.Spider, err error)

func (*SpiderServiceDelegate) GetSpiderList 

func (svc *SpiderServiceDelegate) GetSpiderList(query bson.M, opts *mongo.FindOptions) (res []interfaces.Spider, err error)

type TaskServiceDelegate 

type TaskServiceDelegate struct {
	interfaces.GrpcClientModelBaseService
}

func (*TaskServiceDelegate) GetTask 

func (svc *TaskServiceDelegate) GetTask(query bson.M, opts *mongo.FindOptions) (t interfaces.Task, err error)

func (*TaskServiceDelegate) GetTaskById 

func (svc *TaskServiceDelegate) GetTaskById(id primitive.ObjectID) (t interfaces.Task, err error)

func (*TaskServiceDelegate) GetTaskList 

func (svc *TaskServiceDelegate) GetTaskList(query bson.M, opts *mongo.FindOptions) (res []interfaces.Task, err error)

type TaskStatServiceDelegate 

type TaskStatServiceDelegate struct {
	interfaces.GrpcClientModelBaseService
}

func (*TaskStatServiceDelegate) GetTaskStat 

func (svc *TaskStatServiceDelegate) GetTaskStat(query bson.M, opts *mongo.FindOptions) (t interfaces.TaskStat, err error)

func (*TaskStatServiceDelegate) GetTaskStatById 

func (svc *TaskStatServiceDelegate) GetTaskStatById(id primitive.ObjectID) (t interfaces.TaskStat, err error)

func (*TaskStatServiceDelegate) GetTaskStatList 

func (svc *TaskStatServiceDelegate) GetTaskStatList(query bson.M, opts *mongo.FindOptions) (res []interfaces.TaskStat, err 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.