stream

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

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

func DifferenceShardLevelMetrics(local []*string, remote []*string) ([]*string, []*string)

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

func IsNotFound(err error) bool

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.