replay

type AlterChannelIdBeforeSendHandlerFunc func(channelId uint32, msgType channeldpb.MessageType, msgPack *channeldpb.MessagePack, c *client.ChanneldClient) (chId uint32, needToSend bool)

type BeforeSendMessageHandlerFunc func(msg proto.Message, msgPack *channeldpb.MessagePack, c *client.ChanneldClient) (needToSend bool)

type CaseConfig struct {
	ChanneldAddr     string                  `json:"channeldAddr"`
	ConnectionGroups []ConnectionGroupConfig `json:"connectionGroups"`
}

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

type ConnectionGroupConfig struct {
	CprFilePath              string   `json:"cprFilePath"`
	ConnectionNumber         int      `json:"connectionNumber"`         // Number of connections
	ConnectInterval          Duration `json:"connectInterval"`          // start connections interval
	RunningTime              Duration `json:"runningTime"`              // replay session running time
	SleepEndOfSession        Duration `json:"sleepEndOfSession"`        // sleep each end of session
	MaxTickInterval          Duration `json:"maxTickInterval"`          // channeld connection max tick time
	ActionIntervalMultiplier float64  `json:"actionIntervalMultiplier"` // used to adjust the packet offsettime (ActionIntervalMultiplier * ReplayPacket.Offsettime)
	WaitAuthSuccess          bool     `json:"waitAuthSuccess"`          // if true, replay loop will wait for auth success
	AuthOnlyOnce             bool     `json:"authOnlyOnce"`             // if true, only send auth message once in the entire replay
}

type Duration time.Duration

type MessageHandlerFunc func(c *client.ChanneldClient, channelId uint32, m proto.Message)

type NeedWaitMessageCallbackHandlerFunc func(msgType channeldpb.MessageType, msgPack *channeldpb.MessagePack, c *client.ChanneldClient) bool

type ReplayClient struct {
	CaseConfig       CaseConfig
	ConnectionGroups []ConnectionGroup
	// contains filtered or unexported fields
}