workload

Documentation

Index

• type EventHandler
  • func NewEventHandler() *EventHandler
  • func (e *EventHandler) Handle(action string, h func(context.Context, *types.WorkloadEventMessage))
  • func (e *EventHandler) Watch(ctx context.Context, c <-chan *types.WorkloadEventMessage)
• type Manager
  • func NewManager(ctx context.Context, config *types.Config) (*Manager, error)
  • func (m *Manager) PullLog(ctx context.Context, app string, buf *bufio.ReadWriter)
  • func (m *Manager) Run(ctx context.Context) error

Types

type EventHandler

type EventHandler struct {
	sync.Mutex
	// contains filtered or unexported fields
}

EventHandler define event handler

func NewEventHandler

func NewEventHandler() *EventHandler

NewEventHandler new a event handler

func (*EventHandler) Handle

func (e *EventHandler) Handle(action string, h func(context.Context, *types.WorkloadEventMessage))

Handle hand a event

func (*EventHandler) Watch

func (e *EventHandler) Watch(ctx context.Context, c <-chan *types.WorkloadEventMessage)

Watch watch change

type Manager

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

Manager .

func NewManager

func NewManager(ctx context.Context, config *types.Config) (*Manager, error)

NewManager returns a workload manager

func (*Manager) PullLog

func (m *Manager) PullLog(ctx context.Context, app string, buf *bufio.ReadWriter)

PullLog pull logs for specific app

func (*Manager) Run

func (m *Manager) Run(ctx context.Context) error

Run will start agent blocks by ctx.Done() either call this in a separated goroutine, or used in main to block main goroutine