jobs

Documentation

Index

• type AppliedConfEvent
• type Ask2ResolveDomainAddresses
  • func (a Ask2ResolveDomainAddresses) Cmp(other Ask2ResolveDomainAddresses) int
• type DnsRefresher
  • func NewDnsRefresher(sbj observer.Subject) *DnsRefresher
  • func (rf *DnsRefresher) Close() error
  • func (rf *DnsRefresher) MakeObserver(ctx context.Context) observer.Observer
  • func (rf *DnsRefresher) Run(ctx context.Context) (err error)
• type DomainAddresses
• type NftApplierJob
  • func NewNftApplierJob(proc nft.NfTablesProcessor, client agent.SGClient, opts ...Option) *NftApplierJob
  • func (jb *NftApplierJob) Close() error
  • func (jb *NftApplierJob) MakeObserver() observer.Observer
  • func (jb *NftApplierJob) Run(ctx context.Context) (err error)
• type Option
• type WithNetNS
• type WithSubject

Types

type AppliedConfEvent

type AppliedConfEvent struct {
	NetConf      host.NetConf
	AppliedRules nft.AppliedRules

	observer.EventType
}

AppliedConfEvent -

type Ask2ResolveDomainAddresses

type Ask2ResolveDomainAddresses struct {
	IpVersion   int
	FQDN        model.FQDN
	ValidBefore time.Time

	observer.EventType
}

Ask2ResolveDomainAddresses -

func (Ask2ResolveDomainAddresses) Cmp

func (a Ask2ResolveDomainAddresses) Cmp(other Ask2ResolveDomainAddresses) int

Cmp -

type DnsRefresher

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

DnsRefresher -

func NewDnsRefresher

func NewDnsRefresher(sbj observer.Subject) *DnsRefresher

NewDnsRefresher -

func (*DnsRefresher) Close

func (rf *DnsRefresher) Close() error

Close -

func (*DnsRefresher) MakeObserver

func (rf *DnsRefresher) MakeObserver(ctx context.Context) observer.Observer

MakeObserver -

func (*DnsRefresher) Run

func (rf *DnsRefresher) Run(ctx context.Context) (err error)

Run -

type DomainAddresses

type DomainAddresses struct {
	IpVersion int
	FQDN      model.FQDN
	DnsAnswer agent.DomainAddresses

	observer.EventType
}

DomainAddresses -

type NftApplierJob

type NftApplierJob struct {
	Subject observer.Subject
	// contains filtered or unexported fields
}

NftApplierJob -

func NewNftApplierJob

func NewNftApplierJob(proc nft.NfTablesProcessor, client agent.SGClient, opts ...Option) *NftApplierJob

func (*NftApplierJob) Close

func (jb *NftApplierJob) Close() error

Close -

func (*NftApplierJob) MakeObserver

func (jb *NftApplierJob) MakeObserver() observer.Observer

MakeObserver -

func (*NftApplierJob) Run

func (jb *NftApplierJob) Run(ctx context.Context) (err error)

Run -

type Option

type Option interface {
	// contains filtered or unexported methods
}

Option -

type WithNetNS

type WithNetNS string

WithNetNS -

type WithSubject

type WithSubject struct {
	observer.Subject
}

WithSubject -