model

Documentation

Index

• Constants
• type BufferConfig
• type ChannelInfo
• type CollectionInfo
• type DatabaseInfo
• type ExtraInfo
• type KafkaConnectParam
• type KafkaSASL
• type MilvusConnectParam
• type NameMapping

Constants

const (
	// TmpCollectionID which means it's the user custom collection position
	TmpCollectionID int64 = -1
	// TmpCollectionName TODO if replicate the rbac info, the collection id will be set it
	TmpCollectionName = "-1"

	ReplicateCollectionID   int64 = -10
	ReplicateCollectionName       = "-10"
)

Types

type BufferConfig

type BufferConfig struct {
	Period int `json:"period" mapstructure:"period"`
	Size   int `json:"size" mapstructure:"size"`
}

type ChannelInfo

type ChannelInfo struct {
	Name     string `json:"name" mapstructure:"name"`
	Position string `json:"position" mapstructure:"position"`
}

type CollectionInfo

type CollectionInfo struct {
	Name             string            `json:"name" mapstructure:"name"`
	Positions        map[string]string `json:"positions" mapstructure:"positions"` // the key is the vchannel
	UseStartPosition bool              `json:"use_start_position" mapstructure:"use_start_position"`
}

type DatabaseInfo

type DatabaseInfo struct {
	Name string `json:"name" mapstructure:"name"`
}

type ExtraInfo

type ExtraInfo struct {
	EnableUserRole bool `json:"enable_user_role" mapstructure:"enable_user_role"`
}

type KafkaConnectParam

type KafkaConnectParam struct {
	Address    string    `json:"address" mapstructure:"address"`
	Topic      string    `json:"topic" mapstructure:"topic"`
	EnableSASL bool      `json:"enable_sasl" mapstructure:"enable_sasl"`
	SASL       KafkaSASL `json:"sasl,omitempty" mapstructure:"sasl,omitempty"`
}

type KafkaSASL

type KafkaSASL struct {
	Username         string `json:"username,omitempty" mapstructure:"username,omitempty"`
	Password         string `json:"password,omitempty" mapstructure:"password,omitempty"`
	Mechanisms       string `json:"mechanisms,omitempty" mapstructure:"mechanisms,omitempty"`
	SecurityProtocol string `json:"security_protocol,omitempty" mapstructure:"security_protocol,omitempty"`
}

type MilvusConnectParam

type MilvusConnectParam struct {
	// Deprecated: use uri instead
	Host string `json:"host" mapstructure:"host"`
	// Deprecated: use uri instead
	Port int `json:"port" mapstructure:"port"`
	// Deprecated: use uri instead
	EnableTLS bool `json:"enable_tls" mapstructure:"enable_tls"`
	// Deprecated: use token instead
	Username string `json:"username,omitempty" mapstructure:"username,omitempty"`
	// Deprecated: use token instead
	Password        string          `json:"password,omitempty" mapstructure:"password,omitempty"`
	URI             string          `json:"uri" mapstructure:"uri"`
	Token           string          `json:"token,omitempty" mapstructure:"token,omitempty"`
	DialConfig      util.DialConfig `json:"dial_config,omitempty" mapstructure:"dial_config,omitempty"`
	ChannelNum      int             `json:"channel_num" mapstructure:"channel_num"`
	IgnorePartition bool            `json:"ignore_partition" mapstructure:"ignore_partition"`
	// ConnectTimeout unit: s
	ConnectTimeout int `json:"connect_timeout" mapstructure:"connect_timeout"`
}

type NameMapping

type NameMapping struct {
	SourceDB          string            `json:"source_db" mapstructure:"source_db"`
	TargetDB          string            `json:"target_db" mapstructure:"target_db"`
	CollectionMapping map[string]string `json:"collection_mapping" mapstructure:"collection_mapping"`
}