Documentation
¶
Index ¶
- func NilCompare[T constraints.Ordered](a *T, b *T) int
- func StartPeriodicallyReportConnectionToCloud(client CloudClient, ctx context.Context)
- type CloudClient
- 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
- type OtterizeCloudReconciler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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)
}
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
Source Files
Click to show internal directories.
Click to hide internal directories.