Documentation
¶
Index ¶
- func DiffTags(local []svcapitypes.CustomTag, remote []*svcsdk.Tag) (add map[string]*string, remove []*string)
- func DifferenceShardLevelMetrics(local []*string, remote []*string) ([]*string, []*string)
- func GenerateCreateStreamInput(cr *svcapitypes.Stream) *svcsdk.CreateStreamInput
- func GenerateDeleteStreamInput(cr *svcapitypes.Stream) *svcsdk.DeleteStreamInput
- func GenerateDescribeStreamInput(cr *svcapitypes.Stream) *svcsdk.DescribeStreamInput
- func GenerateObservation(obj *svcsdk.StreamDescription) svcapitypes.StreamObservation
- func GenerateStream(resp *svcsdk.DescribeStreamOutput) *svcapitypes.Stream
- func IsNotFound(err error) bool
- func SetupStream(mgr ctrl.Manager, o controller.Options) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DiffTags ¶
func DiffTags(local []svcapitypes.CustomTag, remote []*svcsdk.Tag) (add map[string]*string, remove []*string)
DiffTags returns the lists of tags that need to be removed and added according to current and desired states.
func DifferenceShardLevelMetrics ¶
DifferenceShardLevelMetrics returns the lists of ShardLevelMetrics that need to be removed and added according to current and desired states.
func GenerateCreateStreamInput ¶
func GenerateCreateStreamInput(cr *svcapitypes.Stream) *svcsdk.CreateStreamInput
GenerateCreateStreamInput returns a create input.
func GenerateDeleteStreamInput ¶
func GenerateDeleteStreamInput(cr *svcapitypes.Stream) *svcsdk.DeleteStreamInput
GenerateDeleteStreamInput returns a deletion input.
func GenerateDescribeStreamInput ¶
func GenerateDescribeStreamInput(cr *svcapitypes.Stream) *svcsdk.DescribeStreamInput
GenerateDescribeStreamInput returns input for read operation.
func GenerateObservation ¶
func GenerateObservation(obj *svcsdk.StreamDescription) svcapitypes.StreamObservation
GenerateObservation is used to produce v1beta1.ClusterObservation from ekstypes.Cluster.
func GenerateStream ¶
func GenerateStream(resp *svcsdk.DescribeStreamOutput) *svcapitypes.Stream
GenerateStream returns the current state in the form of *svcapitypes.Stream.
func IsNotFound ¶
IsNotFound returns whether the given error is of type NotFound or not.
func SetupStream ¶
func SetupStream(mgr ctrl.Manager, o controller.Options) error
SetupStream adds a controller that reconciles Stream.
Types ¶
This section is empty.
Source Files