controller

Documentation

Index

• Constants
• func Start(cfg *config.Case) error
• func WriteDefaultFlusherConfig(cfg string) error
• type BootController
  • func (c *BootController) CancelChain() *CancelChain
  • func (c *BootController) Clean()
  • func (c *BootController) Init(parent *CancelChain, cfg *config.Case) error
  • func (c *BootController) Start() error
• type CancelChain
  • func WithCancelChain(parent *CancelChain) *CancelChain
  • func (c *CancelChain) CancelChild()
  • func (c *CancelChain) Done() <-chan struct{}
• type Controller
• type HTTPCaseController
  • func (c *HTTPCaseController) CancelChain() *CancelChain
  • func (c *HTTPCaseController) Clean()
  • func (c *HTTPCaseController) Init(parent *CancelChain, cfg *config.Case) error
  • func (c *HTTPCaseController) Start() error
• type LogtailController
  • func (l *LogtailController) CancelChain() *CancelChain
  • func (l *LogtailController) Clean()
  • func (l *LogtailController) Init(parent *CancelChain, fullCfg *config.Case) error
  • func (l *LogtailController) Start() error
• type LogtailPluginController
  • func (c *LogtailPluginController) CancelChain() *CancelChain
  • func (c *LogtailPluginController) Clean()
  • func (c *LogtailPluginController) Init(parent *CancelChain, cfg *config.Case) error
  • func (c *LogtailPluginController) Start() error
• type ProfileController
  • func (p *ProfileController) CancelChain() *CancelChain
  • func (p *ProfileController) Clean()
  • func (p *ProfileController) Init(parent *CancelChain, cfg *config.Case) error
  • func (p *ProfileController) Start() error
• type Reason
• type Report
• type SubscriberController
  • func (c *SubscriberController) CancelChain() *CancelChain
  • func (c *SubscriberController) Clean()
  • func (c *SubscriberController) Init(parent *CancelChain, cfg *config.Case) error
  • func (c *SubscriberController) Start() error
• type ValidatorController
  • func (c *ValidatorController) CancelChain() *CancelChain
  • func (c *ValidatorController) Clean()
  • func (c *ValidatorController) Init(parent *CancelChain, cfg *config.Case) error
  • func (c *ValidatorController) Start() error

Constants

const E2ELogstoreName = "e2e-test-logstore"

const E2EProjectName = "e2e-test-project"

Functions

func Start

func Start(cfg *config.Case) error

Start the E2E test case.

func WriteDefaultFlusherConfig

func WriteDefaultFlusherConfig(cfg string) error

Types

type BootController

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

func (*BootController) CancelChain

func (c *BootController) CancelChain() *CancelChain

func (*BootController) Clean

func (c *BootController) Clean()

func (*BootController) Init

func (c *BootController) Init(parent *CancelChain, cfg *config.Case) error

func (*BootController) Start

func (c *BootController) Start() error

type CancelChain

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

func WithCancelChain

func WithCancelChain(parent *CancelChain) *CancelChain

func (*CancelChain) CancelChild

func (c *CancelChain) CancelChild()

func (*CancelChain) Done

func (c *CancelChain) Done() <-chan struct{}

type Controller

type Controller interface {
	Init(parent *CancelChain, cfg *config.Case) error
	Start() error
	Clean()
	CancelChain() *CancelChain
}

type HTTPCaseController

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

func (*HTTPCaseController) CancelChain

func (c *HTTPCaseController) CancelChain() *CancelChain

func (*HTTPCaseController) Clean

func (c *HTTPCaseController) Clean()

func (*HTTPCaseController) Init

func (c *HTTPCaseController) Init(parent *CancelChain, cfg *config.Case) error

func (*HTTPCaseController) Start

func (c *HTTPCaseController) Start() error

type LogtailController

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

func (*LogtailController) CancelChain

func (l *LogtailController) CancelChain() *CancelChain

func (*LogtailController) Clean

func (l *LogtailController) Clean()

func (*LogtailController) Init

func (l *LogtailController) Init(parent *CancelChain, fullCfg *config.Case) error

func (*LogtailController) Start

func (l *LogtailController) Start() error

type LogtailPluginController

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

func (*LogtailPluginController) CancelChain

func (c *LogtailPluginController) CancelChain() *CancelChain

func (*LogtailPluginController) Clean

func (c *LogtailPluginController) Clean()

func (*LogtailPluginController) Init

func (c *LogtailPluginController) Init(parent *CancelChain, cfg *config.Case) error

func (*LogtailPluginController) Start

func (c *LogtailPluginController) Start() error

type ProfileController

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

func (*ProfileController) CancelChain

func (p *ProfileController) CancelChain() *CancelChain

func (*ProfileController) Clean

func (p *ProfileController) Clean()

func (*ProfileController) Init

func (p *ProfileController) Init(parent *CancelChain, cfg *config.Case) error

func (*ProfileController) Start

func (p *ProfileController) Start() error

nolint:gosec

type Reason

type Reason struct {
	Pass        bool           `json:"pass"`
	FailReasons map[string]int `json:"fail_reasons"`
}

type Report

type Report struct {
	Pass               bool                                 `json:"pass"`
	RowLogCount        int                                  `json:"row_log_count"`
	ProcessedLogCount  int                                  `json:"processed_log_count"`
	FlushLogCount      int                                  `json:"flush_log_count"`
	FlushLogGroupCount int                                  `json:"flush_log_group"`
	AlarmLogs          map[string]map[string]map[string]int `json:"alarm_logs"`
	LogReports         map[string]*Reason                   `json:"log_reports"`
	TagReports         map[string]*Reason                   `json:"tag_reports"`
	TotalReports       map[string]*Reason                   `json:"total_reports"`
}

type SubscriberController

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

func (*SubscriberController) CancelChain

func (c *SubscriberController) CancelChain() *CancelChain

func (*SubscriberController) Clean

func (c *SubscriberController) Clean()

func (*SubscriberController) Init

func (c *SubscriberController) Init(parent *CancelChain, cfg *config.Case) error

func (*SubscriberController) Start

func (c *SubscriberController) Start() error

type ValidatorController

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

func (*ValidatorController) CancelChain

func (c *ValidatorController) CancelChain() *CancelChain

func (*ValidatorController) Clean

func (c *ValidatorController) Clean()

func (*ValidatorController) Init

func (c *ValidatorController) Init(parent *CancelChain, cfg *config.Case) error

func (*ValidatorController) Start

func (c *ValidatorController) Start() error