logs

Documentation

Index

• Variables
• type Controller
  • func NewController(authorizer authz.Authorizer, executionStore store.ExecutionStore, ...) *Controller
  • func ProvideController(authorizer authz.Authorizer, executionStore store.ExecutionStore, ...) *Controller
  • func (c *Controller) Find(ctx context.Context, session *auth.Session, repoRef string, ...) ([]*livelog.Line, error)
  • func (c *Controller) Tail(ctx context.Context, session *auth.Session, repoRef string, ...) (<-chan *livelog.Line, <-chan error, error)

Variables

var WireSet = wire.NewSet(
	ProvideController,
)

WireSet provides a wire set for this package.

Types

type Controller

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

func NewController

func NewController(
	authorizer authz.Authorizer,
	executionStore store.ExecutionStore,
	repoStore store.RepoStore,
	pipelineStore store.PipelineStore,
	stageStore store.StageStore,
	stepStore store.StepStore,
	logStore store.LogStore,
	logStream livelog.LogStream,
) *Controller

func ProvideController

func ProvideController(
	authorizer authz.Authorizer,
	executionStore store.ExecutionStore,
	repoStore store.RepoStore,
	pipelineStore store.PipelineStore,
	stageStore store.StageStore,
	stepStore store.StepStore,
	logStore store.LogStore,
	logStream livelog.LogStream,
) *Controller

func (*Controller) Find

func (c *Controller) Find(
	ctx context.Context,
	session *auth.Session,
	repoRef string,
	pipelineIdentifier string,
	executionNum int64,
	stageNum int,
	stepNum int,
) ([]*livelog.Line, error)

func (*Controller) Tail

func (c *Controller) Tail(
	ctx context.Context,
	session *auth.Session,
	repoRef string,
	pipelineIdentifier string,
	executionNum int64,
	stageNum int,
	stepNum int,
) (<-chan *livelog.Line, <-chan error, error)