dscheduler

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type SchedulerClient interface {
	// List scheduled tasks
	List(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TaskList, error)
	// Add new task to scheduler.
	// Returns same Task message with initialized id field
	Add(ctx context.Context, in *Task, opts ...grpc.CallOption) (*Task, error)
	// Remove task from scheduler. Only id field is significant
	// with this function. Other Task's fields are ignored.
	Remove(ctx context.Context, in *Task, opts ...grpc.CallOption) (*Empty, error)
	// Remove all scheduled tasks
	RemoveAll(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
}

type SchedulerServer interface {
	// List scheduled tasks
	List(context.Context, *Empty) (*TaskList, error)
	// Add new task to scheduler.
	// Returns same Task message with initialized id field
	Add(context.Context, *Task) (*Task, error)
	// Remove task from scheduler. Only id field is significant
	// with this function. Other Task's fields are ignored.
	Remove(context.Context, *Task) (*Empty, error)
	// Remove all scheduled tasks
	RemoveAll(context.Context, *Empty) (*Empty, error)
}

type Task struct {
	Id                   uint32   `protobuf:"varint,10,opt,name=id,proto3" json:"id,omitempty"`
	Cron                 string   `protobuf:"bytes,20,opt,name=cron,proto3" json:"cron,omitempty"`
	Action               string   `protobuf:"bytes,30,opt,name=action,proto3" json:"action,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type TaskList struct {
	Tasks                []*Task  `protobuf:"bytes,10,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}