service

Documentation

Index

• Constants
• func ConvertLogs(rawLog []byte) ([]*binoculars.LogLine, []error)
• func GetPatchBytes(patchData *nodePatch) ([]byte, error)
• type CordonService
• type KubernetesCordonService
  • func NewKubernetesCordonService(cordonConfig configuration.CordonConfiguration, ...) *KubernetesCordonService
  • func (c *KubernetesCordonService) CordonNode(ctx *armadacontext.Context, request *binoculars.CordonRequest) error
• type KubernetesLogService
  • func NewKubernetesLogService(clientProvider cluster.KubernetesClientProvider) *KubernetesLogService
  • func (l *KubernetesLogService) GetLogs(ctx *armadacontext.Context, params *LogParams) ([]*binoculars.LogLine, error)
• type LogParams
• type LogService

Constants

const MaxLogBytes = 2000000

Functions

func ConvertLogs

func ConvertLogs(rawLog []byte) ([]*binoculars.LogLine, []error)

func GetPatchBytes

func GetPatchBytes(patchData *nodePatch) ([]byte, error)

Types

type CordonService

type CordonService interface {
	CordonNode(ctx *armadacontext.Context, request *binoculars.CordonRequest) error
}

type KubernetesCordonService

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

func NewKubernetesCordonService

func NewKubernetesCordonService(
	cordonConfig configuration.CordonConfiguration,
	permissionsChecker authorization.PermissionChecker,
	clientProvider cluster.KubernetesClientProvider,
) *KubernetesCordonService

func (*KubernetesCordonService) CordonNode

func (c *KubernetesCordonService) CordonNode(ctx *armadacontext.Context, request *binoculars.CordonRequest) error

type KubernetesLogService

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

func NewKubernetesLogService

func NewKubernetesLogService(clientProvider cluster.KubernetesClientProvider) *KubernetesLogService

func (*KubernetesLogService) GetLogs

func (l *KubernetesLogService) GetLogs(ctx *armadacontext.Context, params *LogParams) ([]*binoculars.LogLine, error)

type LogParams

type LogParams struct {
	Principal  authorization.Principal
	Namespace  string
	PodName    string
	SinceTime  string
	LogOptions *v1.PodLogOptions
}

type LogService

type LogService interface {
	GetLogs(ctx *armadacontext.Context, params *LogParams) ([]*binoculars.LogLine, error)
}