service

package
v0.1.0-alpha Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2021 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var NeedClusterID = errors.BadRequest.New("need set cluster id")

Functions

func Middleware 

func Middleware(s Service) fiber.Handler

New creates a new middleware handler

Types

type ClientContext 

type ClientContext struct {
	App *models.AppServer
	// contains filtered or unexported fields
}

func GetClientContext 

func GetClientContext(ctx *fiber.Ctx) (ClientContext, error)

func NewClientContext 

func NewClientContext(app *models.AppServer, ctx *fiber.Ctx) *ClientContext

func (ClientContext) AddAuth 

func (c ClientContext) AddAuth(cluster uuid.UUID, infobase ...uuid.UUID)

func (ClientContext) AuthenticateAgent 

func (c ClientContext) AuthenticateAgent(user, password string)

func (ClientContext) AuthenticateCluster 

func (c ClientContext) AuthenticateCluster(cluster uuid.UUID, user, password string)

func (ClientContext) AuthenticateInfobase 

func (c ClientContext) AuthenticateInfobase(infobase uuid.UUID, user, password string)

func (ClientContext) Close 

func (c ClientContext) Close() error

func (ClientContext) Context 

func (c ClientContext) Context() context.Context

func (ClientContext) CreateInfobase 

func (c ClientContext) CreateInfobase(cluster uuid.UUID, infobase serialize.InfobaseInfo, mode int) (serialize.InfobaseInfo, error)

func (ClientContext) DisconnectConnection 

func (c ClientContext) DisconnectConnection(cluster uuid.UUID, process uuid.UUID, connection uuid.UUID, infobase uuid.UUID) error

func (ClientContext) DropInfobase 

func (c ClientContext) DropInfobase(cluster uuid.UUID, infobase uuid.UUID, mode int) error

func (ClientContext) Force 

func (c ClientContext) Force() bool

func (ClientContext) GetAgentAdmins 

func (c ClientContext) GetAgentAdmins() (serialize.UsersList, error)

func (ClientContext) GetAgentVersion 

func (c ClientContext) GetAgentVersion() (string, error)

func (ClientContext) GetApiClient 

func (c ClientContext) GetApiClient() rclient.Api

func (ClientContext) GetClusterAdmins 

func (c ClientContext) GetClusterAdmins(cluster uuid.UUID) (serialize.UsersList, error)

func (ClientContext) GetClusterConnections 

func (c ClientContext) GetClusterConnections(cluster uuid.UUID) (serialize.ConnectionShortInfoList, error)

func (ClientContext) GetClusterID 

func (c ClientContext) GetClusterID() (uuid.UUID, bool)

func (ClientContext) GetClusterIDOrNil 

func (c ClientContext) GetClusterIDOrNil() uuid.UUID

func (ClientContext) GetClusterInfo 

func (c ClientContext) GetClusterInfo(cluster uuid.UUID) (serialize.ClusterInfo, error)

func (ClientContext) GetClusterInfobases 

func (c ClientContext) GetClusterInfobases(cluster uuid.UUID) (serialize.InfobaseSummaryList, error)

func (ClientContext) GetClusterLocks 

func (c ClientContext) GetClusterLocks(cluster uuid.UUID) (serialize.LocksList, error)

func (ClientContext) GetClusterManagers 

func (c ClientContext) GetClusterManagers(cluster uuid.UUID) ([]*serialize.ManagerInfo, error)

func (ClientContext) GetClusterServices 

func (c ClientContext) GetClusterServices(cluster uuid.UUID) ([]*serialize.ServiceInfo, error)

func (ClientContext) GetClusterSessions 

func (c ClientContext) GetClusterSessions(cluster uuid.UUID) (serialize.SessionInfoList, error)

func (ClientContext) GetClusters 

func (c ClientContext) GetClusters() ([]*serialize.ClusterInfo, error)

func (ClientContext) GetConnectionLocks 

func (c ClientContext) GetConnectionLocks(cluster uuid.UUID, connection uuid.UUID) (serialize.LocksList, error)

func (ClientContext) GetContextValue 

func (c ClientContext) GetContextValue(name string, unescape ...bool) (ContextValue, bool)

func (ClientContext) GetInfobaseConnections 

func (c ClientContext) GetInfobaseConnections(cluster uuid.UUID, infobase uuid.UUID) (serialize.ConnectionShortInfoList, error)

func (ClientContext) GetInfobaseID 

func (c ClientContext) GetInfobaseID() (ContextValue, bool)

func (ClientContext) GetInfobaseInfo 

func (c ClientContext) GetInfobaseInfo(cluster uuid.UUID, infobase uuid.UUID) (serialize.InfobaseInfo, error)

func (ClientContext) GetInfobaseLocks 

func (c ClientContext) GetInfobaseLocks(cluster uuid.UUID, infobase uuid.UUID) (serialize.LocksList, error)

func (ClientContext) GetInfobaseSessions 

func (c ClientContext) GetInfobaseSessions(cluster uuid.UUID, infobase uuid.UUID) (serialize.SessionInfoList, error)

func (ClientContext) GetSessionLocks 

func (c ClientContext) GetSessionLocks(cluster uuid.UUID, infobase uuid.UUID, session uuid.UUID) (serialize.LocksList, error)

func (ClientContext) GetWorkingProcessInfo 

func (c ClientContext) GetWorkingProcessInfo(cluster, process uuid.UUID) (*serialize.ProcessInfo, error)

func (ClientContext) GetWorkingProcesses 

func (c ClientContext) GetWorkingProcesses(cluster uuid.UUID) (serialize.ProcessInfoList, error)

func (ClientContext) GetWorkingServerInfo 

func (c ClientContext) GetWorkingServerInfo(cluster, serverID uuid.UUID) (*serialize.ServerInfo, error)

func (ClientContext) GetWorkingServers 

func (c ClientContext) GetWorkingServers(cluster uuid.UUID) ([]*serialize.ServerInfo, error)

func (ClientContext) HealthCheck 

func (c ClientContext) HealthCheck() (bool, error)

func (ClientContext) RegAgentAdmin 

func (c ClientContext) RegAgentAdmin(user serialize.UserInfo) error

func (ClientContext) RegClusterAdmin 

func (c ClientContext) RegClusterAdmin(cluster uuid.UUID, user serialize.UserInfo) error

func (ClientContext) RegWorkingServer 

func (c ClientContext) RegWorkingServer(cluster uuid.UUID, info *serialize.ServerInfo) (*serialize.ServerInfo, error)

func (ClientContext) TerminateSession 

func (c ClientContext) TerminateSession(cluster uuid.UUID, session uuid.UUID, msg string) error

func (ClientContext) UnRegWorkingServer 

func (c ClientContext) UnRegWorkingServer(cluster, serverID uuid.UUID) error

func (ClientContext) UnregAgentAdmin 

func (c ClientContext) UnregAgentAdmin(user string) error

func (ClientContext) UnregClusterAdmin 

func (c ClientContext) UnregClusterAdmin(cluster uuid.UUID, user string) error

func (ClientContext) UpdateInfobase 

func (c ClientContext) UpdateInfobase(cluster uuid.UUID, infobase serialize.InfobaseInfo) error

func (ClientContext) UpdateSummaryInfobase 

func (c ClientContext) UpdateSummaryInfobase(cluster uuid.UUID, infobase serialize.InfobaseSummaryInfo) error

func (ClientContext) Version 

func (c ClientContext) Version() string

type ContextValue 

type ContextValue string

func GetClusterID 

func GetClusterID(ctx *fiber.Ctx) (ContextValue, bool)

func GetContextValue 

func GetContextValue(ctx *fiber.Ctx, name string, unescape ...bool) (ContextValue, bool)

func GetContextValueOrNil 

func GetContextValueOrNil(ctx *fiber.Ctx, name string, unescape ...bool) ContextValue

func GetInfobaseID 

func GetInfobaseID(ctx *fiber.Ctx) (ContextValue, bool)

func (ContextValue) Bool 

func (val ContextValue) Bool(defaultVal ...bool) bool

func (ContextValue) Empty 

func (val ContextValue) Empty() bool

func (ContextValue) NilUUID 

func (val ContextValue) NilUUID() bool

func (ContextValue) NotEmpty 

func (val ContextValue) NotEmpty() bool

func (ContextValue) NotNilUUID 

func (val ContextValue) NotNilUUID() bool

func (ContextValue) String 

func (val ContextValue) String() string

func (ContextValue) UUID 

func (val ContextValue) UUID() (uuid.UUID, error)

type Service 

type Service interface {
	Repository() db.Repository

	CreateInfobase(ctt ClientContext, info *serialize.InfobaseInfo, createDB bool) (*serialize.InfobaseInfo, error)
	DropInfobase(ctt ClientContext, deleteDB bool) error

	GetInfobases(ctt ClientContext) (serialize.InfobaseSummaryList, error)

	GetClusters(ctt ClientContext) ([]*serialize.ClusterInfo, error)
	GetClusterInfo(ctt ClientContext) (*serialize.ClusterInfo, error)

	GetAppServers() (apps []*models.AppServer, err error)
	GetAppServer(name string) (*models.AppServer, error)

	GetCache() cache.Cache
}

Service interface allows us to access the CRUD Operations

func NewService 

func NewService(cache cache.Cache, repository db.Repository) (Service, error)

Source Files

View all Source files

Directories

Path Synopsis

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.