client

Documentation

Index

• type TaskGRPCClient
  • func NewTaskGRPCClient(config *viper.Viper) *TaskGRPCClient
  • func (g *TaskGRPCClient) AddTask(namespace, jobName string, spec string, args map[string]interface{}) (*task.TaskReply, error)

Types

type TaskGRPCClient

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

func NewTaskGRPCClient

func NewTaskGRPCClient(config *viper.Viper) *TaskGRPCClient

func (*TaskGRPCClient) AddTask

func (g *TaskGRPCClient) AddTask(namespace, jobName string, spec string, args map[string]interface{}) (*task.TaskReply, error)