agent

Documentation

Index

• type Agent
  • func New(client *kubernetes.Clientset, sdk *sdk.Sdk) (*Agent, error)
  • func (a *Agent) Handle(run sdk.Run) error
  • func (a *Agent) PollLogs(closer io.ReadCloser) error
  • func (a *Agent) RegisterSink(sink io.Writer)
  • func (a *Agent) Run() error
  • func (a *Agent) Write(p []byte) (int, error)
• type ChangeSink
  • func (sink ChangeSink) Write(p []byte) (int, error)
• type ChangeSummary
• type ChangeSummaryChange

Types

type Agent

type Agent struct {
	Client *kubernetes.Clientset
	Sdk    *sdk.Sdk
	// contains filtered or unexported fields
}

func New

func New(client *kubernetes.Clientset, sdk *sdk.Sdk) (*Agent, error)

func (*Agent) Handle

func (a *Agent) Handle(run sdk.Run) error

func (*Agent) PollLogs

func (a *Agent) PollLogs(closer io.ReadCloser) error

func (*Agent) RegisterSink

func (a *Agent) RegisterSink(sink io.Writer)

func (*Agent) Run

func (a *Agent) Run() error

func (*Agent) Write

func (a *Agent) Write(p []byte) (int, error)

type ChangeSink

type ChangeSink struct {
	Sdk   *sdk.Sdk
	RunId string
}

func (ChangeSink) Write

func (sink ChangeSink) Write(p []byte) (int, error)

type ChangeSummary

type ChangeSummary struct {
	Type    string              `json:"type"`
	Changes ChangeSummaryChange `json:"changes"`
}

type ChangeSummaryChange

type ChangeSummaryChange struct {
	Add       int    `json:"add"`
	Change    int    `json:"change"`
	Remove    int    `json:"remove"`
	Import    int    `json:"import"`
	Operation string `json:"operation"`
}