util

Documentation

Index

• func CalculateNumberOfCollector(topicCount int, maxHostCount int) int
• func CheckMCISType(serviceType string) bool
• func CheckMCK8SType(serviceType string) bool
• func DeploymentTemplate(collectorCreateOrder int, collectorUUID string, env []apiv1.EnvVar) *appsv1.Deployment
• func GetAllTopicBySort(topicsSlice []string) []string
• func GetCspCollectorIdx(topic string) (collectorIdx int)
• func GetFields(val reflect.Value) []string
• func GetLogger() *logrus.Logger
• func GetMCK8SRingQueue() *queue.Queue
• func GetRingQueue() *queue.Queue
• func Initialize() error
• func Int32Ptr(i int32) *int32
• func Int64Ptr(i int64) *int64
• func MakeCollectorTopicMap(allTopics []string, maxHostCount int) (map[int][]string, []int)
• func MergeTopicsToOneString(topicsSlice []string) string
• func PutMCK8SRingQueue(topicManagePolicy string, topic string) error
• func ReturnDiffTopicList(a, b []string) (diff []string)
• func RingQueuePut(topicManagePolicy string, topic string) error
• func RunCommand(vmIP string, userName string, privateKey string, cmd string) (*string, error)
• func SplitOneStringToTopicsSlice(topicsStrings string) []string
• func StructToMap(i interface{}) (values url.Values)
• func ToFixed(num float64, precision int) float64
• func ToMap(val interface{}) (map[string]interface{}, error)
• func Unique(slice []string, sortOption bool) []string
• type KafkaStruct
  • func GetInstance() (*KafkaStruct, error)
• type TopicStructure

Functions

func CalculateNumberOfCollector

func CalculateNumberOfCollector(topicCount int, maxHostCount int) int

func CheckMCISType

func CheckMCISType(serviceType string) bool

func CheckMCK8SType

func CheckMCK8SType(serviceType string) bool

func DeploymentTemplate

func DeploymentTemplate(collectorCreateOrder int, collectorUUID string, env []apiv1.EnvVar) *appsv1.Deployment

func GetAllTopicBySort

func GetAllTopicBySort(topicsSlice []string) []string

func GetCspCollectorIdx

func GetCspCollectorIdx(topic string) (collectorIdx int)

func GetFields

func GetFields(val reflect.Value) []string

func GetLogger

func GetLogger() *logrus.Logger

func GetMCK8SRingQueue

func GetMCK8SRingQueue() *queue.Queue

func GetRingQueue

func GetRingQueue() *queue.Queue

func Initialize

func Initialize() error

TODO: Broker connection close logic

defer func() {
	if err := kafka.Close(); err != nil {
		panic(err)
	}
}()

func Int32Ptr

func Int32Ptr(i int32) *int32

func Int64Ptr

func Int64Ptr(i int64) *int64

func MakeCollectorTopicMap

func MakeCollectorTopicMap(allTopics []string, maxHostCount int) (map[int][]string, []int)

func MergeTopicsToOneString

func MergeTopicsToOneString(topicsSlice []string) string

func PutMCK8SRingQueue

func PutMCK8SRingQueue(topicManagePolicy string, topic string) error

func ReturnDiffTopicList

func ReturnDiffTopicList(a, b []string) (diff []string)

func RingQueuePut

func RingQueuePut(topicManagePolicy string, topic string) error

func RunCommand

func RunCommand(vmIP string, userName string, privateKey string, cmd string) (*string, error)

func SplitOneStringToTopicsSlice

func SplitOneStringToTopicsSlice(topicsStrings string) []string

func StructToMap

func StructToMap(i interface{}) (values url.Values)

func ToFixed

func ToFixed(num float64, precision int) float64

func ToMap

func ToMap(val interface{}) (map[string]interface{}, error)

func Unique

func Unique(slice []string, sortOption bool) []string

Types

type KafkaStruct

type KafkaStruct struct {
	AdminClient    *kafka.AdminClient
	ConsumerClient *kafka.Consumer
}

func GetInstance

func GetInstance() (*KafkaStruct, error)

type TopicStructure

type TopicStructure struct {
	Policy string
	Topic  string
}