nats

package
v0.0.0-...-4673371 Latest Latest
Warning

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

 Go to latest Published: Jul 7, 2024 License: EUPL-1.2 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_protobuf_proto protoreflect.FileDescriptor

Functions

func NewAllTasksRunner 

func NewAllTasksRunner(conn *nats.Conn, localRunner tasks.TaskRunner, querier AllTasksQuerier, concurrency int, saltKey string) *allTasksRunner

func NewDockerScannerTaskRunner 

func NewDockerScannerTaskRunner(conn *nats.Conn, localRunner tasks.DockerTasksRunner, querier DockerQuerier, concurrency int, saltKey string) *dockerScannerTaskRunner

func NewDockerScannerTaskSender 

func NewDockerScannerTaskSender(conn *nats.Conn) *dockerScannerTaskSender

func NewEmailSenderTaskRunner 

func NewEmailSenderTaskRunner(conn *nats.Conn, localRunner tasks.EmailTasksRunner, concurrency int) *emailSenderTaskRunner

func NewEmailSenderTaskSender 

func NewEmailSenderTaskSender(conn *nats.Conn) *emailSenderTaskSender

func NewGitScannerTaskRunner 

func NewGitScannerTaskRunner(conn *nats.Conn, localRunner tasks.GitTasksRunner, querier GitQuerier, concurrency int, saltKey string) *gitScannerTaskRunner

func NewGitScannerTaskSender 

func NewGitScannerTaskSender(conn *nats.Conn) *gitScannerTaskSender

func NewNVDScannerTaskRunner 

func NewNVDScannerTaskRunner(conn *nats.Conn, localRunner tasks.VulnerabilityTasksRunner, querier local.NvdQuerier, concurrency int) *nvdScannerTaskRunner

func NewNVDScannerTaskSender 

func NewNVDScannerTaskSender(conn *nats.Conn) *nvdScannerTaskSender

func NewNatsScannerTaskRunner 

func NewNatsScannerTaskRunner(conn *nats.Conn, localRunner tasks.TaskRunner, querier local.SaverQuerier, concurrency int) *natsScannerTaskRunner

func NewNatsScannerTaskSender 

func NewNatsScannerTaskSender(conn *nats.Conn) *natsScannerTaskSender

func NewTaskSender 

func NewTaskSender(conn *nats.Conn) tasks.TaskRunner

Types

type AllTasksQuerier 

type AllTasksQuerier interface {
	DockerQuerier
	GitQuerier
	local.NvdQuerier
	local.SaverQuerier
}

type DockerQuerier 

type DockerQuerier interface {
	local.DockerQuerier
	GetDockerImage(context.Context, queries.GetDockerImageParams) (*queries.GetDockerImageRow, error)
	GetScan(ctx context.Context, id int64) (*queries.GetScanRow, error)
}

type GitQuerier 

type GitQuerier interface {
	local.GitQuerier
	GetGitRepository(context.Context, queries.GetGitRepositoryParams) (*queries.GetGitRepositoryRow, error)
	GetScan(ctx context.Context, id int64) (*queries.GetScanRow, error)
}

type MessageHeader 

type MessageHeader struct {
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	Retries  int32             `protobuf:"varint,2,opt,name=retries,proto3" json:"retries,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageHeader) Descriptor deprecated 

func (*MessageHeader) Descriptor() ([]byte, []int)

Deprecated: Use MessageHeader.ProtoReflect.Descriptor instead.

func (*MessageHeader) GetMetadata 

func (x *MessageHeader) GetMetadata() map[string]string

func (*MessageHeader) GetRetries 

func (x *MessageHeader) GetRetries() int32

func (*MessageHeader) ProtoMessage 

func (*MessageHeader) ProtoMessage()

func (*MessageHeader) ProtoReflect 

func (x *MessageHeader) ProtoReflect() protoreflect.Message

func (*MessageHeader) Reset 

func (x *MessageHeader) Reset()

func (*MessageHeader) String 

func (x *MessageHeader) String() string

type RunSaverForPublicMessage 

type RunSaverForPublicMessage struct {
	ScanId   int64  `protobuf:"varint,1,opt,name=scanId,proto3" json:"scanId,omitempty"`
	ScanType string `protobuf:"bytes,2,opt,name=scanType,proto3" json:"scanType,omitempty"`
	// contains filtered or unexported fields
}

func (*RunSaverForPublicMessage) Descriptor deprecated 

func (*RunSaverForPublicMessage) Descriptor() ([]byte, []int)

Deprecated: Use RunSaverForPublicMessage.ProtoReflect.Descriptor instead.

func (*RunSaverForPublicMessage) GetScanId 

func (x *RunSaverForPublicMessage) GetScanId() int64

func (*RunSaverForPublicMessage) GetScanType 

func (x *RunSaverForPublicMessage) GetScanType() string

func (*RunSaverForPublicMessage) ProtoMessage 

func (*RunSaverForPublicMessage) ProtoMessage()

func (*RunSaverForPublicMessage) ProtoReflect 

func (x *RunSaverForPublicMessage) ProtoReflect() protoreflect.Message

func (*RunSaverForPublicMessage) Reset 

func (x *RunSaverForPublicMessage) Reset()

func (*RunSaverForPublicMessage) String 

func (x *RunSaverForPublicMessage) String() string

type RunSaverRemoteMessage 

type RunSaverRemoteMessage struct {
	ScanId   int64  `protobuf:"varint,1,opt,name=scanId,proto3" json:"scanId,omitempty"`
	ScanType string `protobuf:"bytes,2,opt,name=scanType,proto3" json:"scanType,omitempty"`
	// contains filtered or unexported fields
}

func (*RunSaverRemoteMessage) Descriptor deprecated 

func (*RunSaverRemoteMessage) Descriptor() ([]byte, []int)

Deprecated: Use RunSaverRemoteMessage.ProtoReflect.Descriptor instead.

func (*RunSaverRemoteMessage) GetScanId 

func (x *RunSaverRemoteMessage) GetScanId() int64

func (*RunSaverRemoteMessage) GetScanType 

func (x *RunSaverRemoteMessage) GetScanType() string

func (*RunSaverRemoteMessage) ProtoMessage 

func (*RunSaverRemoteMessage) ProtoMessage()

func (*RunSaverRemoteMessage) ProtoReflect 

func (x *RunSaverRemoteMessage) ProtoReflect() protoreflect.Message

func (*RunSaverRemoteMessage) Reset 

func (x *RunSaverRemoteMessage) Reset()

func (*RunSaverRemoteMessage) String 

func (x *RunSaverRemoteMessage) String() string

type ScanDockerRepoMessage 

type ScanDockerRepoMessage struct {
	ImageId int64 `protobuf:"varint,1,opt,name=imageId,proto3" json:"imageId,omitempty"`
	ScanId  int64 `protobuf:"varint,2,opt,name=scanId,proto3" json:"scanId,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanDockerRepoMessage) Descriptor deprecated 

func (*ScanDockerRepoMessage) Descriptor() ([]byte, []int)

Deprecated: Use ScanDockerRepoMessage.ProtoReflect.Descriptor instead.

func (*ScanDockerRepoMessage) GetImageId 

func (x *ScanDockerRepoMessage) GetImageId() int64

func (*ScanDockerRepoMessage) GetScanId 

func (x *ScanDockerRepoMessage) GetScanId() int64

func (*ScanDockerRepoMessage) ProtoMessage 

func (*ScanDockerRepoMessage) ProtoMessage()

func (*ScanDockerRepoMessage) ProtoReflect 

func (x *ScanDockerRepoMessage) ProtoReflect() protoreflect.Message

func (*ScanDockerRepoMessage) Reset 

func (x *ScanDockerRepoMessage) Reset()

func (*ScanDockerRepoMessage) String 

func (x *ScanDockerRepoMessage) String() string

type ScanGitRepositoryMessage 

type ScanGitRepositoryMessage struct {
	RepoId int64 `protobuf:"varint,1,opt,name=repoId,proto3" json:"repoId,omitempty"`
	ScanId int64 `protobuf:"varint,2,opt,name=scanId,proto3" json:"scanId,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanGitRepositoryMessage) Descriptor deprecated 

func (*ScanGitRepositoryMessage) Descriptor() ([]byte, []int)

Deprecated: Use ScanGitRepositoryMessage.ProtoReflect.Descriptor instead.

func (*ScanGitRepositoryMessage) GetRepoId 

func (x *ScanGitRepositoryMessage) GetRepoId() int64

func (*ScanGitRepositoryMessage) GetScanId 

func (x *ScanGitRepositoryMessage) GetScanId() int64

func (*ScanGitRepositoryMessage) ProtoMessage 

func (*ScanGitRepositoryMessage) ProtoMessage()

func (*ScanGitRepositoryMessage) ProtoReflect 

func (x *ScanGitRepositoryMessage) ProtoReflect() protoreflect.Message

func (*ScanGitRepositoryMessage) Reset 

func (x *ScanGitRepositoryMessage) Reset()

func (*ScanGitRepositoryMessage) String 

func (x *ScanGitRepositoryMessage) String() string

type ScheduleFullRunMessage 

type ScheduleFullRunMessage struct {
	ProjectId   int64  `protobuf:"varint,1,opt,name=projectId,proto3" json:"projectId,omitempty"`
	ScanGroupId int64  `protobuf:"varint,2,opt,name=scanGroupId,proto3" json:"scanGroupId,omitempty"`
	SourceType  string `protobuf:"bytes,3,opt,name=sourceType,proto3" json:"sourceType,omitempty"`
	ScanType    string `protobuf:"bytes,4,opt,name=scanType,proto3" json:"scanType,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduleFullRunMessage) Descriptor deprecated 

func (*ScheduleFullRunMessage) Descriptor() ([]byte, []int)

Deprecated: Use ScheduleFullRunMessage.ProtoReflect.Descriptor instead.

func (*ScheduleFullRunMessage) GetProjectId 

func (x *ScheduleFullRunMessage) GetProjectId() int64

func (*ScheduleFullRunMessage) GetScanGroupId 

func (x *ScheduleFullRunMessage) GetScanGroupId() int64

func (*ScheduleFullRunMessage) GetScanType 

func (x *ScheduleFullRunMessage) GetScanType() string

func (*ScheduleFullRunMessage) GetSourceType 

func (x *ScheduleFullRunMessage) GetSourceType() string

func (*ScheduleFullRunMessage) ProtoMessage 

func (*ScheduleFullRunMessage) ProtoMessage()

func (*ScheduleFullRunMessage) ProtoReflect 

func (x *ScheduleFullRunMessage) ProtoReflect() protoreflect.Message

func (*ScheduleFullRunMessage) Reset 

func (x *ScheduleFullRunMessage) Reset()

func (*ScheduleFullRunMessage) String 

func (x *ScheduleFullRunMessage) String() string

type ScheduleSaverRunMessage 

type ScheduleSaverRunMessage struct {
	ScanId   int64  `protobuf:"varint,1,opt,name=scanId,proto3" json:"scanId,omitempty"`
	ScanType string `protobuf:"bytes,2,opt,name=scanType,proto3" json:"scanType,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduleSaverRunMessage) Descriptor deprecated 

func (*ScheduleSaverRunMessage) Descriptor() ([]byte, []int)

Deprecated: Use ScheduleSaverRunMessage.ProtoReflect.Descriptor instead.

func (*ScheduleSaverRunMessage) GetScanId 

func (x *ScheduleSaverRunMessage) GetScanId() int64

func (*ScheduleSaverRunMessage) GetScanType 

func (x *ScheduleSaverRunMessage) GetScanType() string

func (*ScheduleSaverRunMessage) ProtoMessage 

func (*ScheduleSaverRunMessage) ProtoMessage()

func (*ScheduleSaverRunMessage) ProtoReflect 

func (x *ScheduleSaverRunMessage) ProtoReflect() protoreflect.Message

func (*ScheduleSaverRunMessage) Reset 

func (x *ScheduleSaverRunMessage) Reset()

func (*ScheduleSaverRunMessage) String 

func (x *ScheduleSaverRunMessage) String() string

type ScheduleSourceRunMessage 

type ScheduleSourceRunMessage struct {
	ProjectId   int64  `protobuf:"varint,1,opt,name=projectId,proto3" json:"projectId,omitempty"`
	ScanGroupId int64  `protobuf:"varint,2,opt,name=scanGroupId,proto3" json:"scanGroupId,omitempty"`
	SourceType  string `protobuf:"bytes,3,opt,name=sourceType,proto3" json:"sourceType,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduleSourceRunMessage) Descriptor deprecated 

func (*ScheduleSourceRunMessage) Descriptor() ([]byte, []int)

Deprecated: Use ScheduleSourceRunMessage.ProtoReflect.Descriptor instead.

func (*ScheduleSourceRunMessage) GetProjectId 

func (x *ScheduleSourceRunMessage) GetProjectId() int64

func (*ScheduleSourceRunMessage) GetScanGroupId 

func (x *ScheduleSourceRunMessage) GetScanGroupId() int64

func (*ScheduleSourceRunMessage) GetSourceType 

func (x *ScheduleSourceRunMessage) GetSourceType() string

func (*ScheduleSourceRunMessage) ProtoMessage 

func (*ScheduleSourceRunMessage) ProtoMessage()

func (*ScheduleSourceRunMessage) ProtoReflect 

func (x *ScheduleSourceRunMessage) ProtoReflect() protoreflect.Message

func (*ScheduleSourceRunMessage) Reset 

func (x *ScheduleSourceRunMessage) Reset()

func (*ScheduleSourceRunMessage) String 

func (x *ScheduleSourceRunMessage) String() string

type SendEmailMessage 

type SendEmailMessage struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Subject string `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	Text    string `protobuf:"bytes,3,opt,name=text,proto3" json:"text,omitempty"`
	Html    string `protobuf:"bytes,4,opt,name=html,proto3" json:"html,omitempty"`
	// contains filtered or unexported fields
}

func (*SendEmailMessage) Descriptor deprecated 

func (*SendEmailMessage) Descriptor() ([]byte, []int)

Deprecated: Use SendEmailMessage.ProtoReflect.Descriptor instead.

func (*SendEmailMessage) GetAddress 

func (x *SendEmailMessage) GetAddress() string

func (*SendEmailMessage) GetHtml 

func (x *SendEmailMessage) GetHtml() string

func (*SendEmailMessage) GetSubject 

func (x *SendEmailMessage) GetSubject() string

func (*SendEmailMessage) GetText 

func (x *SendEmailMessage) GetText() string

func (*SendEmailMessage) ProtoMessage 

func (*SendEmailMessage) ProtoMessage()

func (*SendEmailMessage) ProtoReflect 

func (x *SendEmailMessage) ProtoReflect() protoreflect.Message

func (*SendEmailMessage) Reset 

func (x *SendEmailMessage) Reset()

func (*SendEmailMessage) String 

func (x *SendEmailMessage) String() string

type UpdateNVDVulnerabilitiesForProductMessage 

type UpdateNVDVulnerabilitiesForProductMessage struct {
	ProductId int64 `protobuf:"varint,1,opt,name=productId,proto3" json:"productId,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNVDVulnerabilitiesForProductMessage) Descriptor deprecated 

func (*UpdateNVDVulnerabilitiesForProductMessage) Descriptor() ([]byte, []int)

Deprecated: Use UpdateNVDVulnerabilitiesForProductMessage.ProtoReflect.Descriptor instead.

func (*UpdateNVDVulnerabilitiesForProductMessage) GetProductId 

func (x *UpdateNVDVulnerabilitiesForProductMessage) GetProductId() int64

func (*UpdateNVDVulnerabilitiesForProductMessage) ProtoMessage 

func (*UpdateNVDVulnerabilitiesForProductMessage) ProtoMessage()

func (*UpdateNVDVulnerabilitiesForProductMessage) ProtoReflect 

func (x *UpdateNVDVulnerabilitiesForProductMessage) ProtoReflect() protoreflect.Message

func (*UpdateNVDVulnerabilitiesForProductMessage) Reset 

func (x *UpdateNVDVulnerabilitiesForProductMessage) Reset()

func (*UpdateNVDVulnerabilitiesForProductMessage) String 

func (x *UpdateNVDVulnerabilitiesForProductMessage) String() string

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.