runnerclient

Documentation

Index

• type Client
  • func NewClient(config *config.Config) (Client, error)
• type LoadOption
• type LoadOptions
  • func (o *LoadOptions) ApplyOptions(opts []LoadOption) *LoadOptions
  • func (o *LoadOptions) ApplyToLoad(lo *LoadOptions)
• type OnceOption
• type OnceOptions
  • func (o *OnceOptions) ApplyOptions(opts []OnceOption) *OnceOptions
  • func (o *OnceOptions) ApplyToOnce(lo *OnceOptions)
• type RunnerClient
  • func NewRunnerClient(config *config.Config) (RunnerClient, error)
• type StartOption
• type StartOptions
  • func (o *StartOptions) ApplyOptions(opts []StartOption) *StartOptions
  • func (o *StartOptions) ApplyToStart(lo *StartOptions)
• type StopOption
• type StopOptions
  • func (o *StopOptions) ApplyOptions(opts []StopOption) *StopOptions
  • func (o *StopOptions) ApplyToStop(lo *StopOptions)

Types

type Client

type Client interface {
	Start(ctx context.Context, opts ...StartOption) error
	Stop(ctx context.Context, opts ...StopOption) error
	Once(ctx context.Context, opts ...OnceOption) (runnerpb.Runner_OnceClient, error)
	Load(ctx context.Context, opts ...LoadOption) error
	Close() error
}

func NewClient

func NewClient(config *config.Config) (Client, error)

type LoadOption

type LoadOption interface {
	ApplyToLoad(*LoadOptions)
}

type LoadOptions

type LoadOptions struct {
	Proxy types.NamespacedName
}

func (*LoadOptions) ApplyOptions

func (o *LoadOptions) ApplyOptions(opts []LoadOption) *LoadOptions

ApplyOptions applies the given get options on these options, and then returns itself (for convenient chaining).

func (*LoadOptions) ApplyToLoad

func (o *LoadOptions) ApplyToLoad(lo *LoadOptions)

type OnceOption

type OnceOption interface {
	ApplyToOnce(*OnceOptions)
}

type OnceOptions

type OnceOptions struct {
	Proxy types.NamespacedName
}

func (*OnceOptions) ApplyOptions

func (o *OnceOptions) ApplyOptions(opts []OnceOption) *OnceOptions

ApplyOptions applies the given get options on these options, and then returns itself (for convenient chaining).

func (*OnceOptions) ApplyToOnce

func (o *OnceOptions) ApplyToOnce(lo *OnceOptions)

type RunnerClient

type RunnerClient interface {
	runnerpb.RunnerClient
	Close() error
}

func NewRunnerClient

func NewRunnerClient(config *config.Config) (RunnerClient, error)

type StartOption

type StartOption interface {
	// ApplyToGet applies this configuration to the given get options.
	ApplyToStart(*StartOptions)
}

type StartOptions

type StartOptions struct {
	Proxy types.NamespacedName
}

func (*StartOptions) ApplyOptions

func (o *StartOptions) ApplyOptions(opts []StartOption) *StartOptions

ApplyOptions applies the given get options on these options, and then returns itself (for convenient chaining).

func (*StartOptions) ApplyToStart

func (o *StartOptions) ApplyToStart(lo *StartOptions)

type StopOption

type StopOption interface {
	ApplyToStop(*StopOptions)
}

type StopOptions

type StopOptions struct {
	Proxy types.NamespacedName
}

func (*StopOptions) ApplyOptions

func (o *StopOptions) ApplyOptions(opts []StopOption) *StopOptions

ApplyOptions applies the given get options on these options, and then returns itself (for convenient chaining).

func (*StopOptions) ApplyToStop

func (o *StopOptions) ApplyToStop(lo *StopOptions)