services

Documentation

Index

• Constants
• Variables
• func FindDefaultContainer(pod *v1.Pod) string
• func RegisterEndpoint(fn endpointFunc)
• func RegisterServer(fn registryFunc)
• func RegisteredEndpoints() []endpointFunc
• func RegisteredServers() []registryFunc
• type OidcAuthProvider
  • func NewDefaultAuthProvider(cfg oauth2.Config, provider *oidc.Provider) OidcAuthProvider
• type Steamer

Constants

const (
	OptionTypeProject string = "project"
	OptionTypeBranch  string = "branch"
	OptionTypeCommit  string = "commit"
)

const ProjectOptionsCacheKey = "ProjectOptions"

Variables

var AuditLog = func(username string, action types.EventActionType, msg string) {
	events.AuditLog(username, action, msg, nil, nil)
}

var AuditLogWithChange = events.AuditLog

var ErrorPermissionDenied = errors.New("没有权限执行该操作")

var FileAuditLog = func(username string, msg string, fileID int) {
	events.FileAuditLog(username, msg, fileID)
}

var GetProjectMarsConfig = utils.GetProjectMarsConfig

var MustGetUser = auth.MustGetUser

Functions

func FindDefaultContainer

func FindDefaultContainer(pod *v1.Pod) string

func RegisterEndpoint

func RegisterEndpoint(fn endpointFunc)

func RegisterServer

func RegisterServer(fn registryFunc)

func RegisteredEndpoints

func RegisteredEndpoints() []endpointFunc

func RegisteredServers

func RegisteredServers() []registryFunc

Types

type OidcAuthProvider

type OidcAuthProvider interface {
	Exchange(ctx context.Context, code string) (string, error)
	Verify(ctx context.Context, token string) (idToken, error)
}

func NewDefaultAuthProvider

func NewDefaultAuthProvider(cfg oauth2.Config, provider *oidc.Provider) OidcAuthProvider

type Steamer

type Steamer interface {
	Stream(ctx context.Context, namespace, pod, container string) (io.ReadCloser, error)
}