client

Documentation

Index

• type RestClient
  • func New(bitfanHost string) *RestClient
  • func (r *RestClient) Asset(UUID string) (*models.Asset, error)
  • func (r *RestClient) CheckSyntax(asset *models.Asset) (map[string]interface{}, error)
  • func (r *RestClient) DeleteAsset(UUID string) error
  • func (r *RestClient) DeletePipeline(UUID string) error
  • func (r *RestClient) DeleteXProcessor(UUID string) error
  • func (r *RestClient) Envs() ([]models.Env, error)
  • func (r *RestClient) NewAsset(initAsset *models.Asset) (*models.Asset, error)
  • func (r *RestClient) NewPipeline(pipeline *models.Pipeline) (*models.Pipeline, error)
  • func (r *RestClient) NewXProcessor(xprocessor *models.XProcessor) (*models.XProcessor, error)
  • func (r *RestClient) Pipeline(ID string) (*models.Pipeline, error)
  • func (r *RestClient) Pipelines() ([]models.Pipeline, error)
  • func (r *RestClient) ReplaceAsset(UUID string, initAsset *models.Asset) (*models.Asset, error)
  • func (r *RestClient) StartPipeline(UUID string) (*models.Pipeline, error)
  • func (r *RestClient) StopPipeline(UUID string) (*models.Pipeline, error)
  • func (r *RestClient) UpdateAsset(UUID string, data *map[string]interface{}) (*models.Asset, error)
  • func (r *RestClient) UpdatePipeline(UUID string, data *map[string]interface{}) (*models.Pipeline, error)
  • func (r *RestClient) UpdateXProcessor(UUID string, data *map[string]interface{}) (*models.XProcessor, error)
  • func (r *RestClient) XProcessor(ID string) (*models.XProcessor, error)
  • func (r *RestClient) XProcessors(behavior string) ([]models.XProcessor, error)

Types

type RestClient

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

func New

func New(bitfanHost string) *RestClient

func (*RestClient) Asset

func (r *RestClient) Asset(UUID string) (*models.Asset, error)

func (*RestClient) CheckSyntax

func (r *RestClient) CheckSyntax(asset *models.Asset) (map[string]interface{}, error)

func (*RestClient) DeleteAsset

func (r *RestClient) DeleteAsset(UUID string) error

func (*RestClient) DeletePipeline

func (r *RestClient) DeletePipeline(UUID string) error

func (*RestClient) DeleteXProcessor

func (r *RestClient) DeleteXProcessor(UUID string) error

func (*RestClient) Envs

func (r *RestClient) Envs() ([]models.Env, error)

func (*RestClient) NewAsset

func (r *RestClient) NewAsset(initAsset *models.Asset) (*models.Asset, error)

func (*RestClient) NewPipeline

func (r *RestClient) NewPipeline(pipeline *models.Pipeline) (*models.Pipeline, error)

func (*RestClient) NewXProcessor

func (r *RestClient) NewXProcessor(xprocessor *models.XProcessor) (*models.XProcessor, error)

func (*RestClient) Pipeline

func (r *RestClient) Pipeline(ID string) (*models.Pipeline, error)

func (*RestClient) Pipelines

func (r *RestClient) Pipelines() ([]models.Pipeline, error)

func (*RestClient) ReplaceAsset

func (r *RestClient) ReplaceAsset(UUID string, initAsset *models.Asset) (*models.Asset, error)

func (*RestClient) StartPipeline

func (r *RestClient) StartPipeline(UUID string) (*models.Pipeline, error)

func (*RestClient) StopPipeline

func (r *RestClient) StopPipeline(UUID string) (*models.Pipeline, error)

func (*RestClient) UpdateAsset

func (r *RestClient) UpdateAsset(UUID string, data *map[string]interface{}) (*models.Asset, error)

func (*RestClient) UpdatePipeline

func (r *RestClient) UpdatePipeline(UUID string, data *map[string]interface{}) (*models.Pipeline, error)

func (*RestClient) UpdateXProcessor

func (r *RestClient) UpdateXProcessor(UUID string, data *map[string]interface{}) (*models.XProcessor, error)

func (*RestClient) XProcessor

func (r *RestClient) XProcessor(ID string) (*models.XProcessor, error)

func (*RestClient) XProcessors

func (r *RestClient) XProcessors(behavior string) ([]models.XProcessor, error)