backend

package

v0.0.5 Latest Latest Go to latest Published: Dec 28, 2022 License: Apache-2.0 Imports: 30 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kubeops/scanner

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func CheckPrivateImage(imageRef name.Reference) (bool, error)
func DownloadReport(fs blobfs.Interface, img string) ([]byte, error)
func DownloadVersionInfo(fs blobfs.Interface, img string) ([]byte, error)
func ErrorToAPIStatus(err error) *metav1.Status
func ExistsReport(fs blobfs.Interface, img string) (bool, error)
func GRPCCode(err error) gcerrors.ErrorCode
func HTTPStatusFromCode(code gcerrors.ErrorCode) int32
func NewBlobFS() blobfs.Interface
func NewConnection(addr, credFile string) (nc *nats.Conn, err error)
func ParseReference(img string) (repo string, digest string, err error)
func SubmitScanRequest(nc *nats.Conn, subj string, img string) error
func UploadReport(fs blobfs.Interface, img string) error
type Manager
- func New(nc *nats.Conn, opts Options) *Manager
- func (mgr *Manager) Start(ctx context.Context, jsmOpts ...nats.JSOpt) error
type Options
- func DefaultOptions() Options

Constants ¶

View Source

const (
	RespondTypeReport  = "report"
	RespondTypeVersion = "version"
)

View Source

const (
	NatsRequestTimeout = 10 * time.Second
)

Variables ¶

This section is empty.

Functions ¶

func CheckPrivateImage ¶

func CheckPrivateImage(imageRef name.Reference) (bool, error)

func DownloadReport ¶

func DownloadReport(fs blobfs.Interface, img string) ([]byte, error)

func DownloadVersionInfo ¶

func DownloadVersionInfo(fs blobfs.Interface, img string) ([]byte, error)

func ErrorToAPIStatus ¶

func ErrorToAPIStatus(err error) *metav1.Status

ErrorToAPIStatus converts an error to an metav1.Status object.

func ExistsReport ¶

func ExistsReport(fs blobfs.Interface, img string) (bool, error)

func GRPCCode ¶

func GRPCCode(err error) gcerrors.ErrorCode

GRPCCode extracts the gRPC status code and converts it into an ErrorCode. It returns Unknown if the error isn't from gRPC.

func HTTPStatusFromCode ¶

func HTTPStatusFromCode(code gcerrors.ErrorCode) int32

HTTPStatusFromCode converts a gRPC error code into the corresponding HTTP response status. See: https://github.com/googleapis/googleapis/blob/master/google/rpc/code.proto See: https://github.com/grpc-ecosystem/grpc-gateway/blob/v2.11.3/runtime/errors.go#L34-L77

func NewBlobFS ¶

func NewBlobFS() blobfs.Interface

func NewConnection ¶

func NewConnection(addr, credFile string) (nc *nats.Conn, err error)

NewConnection creates a new NATS connection

func ParseReference ¶

func ParseReference(img string) (repo string, digest string, err error)

func SubmitScanRequest ¶

func SubmitScanRequest(nc *nats.Conn, subj string, img string) error

func UploadReport ¶

func UploadReport(fs blobfs.Interface, img string) error

Types ¶

type Manager ¶

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

func New ¶

func New(nc *nats.Conn, opts Options) *Manager

func (*Manager) Start ¶

func (mgr *Manager) Start(ctx context.Context, jsmOpts ...nats.JSOpt) error

type Options ¶

type Options struct {
	AckWait time.Duration

	// same as stream
	Stream string

	// manager id, < 0 means auto detect
	Id int
	// hostname
	Name string

	NumReplicas int
	NumWorkers  int

	FS blobfs.Interface
}

func DefaultOptions ¶

func DefaultOptions() Options

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL