util

Documentation

Index

• Constants
• func Contains(arr []string, element string) bool
• func Convert(from interface{}, to interface{})
• func InferShard() (int, error)
• func MaskLeft(s string) string
• func ProcessDataWithFilter(itemType string, key *string, data interface{}, ...) error
• type Sharding
  • func NewSharding(replicas int) *Sharding
  • func (sh *Sharding) InitApplications(applications []unstructured.Unstructured)
  • func (sh *Sharding) ShouldBeProcessed(obj interface{}) bool

Constants

const (
	Base64 string = "^(?:[A-Za-z0-9+\\/]{4})*(?:[A-Za-z0-9+\\/]{2}==|[A-Za-z0-9+\\/]{3}=|[A-Za-z0-9+\\/]{4})$"
)

Functions

func Contains

func Contains(arr []string, element string) bool

func Convert

func Convert(from interface{}, to interface{})

func InferShard

func InferShard() (int, error)

func MaskLeft

func MaskLeft(s string) string

func ProcessDataWithFilter

func ProcessDataWithFilter(itemType string, key *string, data interface{}, comparator func(oldItem interface{}, newItem interface{}) bool, callback func() error) error

Types

type Sharding

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

func NewSharding

func NewSharding(replicas int) *Sharding

func (*Sharding) InitApplications

func (sh *Sharding) InitApplications(applications []unstructured.Unstructured)

func (*Sharding) ShouldBeProcessed

func (sh *Sharding) ShouldBeProcessed(obj interface{}) bool