targets

Documentation

Index

• func GetTargetEnvVars(target *models.Target, params TargetEnvVarParams) map[string]string
• func NewTargetService(config TargetServiceConfig) services.ITargetService
• type TargetEnvVarParams
• type TargetService
  • func (s *TargetService) Create(ctx context.Context, req services.CreateTargetDTO) (*models.Target, error)
  • func (s *TargetService) Delete(ctx context.Context, targetId string) error
  • func (s *TargetService) Find(ctx context.Context, filter *stores.TargetFilter, ...) (*services.TargetDTO, error)
  • func (s *TargetService) ForceDelete(ctx context.Context, targetId string) error
  • func (s *TargetService) GetTargetLogReader(ctx context.Context, targetId string) (io.Reader, error)
  • func (s *TargetService) GetTargetLogWriter(ctx context.Context, targetId string) (io.WriteCloser, error)
  • func (s *TargetService) HandleSuccessfulCreation(ctx context.Context, targetId string) error
  • func (s *TargetService) List(ctx context.Context, filter *stores.TargetFilter, ...) ([]services.TargetDTO, error)
  • func (s *TargetService) Restart(ctx context.Context, targetId string) error
  • func (s *TargetService) Save(ctx context.Context, target *models.Target) error
  • func (s *TargetService) SetDefault(ctx context.Context, id string) error
  • func (s *TargetService) Start(ctx context.Context, targetId string) error
  • func (s *TargetService) Stop(ctx context.Context, targetId string) error
  • func (s *TargetService) UpdateLastJob(ctx context.Context, targetId, jobId string) error
  • func (s *TargetService) UpdateMetadata(ctx context.Context, targetId string, metadata *models.TargetMetadata) (*models.TargetMetadata, error)
  • func (s *TargetService) UpdateProviderMetadata(ctx context.Context, targetId, metadata string) error
• type TargetServiceConfig

Functions

func GetTargetEnvVars

func GetTargetEnvVars(target *models.Target, params TargetEnvVarParams) map[string]string

func NewTargetService

func NewTargetService(config TargetServiceConfig) services.ITargetService

Types

type TargetEnvVarParams

type TargetEnvVarParams struct {
	ApiUrl           string
	ServerUrl        string
	ServerVersion    string
	ClientId         string
	TelemetryEnabled bool
}

type TargetService

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

func (*TargetService) Create

func (s *TargetService) Create(ctx context.Context, req services.CreateTargetDTO) (*models.Target, error)

func (*TargetService) Delete

func (s *TargetService) Delete(ctx context.Context, targetId string) error

func (*TargetService) Find

func (s *TargetService) Find(ctx context.Context, filter *stores.TargetFilter, params services.TargetRetrievalParams) (*services.TargetDTO, error)

func (*TargetService) ForceDelete

func (s *TargetService) ForceDelete(ctx context.Context, targetId string) error

ForceDelete ignores provider errors and makes sure the target is deleted from storage.

func (*TargetService) GetTargetLogReader

func (s *TargetService) GetTargetLogReader(ctx context.Context, targetId string) (io.Reader, error)

func (*TargetService) GetTargetLogWriter

func (s *TargetService) GetTargetLogWriter(ctx context.Context, targetId string) (io.WriteCloser, error)

func (*TargetService) HandleSuccessfulCreation

func (s *TargetService) HandleSuccessfulCreation(ctx context.Context, targetId string) error

func (*TargetService) List

func (s *TargetService) List(ctx context.Context, filter *stores.TargetFilter, params services.TargetRetrievalParams) ([]services.TargetDTO, error)

func (*TargetService) Restart

func (s *TargetService) Restart(ctx context.Context, targetId string) error

func (*TargetService) Save

func (s *TargetService) Save(ctx context.Context, target *models.Target) error

TODO: revise - "remove default" is enough for now

func (*TargetService) SetDefault

func (s *TargetService) SetDefault(ctx context.Context, id string) error

func (*TargetService) Start

func (s *TargetService) Start(ctx context.Context, targetId string) error

func (*TargetService) Stop

func (s *TargetService) Stop(ctx context.Context, targetId string) error

func (*TargetService) UpdateLastJob

func (s *TargetService) UpdateLastJob(ctx context.Context, targetId, jobId string) error

func (*TargetService) UpdateMetadata

func (s *TargetService) UpdateMetadata(ctx context.Context, targetId string, metadata *models.TargetMetadata) (*models.TargetMetadata, error)

func (*TargetService) UpdateProviderMetadata

func (s *TargetService) UpdateProviderMetadata(ctx context.Context, targetId, metadata string) error

type TargetServiceConfig

type TargetServiceConfig struct {
	TargetStore         stores.TargetStore
	TargetMetadataStore stores.TargetMetadataStore

	FindTargetConfig    func(ctx context.Context, name string) (*models.TargetConfig, error)
	CreateApiKey        func(ctx context.Context, name string) (string, error)
	DeleteApiKey        func(ctx context.Context, name string) error
	CreateJob           func(ctx context.Context, targetId string, runnerId string, action models.JobAction) error
	TrackTelemetryEvent func(event telemetry.Event, clientId string) error

	ServerApiUrl  string
	ServerUrl     string
	ServerVersion string
	LoggerFactory logs.ILoggerFactory
}