package calls

import "github.com/mesos/mesos-go/api/v1/lib/executor/calls"

Index ¶

• func CallNoData(ctx context.Context, caller Caller, call *executor.Call) error
• func Executor(id string) executor.CallOpt
• func Framework(id string) executor.CallOpt
• func Message(data []byte) *executor.Call
• func Subscribe(unackdTasks []mesos.TaskInfo, unackdUpdates []executor.Call_Update) *executor.Call
• func Update(status mesos.TaskStatus) *executor.Call
• type Caller
• type CallerFunc
• func (f CallerFunc) Call(ctx context.Context, c *executor.Call) (mesos.Response, error)

Functions ¶

func CallNoData ¶

func CallNoData(ctx context.Context, caller Caller, call *executor.Call) error

CallNoData is a convenience func that executes the given Call using the provided Caller and always drops the response data.

func Executor ¶

func Executor(id string) executor.CallOpt

Executor sets a executor.Call's ExecutorID

func Framework ¶

func Framework(id string) executor.CallOpt

Framework sets a executor.Call's FrameworkID

func Message ¶

func Message(data []byte) *executor.Call

Message returns an executor call with the given parameters.

func Subscribe ¶

func Subscribe(unackdTasks []mesos.TaskInfo, unackdUpdates []executor.Call_Update) *executor.Call

Subscribe returns an executor call with the given parameters.

func Update ¶

func Update(status mesos.TaskStatus) *executor.Call

Update returns an executor call with the given parameters.

Types ¶

type Caller ¶

type Caller interface {
	// Call issues a call to Mesos and properly manages call-specific HTTP response headers & data.
	Call(context.Context, *executor.Call) (mesos.Response, error)
}

Caller is the public interface this framework scheduler's should consume

type CallerFunc ¶

type CallerFunc func(context.Context, *executor.Call) (mesos.Response, error)

CallerFunc is the functional adaptation of the Caller interface

func (CallerFunc) Call ¶

func (f CallerFunc) Call(ctx context.Context, c *executor.Call) (mesos.Response, error)

Call implements the Caller interface for CallerFunc

Source Files ¶

calls.go calls_generated.go gen.go