harness

Documentation

Index

• Variables
• type Action
  • func NewGRPC(in v1alpha1.Action) Action
• type ActionResult
  • func OK() *ActionResult
  • func (a *ActionResult) GetKeyValue(jsonPath string) (string, error)
• type Harness
  • func (h *Harness) Factory(root context.Context, c controllers.Kube, key string, obj interface{}) error
  • func (h *Harness) GetProcessor(key string) (interface{}, bool)
  • func (h *Harness) Stop(key string)
• type Processor

Variables

var (
	ErrNoKey       = errors.New("provided key not exists in result")
	ErrBadJsonPath = errors.New("bad json path formula")
)

Types

type Action

type Action interface {
	Call(ctx context.Context) (*ActionResult, error)
}

func NewGRPC

func NewGRPC(in v1alpha1.Action) Action

type ActionResult

type ActionResult struct {
	Code string
	Body []byte
}

func OK

func OK() *ActionResult

func (*ActionResult) GetKeyValue

func (a *ActionResult) GetKeyValue(jsonPath string) (string, error)

GetKeyValue look up key in our json representation every time perform JSON marshaling. This is too slow!!!

type Harness

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

func (*Harness) Factory

func (h *Harness) Factory(root context.Context, c controllers.Kube, key string, obj interface{}) error

func (*Harness) GetProcessor

func (h *Harness) GetProcessor(key string) (interface{}, bool)

func (*Harness) Stop

func (h *Harness) Stop(key string)

type Processor

type Processor interface {
	// Start should be blocking operation
	Start(ctx context.Context)
}