pipeline_manager

Documentation

Index

• type Options
  • func NewOptions() *Options
• type PipelineManager
  • func NewPipelineManager(options *Options) *PipelineManager
  • func NewPipelineManagerWithClient(client *core.Client, options *Options) *PipelineManager
  • func (pm *PipelineManager) Connect(host string, options *core.Options) error
  • func (pm *PipelineManager) Disconnect()
  • func (pm *PipelineManager) GetEndpoint() (*core.Endpoint, error)
  • func (pm *PipelineManager) GetPipelineCount() (uint64, error)

Types

type Options

type Options struct {
	Endpoint string
	Domain   string
	Key      *keyring.KeyInfo
	Verbose  bool
}

func NewOptions

func NewOptions() *Options

type PipelineManager

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

func NewPipelineManager

func NewPipelineManager(options *Options) *PipelineManager

func NewPipelineManagerWithClient

func NewPipelineManagerWithClient(client *core.Client, options *Options) *PipelineManager

func (*PipelineManager) Connect

func (pm *PipelineManager) Connect(host string, options *core.Options) error

func (*PipelineManager) Disconnect

func (pm *PipelineManager) Disconnect()

func (*PipelineManager) GetEndpoint

func (pm *PipelineManager) GetEndpoint() (*core.Endpoint, error)

func (*PipelineManager) GetPipelineCount

func (pm *PipelineManager) GetPipelineCount() (uint64, error)