otterizecloud

Documentation

Index

• func NilCompare[T constraints.Ordered](a *T, b *T) int
• func StartPeriodicallyReportConnectionToCloud(client CloudClient, ctx context.Context)
• type CloudClient
  • func NewClient(ctx context.Context) (CloudClient, bool, error)
• type CloudClientImpl
  • func (c *CloudClientImpl) ReportAppliedIntents(ctx context.Context, namespace *string, intents []*graphqlclient.IntentInput) error
  • func (c *CloudClientImpl) ReportComponentStatus(ctx context.Context, component graphqlclient.ComponentType)
  • func (c *CloudClientImpl) ReportIntentsOperatorConfiguration(ctx context.Context, config graphqlclient.IntentsOperatorConfigurationInput) error
  • func (c *CloudClientImpl) ReportKafkaServerConfig(ctx context.Context, namespace string, ...) error
• type IntentsMatcher
  • func GetMatcher(expected []graphqlclient.IntentInput) IntentsMatcher
  • func (m IntentsMatcher) Got(got interface{}) string
  • func (m IntentsMatcher) Matches(x interface{}) bool
  • func (m IntentsMatcher) String() string
• type OtterizeCloudReconciler
  • func NewOtterizeCloudReconciler(client client.Client, scheme *runtime.Scheme, cloudClient CloudClient) *OtterizeCloudReconciler
  • func (r *OtterizeCloudReconciler) Reconcile(ctx context.Context, req reconcile.Request) (ctrl.Result, error)

Functions

func NilCompare

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

func StartPeriodicallyReportConnectionToCloud

func StartPeriodicallyReportConnectionToCloud(client CloudClient, ctx context.Context)

Types

type CloudClient

type CloudClient interface {
	ReportKafkaServerConfig(ctx context.Context, namespace string, servers []graphqlclient.KafkaServerConfigInput) error
	ReportAppliedIntents(ctx context.Context, namespace *string, intents []*graphqlclient.IntentInput) error
	ReportIntentsOperatorConfiguration(ctx context.Context, config graphqlclient.IntentsOperatorConfigurationInput) error
	ReportComponentStatus(ctx context.Context, component graphqlclient.ComponentType)
}

func NewClient

func NewClient(ctx context.Context) (CloudClient, bool, error)

type CloudClientImpl

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

func (*CloudClientImpl) ReportAppliedIntents

func (c *CloudClientImpl) ReportAppliedIntents(
	ctx context.Context,
	namespace *string,
	intents []*graphqlclient.IntentInput) error

func (*CloudClientImpl) ReportComponentStatus

func (c *CloudClientImpl) ReportComponentStatus(ctx context.Context, component graphqlclient.ComponentType)

func (*CloudClientImpl) ReportIntentsOperatorConfiguration

func (c *CloudClientImpl) ReportIntentsOperatorConfiguration(
	ctx context.Context,
	config graphqlclient.IntentsOperatorConfigurationInput) error

func (*CloudClientImpl) ReportKafkaServerConfig

func (c *CloudClientImpl) ReportKafkaServerConfig(ctx context.Context, namespace string, servers []graphqlclient.KafkaServerConfigInput) error

type IntentsMatcher

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

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

func GetMatcher

func GetMatcher(expected []graphqlclient.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

type OtterizeCloudReconciler

type OtterizeCloudReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	injectablerecorder.InjectableRecorder
	// contains filtered or unexported fields
}

func NewOtterizeCloudReconciler

func NewOtterizeCloudReconciler(
	client client.Client,
	scheme *runtime.Scheme,
	cloudClient CloudClient) *OtterizeCloudReconciler

func (*OtterizeCloudReconciler) Reconcile

func (r *OtterizeCloudReconciler) Reconcile(ctx context.Context, req reconcile.Request) (ctrl.Result, error)