service

Documentation

Index

• func RunTasks(logger logr.Logger, service Service, tasks []proto.Task) error
• type Service
  • func New(logger logr.Logger, actions []proto.Action, probes []proto.Probe, ...) ([]Service, error)

Functions

func RunTasks

func RunTasks(logger logr.Logger, service Service, tasks []proto.Task) error

Types

type Service

type Service interface {
	Kind() string
	URI() string

	Start() error

	HandleConn(ctx context.Context, conn net.Conn) error

	HandleRequest(ctx context.Context, payload []byte) ([]byte, error)
}

func New

func New(logger logr.Logger, actions []proto.Action, probes []proto.Probe, streaming []string) ([]Service, error)