driver

Documentation

Index

• Variables
• func Check(name string, cfg string) error
• func Register(driver IDriver)
• type IAIOverview
• type IBasicOverview
• type IDriver
  • func Get(name string) (IDriver, bool)
• type IExecutor
  • func CreateExecutor(name string, cfg string) (IExecutor, error)
• type IRestOverview
• type Manager
  • func NewManager() *Manager
  • func (m *Manager) Get(name string) (IDriver, bool)
  • func (m *Manager) Names() []string
  • func (m *Manager) Register(driver IDriver)

Variables

var (
	ErrDriverNotFound = errors.New("driver not found")
)

Functions

func Check

func Check(name string, cfg string) error

func Register

func Register(driver IDriver)

Types

type IAIOverview

type IAIOverview interface {
	TokenOverview(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) ([]time.Time, *monitor.TokenOverview, []*monitor.TokenOverview, error)
}

type IBasicOverview

type IBasicOverview interface {
	RequestOverview(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) ([]time.Time, *monitor.StatusCodeOverview, []*monitor.StatusCodeOverview, error)
	TopN(ctx context.Context, start time.Time, end time.Time, limit int, groupBy string, wheres []monitor.MonWhereItem) ([]*monitor.TopN, error)
	ConsumerOverview(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) (int64, map[time.Time]int64, error)
}

type IDriver

type IDriver interface {
	Name() string
	Check(cfg string) error
	Create(cfg string) (IExecutor, error)
}

func Get

func Get(name string) (IDriver, bool)

type IExecutor

type IExecutor interface {
	Init(ctx context.Context) error
	CommonStatistics(ctx context.Context, start, end time.Time, groupBy string, limit int, wheres []monitor.MonWhereItem) (map[string]monitor.MonCommonData, error)
	RequestSummary(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) (*monitor.Summary, error)
	ProxySummary(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) (*monitor.Summary, error)
	InvokeTrend(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) (*monitor.MonInvokeCountTrend, string, error)
	ProxyTrend(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) (*monitor.MonInvokeCountTrend, string, error)
	MessageTrend(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) (*monitor.MonMessageTrend, string, error)

	IBasicOverview

	IRestOverview

	IAIOverview
}

func CreateExecutor

func CreateExecutor(name string, cfg string) (IExecutor, error)

type IRestOverview

type IRestOverview interface {
	TrafficOverviewByStatusCode(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) ([]time.Time, *monitor.StatusCodeOverview, []*monitor.StatusCodeOverview, error)
	AvgResponseTimeOverview(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) ([]time.Time, *monitor.Aggregate, []int64, error)
	SumResponseTimeOverview(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) ([]time.Time, *monitor.Aggregate, []int64, error)
}

type Manager

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

func NewManager

func NewManager() *Manager

func (*Manager) Get

func (m *Manager) Get(name string) (IDriver, bool)

func (*Manager) Names

func (m *Manager) Names() []string

func (*Manager) Register

func (m *Manager) Register(driver IDriver)