clouduploader

Documentation

Index

• func NilCompare[T constraints.Ordered](a *T, b *T) int
• type CloudUploader
  • func NewCloudUploader(intentsHolder *intentsstore.IntentsHolder, config Config, ...) *CloudUploader
  • func (c *CloudUploader) NotifyAWSIntents(ctx context.Context, intents []awsintentsholder.AWSIntent)
  • func (c *CloudUploader) NotifyAzureIntents(ctx context.Context, ops []model.AzureOperation)
  • func (c *CloudUploader) NotifyExternalTrafficIntents(ctx context.Context, ...)
  • func (c *CloudUploader) NotifyIncomingTrafficIntents(ctx context.Context, ...)
  • func (c *CloudUploader) NotifyIntents(ctx context.Context, intents []intentsstore.TimestampedIntent)
  • func (c *CloudUploader) PeriodicStatusReport(ctx context.Context)
• type Config
  • func ConfigFromViper() Config
• type IntentsMatcher
  • func GetMatcher(expected []cloudclient.IntentInput) IntentsMatcher
  • func (m IntentsMatcher) Got(got interface{}) string
  • func (m IntentsMatcher) Matches(x interface{}) bool
  • func (m IntentsMatcher) String() string

Functions

func NilCompare

func NilCompare[T constraints.Ordered](a *T, b *T) int

Types

type CloudUploader

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

func NewCloudUploader

func NewCloudUploader(intentsHolder *intentsstore.IntentsHolder, config Config, client cloudclient.CloudClient) *CloudUploader

func (*CloudUploader) NotifyAWSIntents

func (c *CloudUploader) NotifyAWSIntents(ctx context.Context, intents []awsintentsholder.AWSIntent)

func (*CloudUploader) NotifyAzureIntents

func (c *CloudUploader) NotifyAzureIntents(ctx context.Context, ops []model.AzureOperation)

func (*CloudUploader) NotifyExternalTrafficIntents

func (c *CloudUploader) NotifyExternalTrafficIntents(ctx context.Context, intents []externaltrafficholder.TimestampedExternalTrafficIntent)

func (*CloudUploader) NotifyIncomingTrafficIntents

func (c *CloudUploader) NotifyIncomingTrafficIntents(ctx context.Context, intents []incomingtrafficholder.TimestampedIncomingTrafficIntent)

func (*CloudUploader) NotifyIntents

func (c *CloudUploader) NotifyIntents(ctx context.Context, intents []intentsstore.TimestampedIntent)

func (*CloudUploader) PeriodicStatusReport

func (c *CloudUploader) PeriodicStatusReport(ctx context.Context)

type Config

type Config struct {
	UploadInterval  time.Duration
	UploadBatchSize int
}

func ConfigFromViper

func ConfigFromViper() Config

type IntentsMatcher

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

IntentsMatcher Implement gomock.Matcher interface for []cloudclient.IntentInput

func GetMatcher

func GetMatcher(expected []cloudclient.IntentInput) IntentsMatcher

func (IntentsMatcher) Got

func (m IntentsMatcher) Got(got interface{}) string

func (IntentsMatcher) Matches

func (m IntentsMatcher) Matches(x interface{}) bool

func (IntentsMatcher) String

func (m IntentsMatcher) String() string