local

Documentation

Index

• func ResolveAddress(ctx context.Context, address string) string
• type LocalPublisherServer
  • func NewLocalPublisherServer(ctx context.Context, directory string, port int) *LocalPublisherServer
  • func (s *LocalPublisherServer) Run(ctx context.Context)
• type Publisher
  • func NewLocalPublisher(ctx context.Context, directory string, host string, port int) *Publisher
  • func (p *Publisher) IsInstalled(ctx context.Context) (bool, error)
  • func (p *Publisher) PublishResult(ctx context.Context, execution *models.Execution, resultPath string) (models.SpecConfig, error)
  • func (p *Publisher) ValidateJob(ctx context.Context, j models.Job) error

Functions

func ResolveAddress

func ResolveAddress(ctx context.Context, address string) string

Types

type LocalPublisherServer

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

func NewLocalPublisherServer

func NewLocalPublisherServer(ctx context.Context, directory string, port int) *LocalPublisherServer

func (*LocalPublisherServer) Run

func (s *LocalPublisherServer) Run(ctx context.Context)

type Publisher

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

func NewLocalPublisher

func NewLocalPublisher(ctx context.Context, directory string, host string, port int) *Publisher

func (*Publisher) IsInstalled

func (p *Publisher) IsInstalled(ctx context.Context) (bool, error)

IsInstalled checks if the publisher is installed and it determines this based on the presence of the base directory and a local server.

func (*Publisher) PublishResult

func (p *Publisher) PublishResult(
	ctx context.Context, execution *models.Execution, resultPath string) (models.SpecConfig, error)

func (*Publisher) ValidateJob

func (p *Publisher) ValidateJob(ctx context.Context, j models.Job) error