services

package
v0.0.86 Latest Latest
Warning

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

 Go to latest Published: Nov 27, 2023 License: MIT Imports: 59 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AuditLog = func(username string, action eventpb.ActionType, msg string) {
	events.AuditLog(username, action, msg, nil, nil)
}
View Source 
var ErrorPermissionDenied = errors.New("do not have permission to perform this operation")
View Source 
var FileAuditLog = func(username string, msg string, fileID int) {
	events.FileAuditLog(username, msg, fileID)
}
View Source 
var MustGetLang = middlewares.MustGetLang
View Source 
var MustGetUser = auth.MustGetUser

Functions

func RegisterEndpoint 

func RegisterEndpoint(fn endpointFunc)

func RegisterServer 

func RegisterServer(fn registryFunc)

func RegisteredEndpoints 

func RegisteredEndpoints() []endpointFunc

func RegisteredServers 

func RegisteredServers() []registryFunc

func RunAccessCheck added in v0.0.17 

func RunAccessCheck(cli kubernetes.Interface, namespace string) (bool, error)

Types

type AuthSvc 

type AuthSvc struct {
	auth.UnimplementedAuthServer
	// contains filtered or unexported fields
}

func NewAuthSvc 

func NewAuthSvc(authsvc contracts.AuthInterface, cfg contracts.OidcConfig, adminPwd string) *AuthSvc

func (*AuthSvc) AuthFuncOverride 

func (a *AuthSvc) AuthFuncOverride(ctx context.Context, fullMethodName string) (context.Context, error)

func (*AuthSvc) Exchange 

func (a *AuthSvc) Exchange(ctx context.Context, request *auth.ExchangeRequest) (*auth.ExchangeResponse, error)

func (*AuthSvc) Info 

func (a *AuthSvc) Info(ctx context.Context, req *auth.InfoRequest) (*auth.InfoResponse, error)

func (*AuthSvc) Login 

func (a *AuthSvc) Login(ctx context.Context, request *auth.LoginRequest) (*auth.LoginResponse, error)

func (*AuthSvc) Settings 

func (a *AuthSvc) Settings(ctx context.Context, request *auth.SettingsRequest) (*auth.SettingsResponse, error)

type CardSvc 

type CardSvc struct {
	card.UnimplementedCardSvcServer
}

func (*CardSvc) All 

func (c *CardSvc) All(ctx context.Context, request *card.AllRequest) (*card.AllResponse, error)

func (*CardSvc) AllContainers 

func (c *CardSvc) AllContainers(ctx context.Context, request *card.AllContainersRequest) (*card.AllContainersResponse, error)

func (*CardSvc) Create 

func (c *CardSvc) Create(ctx context.Context, request *card.CreateRequest) (*card.CreateResponse, error)

func (*CardSvc) Delete 

func (c *CardSvc) Delete(ctx context.Context, request *card.DeleteRequest) (*card.DeleteResponse, error)

func (*CardSvc) List 

func (c *CardSvc) List(ctx context.Context, request *card.ListRequest) (*card.ListResponse, error)

func (*CardSvc) Show 

func (c *CardSvc) Show(ctx context.Context, request *card.ShowRequest) (*card.ShowResponse, error)

type ClusterSvc 

type ClusterSvc struct {
	cluster.UnimplementedClusterSvcServer
}

func (*ClusterSvc) Authorize added in v0.0.42 

func (c *ClusterSvc) Authorize(ctx context.Context, fullMethodName string) (context.Context, error)

func (*ClusterSvc) Create 

func (c *ClusterSvc) Create(ctx context.Context, request *cluster.CreateRequest) (*cluster.CreateResponse, error)

func (*ClusterSvc) Delete 

func (c *ClusterSvc) Delete(ctx context.Context, request *cluster.DeleteRequest) (*cluster.DeleteResponse, error)

func (*ClusterSvc) List 

func (c *ClusterSvc) List(ctx context.Context, request *cluster.ListRequest) (*cluster.ListResponse, error)

func (*ClusterSvc) Show 

func (c *ClusterSvc) Show(ctx context.Context, request *cluster.ShowRequest) (*cluster.ShowResponse, error)

func (*ClusterSvc) Update added in v0.0.70 

func (c *ClusterSvc) Update(ctx context.Context, req *cluster.UpdateRequest) (*cluster.UpdateResponse, error)

type ContainerSvc 

type ContainerSvc struct {
	container.UnsafeContainerSvcServer
}

func (*ContainerSvc) ContainerLog 

func (c *ContainerSvc) ContainerLog(ctx context.Context, request *container.LogRequest) (*container.LogResponse, error)

func (*ContainerSvc) CopyToPod 

func (c *ContainerSvc) CopyToPod(ctx context.Context, request *container.CopyToPodRequest) (*container.CopyToPodResponse, error)

func (*ContainerSvc) Exec 

func (c *ContainerSvc) Exec(request *container.ExecRequest, server container.ContainerSvc_ExecServer) error

func (*ContainerSvc) IsPodExists 

func (c *ContainerSvc) IsPodExists(_ context.Context, request *container.IsPodExistsRequest) (*container.IsPodExistsResponse, error)

func (*ContainerSvc) IsPodRunning 

func (c *ContainerSvc) IsPodRunning(_ context.Context, request *container.IsPodRunningRequest) (*container.IsPodRunningResponse, error)

func (*ContainerSvc) Proxy added in v0.0.56 

func (c *ContainerSvc) Proxy(ctx context.Context, request *container.ProxyRequest) (*container.ProxyResponse, error)

func (*ContainerSvc) StreamContainerLog 

func (c *ContainerSvc) StreamContainerLog(request *container.LogRequest, server container.ContainerSvc_StreamContainerLogServer) error

func (*ContainerSvc) StreamCopyToPod 

func (c *ContainerSvc) StreamCopyToPod(server container.ContainerSvc_StreamCopyToPodServer) error

type EventSvc 

type EventSvc struct {
	event.UnsafeEventServer
}

func (*EventSvc) Authorize 

func (e *EventSvc) Authorize(ctx context.Context, fullMethodName string) (context.Context, error)

func (*EventSvc) List 

func (e *EventSvc) List(ctx context.Context, request *event.ListRequest) (*event.ListResponse, error)

type FileSvc 

type FileSvc struct {
	file.UnimplementedFileSvcServer
}

func (*FileSvc) Authorize 

func (m *FileSvc) Authorize(ctx context.Context, fullMethodName string) (context.Context, error)

func (*FileSvc) Delete 

func (*FileSvc) Delete(ctx context.Context, request *file.DeleteRequest) (*file.DeleteResponse, error)

func (*FileSvc) DeleteUndocumentedFiles 

func (m *FileSvc) DeleteUndocumentedFiles(ctx context.Context, _ *file.DeleteUndocumentedFilesRequest) (*file.DeleteUndocumentedFilesResponse, error)

func (*FileSvc) DiskInfo 

func (m *FileSvc) DiskInfo(ctx context.Context, request *file.DiskInfoRequest) (*file.DiskInfoResponse, error)

func (*FileSvc) List 

func (m *FileSvc) List(ctx context.Context, request *file.ListRequest) (*file.ListResponse, error)

func (*FileSvc) ShowRecords added in v0.0.46 

func (m *FileSvc) ShowRecords(ctx context.Context, request *file.ShowRecordsRequest) (*file.ShowRecordsResponse, error)

type MetricsSvc 

type MetricsSvc struct {
	metrics.UnsafeMetricsServer
}

func (*MetricsSvc) StreamTopPod 

func (m *MetricsSvc) StreamTopPod(request *metrics.TopPodRequest, server metrics.Metrics_StreamTopPodServer) error

func (*MetricsSvc) TopPod 

func (m *MetricsSvc) TopPod(ctx context.Context, request *metrics.TopPodRequest) (*metrics.TopPodResponse, error)

type PictureSvc 

type PictureSvc struct {
	picture.UnimplementedPictureServer
}

func (*PictureSvc) AuthFuncOverride 

func (p *PictureSvc) AuthFuncOverride(ctx context.Context, fullMethodName string) (context.Context, error)

func (*PictureSvc) Background 

func (p *PictureSvc) Background(ctx context.Context, req *picture.BackgroundRequest) (*picture.BackgroundResponse, error)

type VersionSvc 

type VersionSvc struct {
	version.UnsafeVersionServer
}

func (*VersionSvc) AuthFuncOverride 

func (*VersionSvc) AuthFuncOverride(ctx context.Context, fullMethodName string) (context.Context, error)

func (*VersionSvc) Version 

func (*VersionSvc) Version(ctx context.Context, request *version.Request) (*version.Response, 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.