pipeline

Documentation

Index

• Variables
• func NewClient() *resty.Client
• func Start(lc fx.Lifecycle, service *Service, logger *zap.Logger) error
• type Service
  • func NewService(client *resty.Client, cfg *pipeline.Config) *Service
  • func (s *Service) Create(ctx context.Context) context.Context
  • func (s *Service) Delete(ctx context.Context) context.Context
  • func (s *Service) Get(ctx context.Context) context.Context
  • func (s *Service) Update(ctx context.Context) context.Context

Variables

var (
	// CreateFlag defines the pipeline path to create a pipeline.
	CreateFlag = flags.String()

	// GetFlag defines a pipeline id to be retrieved.
	GetFlag = flags.String()

	// GetFlag defines the id and pipeline path to update.
	UpdateFlag = flags.String()

	// DeleteFlag defines a pipeline to be deleted by the provided id.
	DeleteFlag = flags.String()
)

var Module = fx.Options(
	fx.Provide(NewClient),
	fx.Provide(NewService),
	fx.Invoke(Start),
)

Module for fx.

Functions

func NewClient

func NewClient() *resty.Client

NewClient for pipeline.

func Start

func Start(lc fx.Lifecycle, service *Service, logger *zap.Logger) error

Start for redis.

Types

type Service

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

Service for pipeline.

func NewService

func NewService(client *resty.Client, cfg *pipeline.Config) *Service

NewService for pipeline.

func (*Service) Create

func (s *Service) Create(ctx context.Context) context.Context

Create a pipeline.

func (*Service) Delete

func (s *Service) Delete(ctx context.Context) context.Context

Delete a pipeline.

func (*Service) Get

func (s *Service) Get(ctx context.Context) context.Context

Get a pipelines.

func (*Service) Update

func (s *Service) Update(ctx context.Context) context.Context

Update a pipeline.